Lines Matching defs:nvme_tcp_qpair
70 TAILQ_HEAD(, nvme_tcp_qpair) needs_poll;
75 struct nvme_tcp_qpair {
111 TAILQ_ENTRY(nvme_tcp_qpair) link;
165 struct nvme_tcp_qpair *tqpair;
177 static void nvme_tcp_icresp_handle(struct nvme_tcp_qpair *tqpair, struct nvme_tcp_pdu *pdu);
178 static void nvme_tcp_req_complete(struct nvme_tcp_req *tcp_req, struct nvme_tcp_qpair *tqpair,
181 static inline struct nvme_tcp_qpair *
182 nvme_tcp_qpair(struct spdk_nvme_qpair *qpair)
185 return SPDK_CONTAINEROF(qpair, struct nvme_tcp_qpair, qpair);
202 nvme_tcp_req_get(struct nvme_tcp_qpair *tqpair)
230 nvme_tcp_req_put(struct nvme_tcp_qpair *tqpair, struct nvme_tcp_req *tcp_req)
267 nvme_tcp_free_reqs(struct nvme_tcp_qpair *tqpair)
277 nvme_tcp_alloc_reqs(struct nvme_tcp_qpair *tqpair)
322 nvme_tcp_qpair_set_recv_state(struct nvme_tcp_qpair *tqpair,
343 struct nvme_tcp_qpair *tqpair = nvme_tcp_qpair(qpair);
389 struct nvme_tcp_qpair *tqpair = nvme_tcp_qpair(qpair);
438 nvme_tcp_cond_schedule_qpair_polling(struct nvme_tcp_qpair *tqpair)
461 struct nvme_tcp_qpair *tqpair = pdu->qpair;
478 struct nvme_tcp_qpair *tqpair = pdu->qpair;
501 struct nvme_tcp_qpair *tqpair = pdu->qpair;
542 struct nvme_tcp_qpair *tqpair = pdu->qpair;
574 struct nvme_tcp_qpair *tqpair = pdu->qpair;
638 struct nvme_tcp_qpair *tqpair = pdu->qpair;
667 nvme_tcp_qpair_write_pdu(struct nvme_tcp_qpair *tqpair,
722 nvme_tcp_build_contig_request(struct nvme_tcp_qpair *tqpair, struct nvme_tcp_req *tcp_req)
750 nvme_tcp_build_sgl_request(struct nvme_tcp_qpair *tqpair, struct nvme_tcp_req *tcp_req)
801 nvme_tcp_req_init(struct nvme_tcp_qpair *tqpair, struct nvme_request *req,
901 nvme_tcp_qpair_capsule_cmd_send(struct nvme_tcp_qpair *tqpair,
962 struct nvme_tcp_qpair *tqpair;
965 tqpair = nvme_tcp_qpair(qpair);
998 struct nvme_tcp_qpair *tqpair,
1045 struct nvme_tcp_qpair *tqpair = nvme_tcp_qpair(qpair);
1065 struct nvme_tcp_qpair *tqpair = cb_arg;
1071 nvme_tcp_qpair_send_h2c_term_req(struct nvme_tcp_qpair *tqpair, struct nvme_tcp_pdu *pdu,
1106 nvme_tcp_qpair_recv_state_valid(struct nvme_tcp_qpair *tqpair)
1120 nvme_tcp_pdu_ch_handle(struct nvme_tcp_qpair *tqpair)
1212 get_nvme_active_req_by_cid(struct nvme_tcp_qpair *tqpair, uint32_t cid)
1227 struct nvme_tcp_qpair *tqpair = treq->tqpair;
1244 nvme_tcp_c2h_data_payload_handle(struct nvme_tcp_qpair *tqpair,
1311 nvme_tcp_c2h_term_req_payload_handle(struct nvme_tcp_qpair *tqpair,
1319 _nvme_tcp_pdu_payload_handle(struct nvme_tcp_qpair *tqpair, uint32_t *reaped)
1358 struct nvme_tcp_qpair *tqpair = treq->tqpair;
1373 struct nvme_tcp_qpair *tqpair = treq->tqpair;
1412 nvme_tcp_pdu_payload_handle(struct nvme_tcp_qpair *tqpair,
1453 struct nvme_tcp_qpair *tqpair = cb_arg;
1466 nvme_tcp_icresp_handle(struct nvme_tcp_qpair *tqpair,
1539 nvme_tcp_capsule_resp_hdr_handle(struct nvme_tcp_qpair *tqpair, struct nvme_tcp_pdu *pdu,
1586 nvme_tcp_c2h_term_req_hdr_handle(struct nvme_tcp_qpair *tqpair,
1610 nvme_tcp_c2h_data_hdr_handle(struct nvme_tcp_qpair *tqpair, struct nvme_tcp_pdu *pdu)
1729 struct nvme_tcp_qpair *tqpair = nvme_tcp_qpair(tcp_req->req->qpair);
1788 nvme_tcp_r2t_hdr_handle(struct nvme_tcp_qpair *tqpair, struct nvme_tcp_pdu *pdu)
1865 nvme_tcp_pdu_psh_handle(struct nvme_tcp_qpair *tqpair, uint32_t *reaped)
1918 nvme_tcp_read_pdu(struct nvme_tcp_qpair *tqpair, uint32_t *reaped, uint32_t max_completions)
2034 struct nvme_tcp_qpair *tqpair = nvme_tcp_qpair(qpair);
2078 struct nvme_tcp_qpair *tqpair = nvme_tcp_qpair(qpair);
2164 struct nvme_tcp_qpair *tqpair = nvme_tcp_qpair(qpair);
2182 nvme_tcp_qpair_icreq_send(struct nvme_tcp_qpair *tqpair)
2214 struct nvme_tcp_qpair *tqpair;
2223 tqpair = nvme_tcp_qpair(qpair);
2300 struct nvme_tcp_qpair *tqpair;
2303 tqpair = nvme_tcp_qpair(qpair);
2375 struct nvme_tcp_qpair *tqpair;
2378 tqpair = nvme_tcp_qpair(qpair);
2431 struct nvme_tcp_qpair *tqpair;
2441 tqpair = calloc(1, sizeof(struct nvme_tcp_qpair));
2573 struct nvme_tcp_qpair *tqpair;
2617 tqpair = nvme_tcp_qpair(tctrlr->ctrlr.adminq);
2648 struct nvme_tcp_qpair *tqpair = nvme_tcp_qpair(qpair);
2669 struct nvme_tcp_qpair *tqpair = nvme_tcp_qpair(qpair);
2693 struct nvme_tcp_qpair *tqpair = nvme_tcp_qpair(qpair);
2733 struct nvme_tcp_qpair *tqpair = nvme_tcp_qpair(qpair);
2749 struct nvme_tcp_qpair *tqpair = nvme_tcp_qpair(qpair);
2761 struct nvme_tcp_qpair *tqpair = nvme_tcp_qpair(qpair);
2780 struct nvme_tcp_qpair *tqpair = nvme_tcp_qpair(qpair);
2797 struct nvme_tcp_qpair *tqpair;
2802 tqpair = nvme_tcp_qpair(qpair);
2822 struct nvme_tcp_qpair *tqpair, *tmp_tqpair;
2832 tqpair = nvme_tcp_qpair(qpair);