Lines Matching defs:rdma_recv
674 struct spdk_nvmf_rdma_recv *rdma_recv;
730 rdma_recv = &resources->recvs[i];
731 rdma_recv->qpair = opts->qpair;
735 rdma_recv->buf = (void *)((uintptr_t)resources->bufs + (i *
739 rdma_recv->rdma_wr.type = RDMA_WR_TYPE_RECV;
741 rdma_recv->sgl[0].addr = (uintptr_t)&resources->cmds[i];
742 rdma_recv->sgl[0].length = sizeof(resources->cmds[i]);
748 rdma_recv->sgl[0].lkey = spdk_rdma_utils_memory_translation_get_lkey(&translation);
749 rdma_recv->wr.num_sge = 1;
751 if (rdma_recv->buf) {
752 rdma_recv->sgl[1].addr = (uintptr_t)rdma_recv->buf;
753 rdma_recv->sgl[1].length = opts->in_capsule_data_size;
754 rc = spdk_rdma_utils_get_translation(opts->map, rdma_recv->buf, opts->in_capsule_data_size,
759 rdma_recv->sgl[1].lkey = spdk_rdma_utils_memory_translation_get_lkey(&translation);
760 rdma_recv->wr.num_sge++;
763 rdma_recv->wr.wr_id = (uintptr_t)&rdma_recv->rdma_wr;
764 rdma_recv->wr.sg_list = rdma_recv->sgl;
766 spdk_rdma_provider_srq_queue_recv_wrs(srq, &rdma_recv->wr);
768 spdk_rdma_provider_qp_queue_recv_wrs(qp, &rdma_recv->wr);
852 struct spdk_nvmf_rdma_recv *rdma_recv, *recv_tmp;
891 STAILQ_FOREACH_SAFE(rdma_recv, &rqpair->resources->incoming_queue, link, recv_tmp) {
892 if (rqpair == rdma_recv->qpair) {
893 STAILQ_REMOVE(&rqpair->resources->incoming_queue, rdma_recv, spdk_nvmf_rdma_recv, link);
894 spdk_rdma_provider_srq_queue_recv_wrs(rqpair->srq, &rdma_recv->wr);
2097 struct spdk_nvmf_rdma_recv *rdma_recv;
2153 rdma_recv = rdma_req->recv;
2156 rdma_req->req.cmd = (union nvmf_h2c_msg *)rdma_recv->sgl[0].addr;
4505 struct spdk_nvmf_rdma_recv *rdma_recv;
4511 rdma_recv = SPDK_CONTAINEROF(bad_rdma_wr, struct spdk_nvmf_rdma_recv, rdma_wr);
4513 rdma_recv->qpair->current_recv_depth++;
4515 SPDK_ERRLOG("Failed to post a recv for the qpair %p with errno %d\n", rdma_recv->qpair, -rc);
4516 spdk_nvmf_qpair_disconnect(&rdma_recv->qpair->qpair);
4680 struct spdk_nvmf_rdma_recv *rdma_recv;
4736 /* rdma_recv->qpair will be invalid if using an SRQ. In that case we have to get the qpair from the wc. */
4737 rdma_recv = SPDK_CONTAINEROF(rdma_wr, struct spdk_nvmf_rdma_recv, rdma_wr);
4739 rdma_recv->qpair = get_rdma_qpair_from_wc(rpoller, &wc[i]);
4744 if (spdk_unlikely(NULL == rdma_recv->qpair)) {
4747 rdma_recv->wr.next = NULL;
4748 spdk_rdma_provider_srq_queue_recv_wrs(rpoller->srq, &rdma_recv->wr);
4756 rqpair = rdma_recv->qpair;
4767 rdma_recv->wr.next = NULL;
4769 rdma_recv->receive_tsc = poll_tsc;
4771 STAILQ_INSERT_HEAD(&rqpair->resources->incoming_queue, rdma_recv, link);