Lines Matching refs:wr_id
153 #define rs_wr_is_recv(wr_id) (wr_id & RS_WR_ID_FLAG_RECV) argument
154 #define rs_wr_is_msg_send(wr_id) (wr_id & RS_WR_ID_FLAG_MSG_SEND) argument
155 #define rs_wr_data(wr_id) ((uint32_t) wr_id) argument
818 wr.wr_id = rs_recv_wr_id(0); in rs_post_recv()
822 wr.wr_id = rs_recv_wr_id(rs->rbuf_msg_index); in rs_post_recv()
849 wr.wr_id = rs_recv_wr_id(offset); in ds_post_recv()
1654 wr.wr_id = rs_send_wr_id(msg); in rs_post_msg()
1682 wr.wr_id = rs_send_wr_id(wr_data); in rs_post_write()
1705 wr.wr_id = rs_send_wr_id(msg); in rs_post_write_msg()
1718 wr.wr_id = rs_send_wr_id(rs_msg_set(rs_msg_op(msg), 0)) | in rs_post_write_msg()
1739 wr.wr_id = rs_send_wr_id(wr_data); in ds_post_send()
1907 if (rs_wr_is_recv(wc.wr_id)) { in rs_poll_cq()
1916 [rs_wr_data(wc.wr_id)]; in rs_poll_cq()
1950 switch (rs_msg_op(rs_wr_data(wc.wr_id))) { in rs_poll_cq()
1956 if (rs_msg_data(rs_wr_data(wc.wr_id)) == RS_CTRL_DISCONNECT) in rs_poll_cq()
1961 if (!rs_wr_is_msg_send(wc.wr_id)) in rs_poll_cq()
1966 rs->sbuf_bytes_avail += rs_msg_data(rs_wr_data(wc.wr_id)); in rs_poll_cq()
2086 hdr = (struct ds_header *) (qp->rbuf + rs_wr_data(wc->wr_id)); in ds_valid_recv()
2119 if (rs_wr_is_recv(wc.wr_id)) { in ds_poll_cqs()
2125 rmsg->offset = rs_wr_data(wc.wr_id); in ds_poll_cqs()
2130 ds_post_recv(rs, qp, rs_wr_data(wc.wr_id)); in ds_poll_cqs()
2133 smsg = (struct ds_smsg *) (rs->sbuf + rs_wr_data(wc.wr_id)); in ds_poll_cqs()