Lines Matching defs:rmsg
375 struct rs_msg *rmsg;
706 rs->rmsg = calloc(rs->rq_size + 1, sizeof(*rs->rmsg));
707 if (!rs->rmsg)
994 if (rs->rmsg)
995 free(rs->rmsg);
1943 rs->rmsg[rs->rmsg_tail].op = rs_msg_op(msg);
1944 rs->rmsg[rs->rmsg_tail].data = rs_msg_data(msg);
2103 struct ds_rmsg *rmsg;
2123 rmsg = &rs->dmsg[rs->rmsg_tail];
2124 rmsg->qp = qp;
2125 rmsg->offset = rs_wr_data(wc.wr_id);
2126 rmsg->length = wc.byte_len - sizeof(struct ibv_grh);
2261 * the remote rmsg queue, or we risk losing notification that data
2345 struct ds_rmsg *rmsg;
2359 rmsg = &rs->dmsg[rs->rmsg_head];
2360 hdr = (struct ds_header *) (rmsg->qp->rbuf + rmsg->offset);
2361 if (len > rmsg->length - hdr->length)
2362 len = rmsg->length - hdr->length;
2369 ds_post_recv(rs, rmsg->qp, rmsg->offset);
2388 if (left < rs->rmsg[rmsg_head].data) {
2391 rsize = rs->rmsg[rmsg_head].data;
2453 if (left < rs->rmsg[rs->rmsg_head].data) {
2455 rs->rmsg[rs->rmsg_head].data -= left;
2458 rsize = rs->rmsg[rs->rmsg_head].data;