Lines Matching defs:sock
22 #include "spdk_internal/sock.h"
268 struct spdk_sock *sock;
629 err = spdk_sock_close(&tqpair->sock);
664 /* Delay the destruction to make sure it isn't performed from the context of a sock
722 static void nvmf_tcp_accept_cb(void *ctx, struct spdk_sock_group *group, struct spdk_sock *sock);
868 SPDK_ERRLOG("Failed to register interrupt for listen socker sock group\n");
1205 int rc = spdk_sock_flush(tqpair->sock);
1227 spdk_sock_writev_async(tqpair->sock, &pdu->sock_req);
1232 rc = spdk_sock_flush(tqpair->sock);
1466 rc = spdk_sock_getaddr(tqpair->sock, saddr, sizeof(saddr), &sport,
1477 rc = spdk_sock_set_recvlowat(tqpair->sock, 1);
1487 nvmf_tcp_handle_connect(struct spdk_nvmf_tcp_port *port, struct spdk_sock *sock)
1498 spdk_sock_close(&sock);
1502 tqpair->sock = sock;
1507 tqpair->qpair.numa.id = spdk_sock_get_numa_id(sock);
1509 rc = spdk_sock_getaddr(tqpair->sock, tqpair->target_addr,
1525 struct spdk_sock *sock;
1530 sock = spdk_sock_accept(port->listen_sock);
1531 if (sock == NULL) {
1535 nvmf_tcp_handle_connect(port, sock);
1559 nvmf_tcp_accept_cb(void *ctx, struct spdk_sock_group *group, struct spdk_sock *sock)
1698 SPDK_ERRLOG("Failed to register interrupt for sock group\n");
1730 rc = spdk_sock_get_optimal_sock_group(tqpair->sock, &group, hint);
2325 if (spdk_sock_set_recvbuf(tqpair->sock, tqpair->recv_buf_size) < 0) {
2543 rc = nvme_tcp_read_data(tqpair->sock,
2564 rc = nvme_tcp_read_data(tqpair->sock,
2603 rc = nvme_tcp_read_payload_data(tqpair->sock, pdu);
2633 if (spdk_sock_is_connected(tqpair->sock) && tqpair->wait_terminate) {
3417 nvmf_tcp_sock_cb(void *arg, struct spdk_sock_group *group, struct spdk_sock *sock)
3437 SPDK_ERRLOG("Cannot set sock opt for tqpair=%p\n", tqpair);
3453 rc = spdk_sock_group_add_sock(tgroup->sock_group, tqpair->sock,
3456 SPDK_ERRLOG("Could not add sock to sock_group: %s (%d)\n",
3490 spdk_sock_flush(tqpair->sock);
3492 rc = spdk_sock_group_remove_sock(tgroup->sock_group, tqpair->sock);
3494 SPDK_ERRLOG("Could not remove sock from sock_group: %s (%d)\n",
3589 if (spdk_sock_is_ipv4(tqpair->sock)) {
3591 } else if (spdk_sock_is_ipv6(tqpair->sock)) {