aboutsummaryrefslogtreecommitdiffstats
path: root/net/rds/iw_send.c
diff options
context:
space:
mode:
Diffstat (limited to 'net/rds/iw_send.c')
-rw-r--r--net/rds/iw_send.c16
1 files changed, 8 insertions, 8 deletions
diff --git a/net/rds/iw_send.c b/net/rds/iw_send.c
index 62234b804d93..9b79a1b10445 100644
--- a/net/rds/iw_send.c
+++ b/net/rds/iw_send.c
@@ -85,8 +85,8 @@ static void rds_iw_send_unmap_rm(struct rds_iw_connection *ic,
85 rm->data.m_sg, rm->data.m_nents, 85 rm->data.m_sg, rm->data.m_nents,
86 DMA_TO_DEVICE); 86 DMA_TO_DEVICE);
87 87
88 if (rm->rdma.m_rdma_op) { 88 if (rm->rdma.m_rdma_op.r_active) {
89 rds_iw_send_unmap_rdma(ic, rm->rdma.m_rdma_op); 89 rds_iw_send_unmap_rdma(ic, &rm->rdma.m_rdma_op);
90 90
91 /* If the user asked for a completion notification on this 91 /* If the user asked for a completion notification on this
92 * message, we can implement three different semantics: 92 * message, we can implement three different semantics:
@@ -110,10 +110,10 @@ static void rds_iw_send_unmap_rm(struct rds_iw_connection *ic,
110 */ 110 */
111 rds_iw_send_rdma_complete(rm, wc_status); 111 rds_iw_send_rdma_complete(rm, wc_status);
112 112
113 if (rm->rdma.m_rdma_op->r_write) 113 if (rm->rdma.m_rdma_op.r_write)
114 rds_stats_add(s_send_rdma_bytes, rm->rdma.m_rdma_op->r_bytes); 114 rds_stats_add(s_send_rdma_bytes, rm->rdma.m_rdma_op.r_bytes);
115 else 115 else
116 rds_stats_add(s_recv_rdma_bytes, rm->rdma.m_rdma_op->r_bytes); 116 rds_stats_add(s_recv_rdma_bytes, rm->rdma.m_rdma_op.r_bytes);
117 } 117 }
118 118
119 /* If anyone waited for this message to get flushed out, wake 119 /* If anyone waited for this message to get flushed out, wake
@@ -591,10 +591,10 @@ int rds_iw_xmit(struct rds_connection *conn, struct rds_message *rm,
591 591
592 /* If it has a RDMA op, tell the peer we did it. This is 592 /* If it has a RDMA op, tell the peer we did it. This is
593 * used by the peer to release use-once RDMA MRs. */ 593 * used by the peer to release use-once RDMA MRs. */
594 if (rm->rdma.m_rdma_op) { 594 if (rm->rdma.m_rdma_op.r_active) {
595 struct rds_ext_header_rdma ext_hdr; 595 struct rds_ext_header_rdma ext_hdr;
596 596
597 ext_hdr.h_rdma_rkey = cpu_to_be32(rm->rdma.m_rdma_op->r_key); 597 ext_hdr.h_rdma_rkey = cpu_to_be32(rm->rdma.m_rdma_op.r_key);
598 rds_message_add_extension(&rm->m_inc.i_hdr, 598 rds_message_add_extension(&rm->m_inc.i_hdr,
599 RDS_EXTHDR_RDMA, &ext_hdr, sizeof(ext_hdr)); 599 RDS_EXTHDR_RDMA, &ext_hdr, sizeof(ext_hdr));
600 } 600 }
@@ -632,7 +632,7 @@ int rds_iw_xmit(struct rds_connection *conn, struct rds_message *rm,
632 * or when requested by the user. Right now, we let 632 * or when requested by the user. Right now, we let
633 * the application choose. 633 * the application choose.
634 */ 634 */
635 if (rm->rdma.m_rdma_op && rm->rdma.m_rdma_op->r_fence) 635 if (rm->rdma.m_rdma_op.r_active && rm->rdma.m_rdma_op.r_fence)
636 send_flags = IB_SEND_FENCE; 636 send_flags = IB_SEND_FENCE;
637 637
638 /* 638 /*