Lines Matching refs:msg_id
202 dma_addr_t dma_addr = sess->dma_addr[id->msg_id]; in rdma_write_sg()
287 srv_mr = &sess->mrs[id->msg_id]; in rdma_write_sg()
297 msg->buf_id = cpu_to_le16(id->msg_id); in rdma_write_sg()
316 imm_wr.wr.ex.imm_data = cpu_to_be32(rtrs_to_io_rsp_imm(id->msg_id, in rdma_write_sg()
399 imm = rtrs_to_io_rsp_imm(id->msg_id, errno, need_inval); in send_io_resp_imm()
405 srv_mr = &sess->mrs[id->msg_id]; in send_io_resp_imm()
416 msg->buf_id = cpu_to_le16(id->msg_id); in send_io_resp_imm()
505 struct rtrs_srv_mr *mr = &sess->mrs[id->msg_id]; in rtrs_srv_resp_rdma()
1017 id->msg_id = buf_id; in process_read()
1070 id->msg_id = buf_id; in process_write()
1138 u32 msg_id, off; in rtrs_srv_inv_rkey_done() local
1146 msg_id = mr->msg_id; in rtrs_srv_inv_rkey_done()
1148 data = page_address(srv->chunks[msg_id]) + off; in rtrs_srv_inv_rkey_done()
1149 process_io_req(con, data, msg_id, off); in rtrs_srv_inv_rkey_done()
1226 u32 msg_id, off; in rtrs_srv_rdma_done() local
1229 msg_id = imm_payload >> sess->mem_bits; in rtrs_srv_rdma_done()
1231 if (msg_id >= srv->queue_depth || off >= max_chunk_size) { in rtrs_srv_rdma_done()
1233 msg_id, off); in rtrs_srv_rdma_done()
1238 struct rtrs_srv_mr *mr = &sess->mrs[msg_id]; in rtrs_srv_rdma_done()
1241 mr->msg_id = msg_id; in rtrs_srv_rdma_done()
1250 data = page_address(srv->chunks[msg_id]) + off; in rtrs_srv_rdma_done()
1251 process_io_req(con, data, msg_id, off); in rtrs_srv_rdma_done()