Lines Matching refs:rmsg
375 struct rs_msg *rmsg; member
706 rs->rmsg = calloc(rs->rq_size + 1, sizeof(*rs->rmsg)); in rs_init_bufs()
707 if (!rs->rmsg) in rs_init_bufs()
994 if (rs->rmsg) in rs_free()
995 free(rs->rmsg); in rs_free()
1943 rs->rmsg[rs->rmsg_tail].op = rs_msg_op(msg); in rs_poll_cq()
1944 rs->rmsg[rs->rmsg_tail].data = rs_msg_data(msg); in rs_poll_cq()
2103 struct ds_rmsg *rmsg; in ds_poll_cqs() local
2123 rmsg = &rs->dmsg[rs->rmsg_tail]; in ds_poll_cqs()
2124 rmsg->qp = qp; in ds_poll_cqs()
2125 rmsg->offset = rs_wr_data(wc.wr_id); in ds_poll_cqs()
2126 rmsg->length = wc.byte_len - sizeof(struct ibv_grh); in ds_poll_cqs()
2345 struct ds_rmsg *rmsg; in ds_recvfrom() local
2359 rmsg = &rs->dmsg[rs->rmsg_head]; in ds_recvfrom()
2360 hdr = (struct ds_header *) (rmsg->qp->rbuf + rmsg->offset); in ds_recvfrom()
2361 if (len > rmsg->length - hdr->length) in ds_recvfrom()
2362 len = rmsg->length - hdr->length; in ds_recvfrom()
2369 ds_post_recv(rs, rmsg->qp, rmsg->offset); in ds_recvfrom()
2388 if (left < rs->rmsg[rmsg_head].data) { in rs_peek()
2391 rsize = rs->rmsg[rmsg_head].data; in rs_peek()
2453 if (left < rs->rmsg[rs->rmsg_head].data) { in rrecv()
2455 rs->rmsg[rs->rmsg_head].data -= left; in rrecv()
2458 rsize = rs->rmsg[rs->rmsg_head].data; in rrecv()