Lines Matching defs:spdk_nvmf_tcp_qpair
265 struct spdk_nvmf_tcp_qpair {
329 TAILQ_ENTRY(spdk_nvmf_tcp_qpair) link;
347 TAILQ_HEAD(, spdk_nvmf_tcp_qpair) qpairs;
414 static void _nvmf_tcp_send_c2h_data(struct spdk_nvmf_tcp_qpair *tqpair,
416 static void nvmf_tcp_qpair_process(struct spdk_nvmf_tcp_qpair *tqpair);
423 struct spdk_nvmf_tcp_qpair *tqpair;
426 tqpair = SPDK_CONTAINEROF(qpair, struct spdk_nvmf_tcp_qpair, qpair);
441 tcp_req->pdu->qpair = SPDK_CONTAINEROF(tcp_req->req.qpair, struct spdk_nvmf_tcp_qpair, qpair);
447 nvmf_tcp_req_get(struct spdk_nvmf_tcp_qpair *tqpair)
472 struct spdk_nvmf_tcp_qpair *tqpair = arg;
481 nvmf_tcp_req_put(struct spdk_nvmf_tcp_qpair *tqpair, struct spdk_nvmf_tcp_req *tcp_req)
537 nvmf_tcp_drain_state_queue(struct spdk_nvmf_tcp_qpair *tqpair,
579 nvmf_tcp_cleanup_all_states(struct spdk_nvmf_tcp_qpair *tqpair)
600 nvmf_tcp_dump_qpair_req_contents(struct spdk_nvmf_tcp_qpair *tqpair)
620 struct spdk_nvmf_tcp_qpair *tqpair = _tqpair;
662 nvmf_tcp_qpair_destroy(struct spdk_nvmf_tcp_qpair *tqpair)
1127 static void nvmf_tcp_qpair_set_recv_state(struct spdk_nvmf_tcp_qpair *tqpair,
1131 nvmf_tcp_qpair_set_state(struct spdk_nvmf_tcp_qpair *tqpair, enum nvmf_tcp_qpair_state state)
1139 nvmf_tcp_qpair_disconnect(struct spdk_nvmf_tcp_qpair *tqpair)
1158 struct spdk_nvmf_tcp_qpair *tqpair = _tqpair;
1175 struct spdk_nvmf_tcp_qpair *tqpair = pdu->qpair;
1204 struct spdk_nvmf_tcp_qpair *tqpair = arg;
1223 struct spdk_nvmf_tcp_qpair *tqpair = pdu->qpair;
1270 struct spdk_nvmf_tcp_qpair *tqpair = pdu->qpair;
1293 nvmf_tcp_qpair_write_pdu(struct spdk_nvmf_tcp_qpair *tqpair,
1321 nvmf_tcp_qpair_write_mgmt_pdu(struct spdk_nvmf_tcp_qpair *tqpair,
1334 nvmf_tcp_qpair_write_req_pdu(struct spdk_nvmf_tcp_qpair *tqpair,
1351 nvmf_tcp_qpair_init_mem_resource(struct spdk_nvmf_tcp_qpair *tqpair)
1438 struct spdk_nvmf_tcp_qpair *tqpair;
1440 tqpair = SPDK_CONTAINEROF(qpair, struct spdk_nvmf_tcp_qpair, qpair);
1459 nvmf_tcp_qpair_sock_init(struct spdk_nvmf_tcp_qpair *tqpair)
1489 struct spdk_nvmf_tcp_qpair *tqpair;
1495 tqpair = calloc(1, sizeof(struct spdk_nvmf_tcp_qpair));
1715 struct spdk_nvmf_tcp_qpair *tqpair;
1729 tqpair = SPDK_CONTAINEROF(qpair, struct spdk_nvmf_tcp_qpair, qpair);
1786 nvmf_tcp_qpair_set_recv_state(struct spdk_nvmf_tcp_qpair *tqpair,
1816 struct spdk_nvmf_tcp_qpair *tqpair = ctx;
1830 struct spdk_nvmf_tcp_qpair *tqpair = (struct spdk_nvmf_tcp_qpair *)cb_arg;
1839 nvmf_tcp_send_c2h_term_req(struct spdk_nvmf_tcp_qpair *tqpair, struct nvme_tcp_pdu *pdu,
1874 struct spdk_nvmf_tcp_qpair *tqpair,
1908 struct spdk_nvmf_tcp_qpair *tqpair,
1948 struct spdk_nvmf_tcp_qpair *tqpair,
2021 struct spdk_nvmf_tcp_qpair *tqpair)
2047 struct spdk_nvmf_tcp_qpair *tqpair = SPDK_CONTAINEROF(tcp_req->req.qpair,
2048 struct spdk_nvmf_tcp_qpair, qpair);
2084 nvmf_tcp_send_r2t_pdu(struct spdk_nvmf_tcp_qpair *tqpair,
2117 struct spdk_nvmf_tcp_qpair *tqpair,
2159 nvmf_tcp_h2c_term_req_hdr_handle(struct spdk_nvmf_tcp_qpair *tqpair,
2183 nvmf_tcp_h2c_term_req_payload_handle(struct spdk_nvmf_tcp_qpair *tqpair,
2193 _nvmf_tcp_pdu_payload_handle(struct spdk_nvmf_tcp_qpair *tqpair, struct nvme_tcp_pdu *pdu)
2231 struct spdk_nvmf_tcp_qpair *tqpair = pdu->qpair;
2250 nvmf_tcp_pdu_payload_handle(struct spdk_nvmf_tcp_qpair *tqpair, struct nvme_tcp_pdu *pdu)
2278 struct spdk_nvmf_tcp_qpair *tqpair = cb_arg;
2285 struct spdk_nvmf_tcp_qpair *tqpair,
2358 nvmf_tcp_pdu_psh_handle(struct spdk_nvmf_tcp_qpair *tqpair,
2410 nvmf_tcp_pdu_ch_handle(struct spdk_nvmf_tcp_qpair *tqpair)
2503 nvmf_tcp_sock_process(struct spdk_nvmf_tcp_qpair *tqpair)
2694 struct spdk_nvmf_tcp_qpair *tqpair;
2850 _nvmf_tcp_send_c2h_data(struct spdk_nvmf_tcp_qpair *tqpair,
2970 nvmf_tcp_send_c2h_data(struct spdk_nvmf_tcp_qpair *tqpair,
2982 struct spdk_nvmf_tcp_qpair *tqpair;
2999 tqpair = SPDK_CONTAINEROF(tcp_req->req.qpair, struct spdk_nvmf_tcp_qpair, qpair);
3012 struct spdk_nvmf_tcp_qpair *tqpair,
3066 struct spdk_nvmf_tcp_qpair *tqpair;
3075 tqpair = SPDK_CONTAINEROF(tcp_req->req.qpair, struct spdk_nvmf_tcp_qpair, qpair);
3403 nvmf_tcp_qpair_process(struct spdk_nvmf_tcp_qpair *tqpair)
3419 struct spdk_nvmf_tcp_qpair *tqpair = arg;
3429 struct spdk_nvmf_tcp_qpair *tqpair;
3433 tqpair = SPDK_CONTAINEROF(qpair, struct spdk_nvmf_tcp_qpair, qpair);
3473 struct spdk_nvmf_tcp_qpair *tqpair;
3477 tqpair = SPDK_CONTAINEROF(qpair, struct spdk_nvmf_tcp_qpair, qpair);
3537 struct spdk_nvmf_tcp_qpair *tqpair;
3541 tqpair = SPDK_CONTAINEROF(qpair, struct spdk_nvmf_tcp_qpair, qpair);
3575 struct spdk_nvmf_tcp_qpair *tqpair;
3578 tqpair = SPDK_CONTAINEROF(qpair, struct spdk_nvmf_tcp_qpair, qpair);
3638 struct spdk_nvmf_tcp_qpair *tqpair = SPDK_CONTAINEROF(req->req_to_abort->qpair,
3639 struct spdk_nvmf_tcp_qpair, qpair);
3688 struct spdk_nvmf_tcp_qpair *tqpair;
3695 tqpair = SPDK_CONTAINEROF(qpair, struct spdk_nvmf_tcp_qpair, qpair);