Lines Matching refs:msg_id
232 dma_addr_t dma_addr = sess->dma_addr[id->msg_id]; in rdma_write_sg()
315 srv_mr = &sess->mrs[id->msg_id]; in rdma_write_sg()
324 msg->buf_id = cpu_to_le16(id->msg_id); in rdma_write_sg()
343 imm_wr.ex.imm_data = cpu_to_be32(rtrs_to_io_rsp_imm(id->msg_id, in rdma_write_sg()
425 imm = rtrs_to_io_rsp_imm(id->msg_id, errno, need_inval); in send_io_resp_imm()
431 srv_mr = &sess->mrs[id->msg_id]; in send_io_resp_imm()
441 msg->buf_id = cpu_to_le16(id->msg_id); in send_io_resp_imm()
532 struct rtrs_srv_mr *mr = &sess->mrs[id->msg_id]; in rtrs_srv_resp_rdma()
1005 id->msg_id = buf_id; in process_read()
1058 id->msg_id = buf_id; in process_write()
1126 u32 msg_id, off; in rtrs_srv_inv_rkey_done() local
1134 msg_id = mr->msg_id; in rtrs_srv_inv_rkey_done()
1136 data = page_address(srv->chunks[msg_id]) + off; in rtrs_srv_inv_rkey_done()
1137 process_io_req(con, data, msg_id, off); in rtrs_srv_inv_rkey_done()
1214 u32 msg_id, off; in rtrs_srv_rdma_done() local
1217 msg_id = imm_payload >> sess->mem_bits; in rtrs_srv_rdma_done()
1219 if (unlikely(msg_id >= srv->queue_depth || in rtrs_srv_rdma_done()
1222 msg_id, off); in rtrs_srv_rdma_done()
1227 struct rtrs_srv_mr *mr = &sess->mrs[msg_id]; in rtrs_srv_rdma_done()
1230 mr->msg_id = msg_id; in rtrs_srv_rdma_done()
1239 data = page_address(srv->chunks[msg_id]) + off; in rtrs_srv_rdma_done()
1240 process_io_req(con, data, msg_id, off); in rtrs_srv_rdma_done()