Lines Matching defs:sock
77 struct spdk_sock *sock;
354 rc = spdk_sock_close(&tqpair->sock);
356 if (tqpair->sock != NULL) {
359 tqpair->sock = NULL;
516 spdk_sock_writev_async(tqpair->sock, &pdu->sock_req);
1517 if (spdk_sock_set_recvbuf(tqpair->sock, recv_buf_size * SPDK_NVMF_TCP_RECV_BUF_SIZE_FACTOR) < 0) {
1945 rc = nvme_tcp_read_data(tqpair->sock,
1963 rc = nvme_tcp_read_data(tqpair->sock,
1993 rc = nvme_tcp_read_payload_data(tqpair->sock, pdu);
2083 rc = spdk_sock_flush(tqpair->sock);
2159 nvme_tcp_qpair_sock_cb(void *ctx, struct spdk_sock_group *group, struct spdk_sock *sock)
2286 tqpair->sock = spdk_sock_connect_ext(ctrlr->trid.traddr, port, sock_impl_name, &opts);
2287 if (!tqpair->sock) {
2288 SPDK_ERRLOG("sock connection error of tqpair=%p with addr=%s, port=%ld\n",
2380 if (!tqpair->sock) {
2619 tctrlr->ctrlr.numa.id = spdk_sock_get_numa_id(tqpair->sock);
2723 SPDK_ERRLOG("Unable to allocate sock group.\n");
2737 rc = spdk_sock_get_optimal_sock_group(tqpair->sock, &group, NULL);
2751 if (spdk_sock_group_add_sock(group->sock_group, tqpair->sock, nvme_tcp_qpair_sock_cb, qpair)) {
2768 if (tqpair->sock && group->sock_group) {
2769 if (spdk_sock_group_remove_sock(group->sock_group, tqpair->sock)) {
2783 /* disconnected qpairs won't have a sock to add. */
2785 if (spdk_sock_group_add_sock(group->sock_group, tqpair->sock, nvme_tcp_qpair_sock_cb, qpair)) {
2849 nvme_tcp_qpair_sock_cb(&tqpair->qpair, group->sock_group, tqpair->sock);
2883 SPDK_ERRLOG("Failed to close the sock group for a tcp poll group.\n");