Lines Matching refs:fd
73 int fd;
238 return spdk_net_getaddr(sock->fd, saddr, slen, sport, caddr, clen, cport);
248 rc = spdk_net_getaddr(sock->fd, saddr, sizeof(saddr), NULL, NULL, 0, NULL);
382 rc = setsockopt(sock->fd, SOL_SOCKET, SO_RCVBUF, &sz, sizeof(sz));
409 rc = setsockopt(sock->fd, SOL_SOCKET, SO_SNDBUF, &sz, sizeof(sz));
420 uring_sock_alloc(int fd, struct spdk_sock_impl_opts *impl_opts, bool enable_zero_copy)
434 sock->fd = fd;
443 rc = setsockopt(sock->fd, IPPROTO_TCP, TCP_QUICKACK, &flag, sizeof(flag));
449 spdk_sock_get_placement_id(sock->fd, sock->base.impl_opts.enable_placement_id,
456 rc = setsockopt(sock->fd, SOL_SOCKET, SO_ZEROCOPY, &flag, sizeof(flag));
481 int fd, flag;
516 fd = -1;
519 fd = socket(res->ai_family, res->ai_socktype, res->ai_protocol);
520 if (fd < 0) {
526 rc = setsockopt(fd, SOL_SOCKET, SO_RCVBUF, &val, sizeof val);
532 rc = setsockopt(fd, SOL_SOCKET, SO_SNDBUF, &val, sizeof val);
537 rc = setsockopt(fd, SOL_SOCKET, SO_REUSEADDR, &val, sizeof val);
539 close(fd);
540 fd = -1;
544 rc = setsockopt(fd, IPPROTO_TCP, TCP_NODELAY, &val, sizeof val);
546 close(fd);
547 fd = -1;
555 rc = setsockopt(fd, IPPROTO_TCP, TCP_USER_TIMEOUT, &val, sizeof val);
557 close(fd);
558 fd = -1;
571 rc = setsockopt(fd, SOL_SOCKET, SO_PRIORITY, &opts->priority, sizeof val);
573 close(fd);
574 fd = -1;
581 rc = setsockopt(fd, IPPROTO_IPV6, IPV6_V6ONLY, &val, sizeof val);
583 close(fd);
584 fd = -1;
591 rc = bind(fd, res->ai_addr, res->ai_addrlen);
597 close(fd);
607 close(fd);
608 fd = -1;
613 rc = listen(fd, 512);
616 close(fd);
617 fd = -1;
621 flag = fcntl(fd, F_GETFL);
622 if (fcntl(fd, F_SETFL, flag | O_NONBLOCK) < 0) {
623 SPDK_ERRLOG("fcntl can't set nonblocking mode for socket, fd: %d (%d)\n", fd, errno);
624 close(fd);
625 fd = -1;
644 close(fd);
645 fd = -1;
648 rc = bind(fd, src_ai->ai_addr, src_ai->ai_addrlen);
652 close(fd);
653 fd = -1;
662 rc = connect(fd, res->ai_addr, res->ai_addrlen);
666 close(fd);
667 fd = -1;
671 flag = fcntl(fd, F_GETFL);
672 if (fcntl(fd, F_SETFL, flag & ~O_NONBLOCK) < 0) {
673 SPDK_ERRLOG("fcntl can't set blocking mode for socket, fd: %d (%d)\n", fd, errno);
674 close(fd);
675 fd = -1;
685 if (fd < 0) {
689 enable_zcopy_user_opts = opts->zcopy && !spdk_net_is_loopback(fd);
690 sock = uring_sock_alloc(fd, &impl_opts, enable_zcopy_user_opts && enable_zcopy_impl_opts);
693 close(fd);
728 int rc, fd;
737 rc = accept(sock->fd, (struct sockaddr *)&sa, &salen);
743 fd = rc;
745 flag = fcntl(fd, F_GETFL);
746 if ((flag & O_NONBLOCK) && (fcntl(fd, F_SETFL, flag & ~O_NONBLOCK) < 0)) {
747 SPDK_ERRLOG("fcntl can't set blocking mode for socket, fd: %d (%d)\n", fd, errno);
748 close(fd);
755 rc = setsockopt(fd, SOL_SOCKET, SO_PRIORITY, &sock->base.opts.priority, sizeof(int));
757 close(fd);
763 new_sock = uring_sock_alloc(fd, &sock->base.impl_opts, sock->zcopy);
765 close(fd);
781 * leak the fd but continue to free the rest of the sock
783 close(sock->fd);
830 sock_readv(int fd, struct iovec *iov, int iovcnt)
837 return recvmsg(fd, &msg, MSG_DONTWAIT);
850 bytes = sock_readv(sock->fd, iov, 2);
928 return sock_readv(sock->fd, iovs, iovcnt);
941 return sock_readv(sock->fd, iovs, iovcnt);
1014 return sock_readv(sock->fd, iov, iovcnt);
1052 return sendmsg(sock->fd, &msg, MSG_DONTWAIT);
1226 io_uring_prep_recvmsg(sqe, sock->fd, &task->msg, MSG_ERRQUEUE);
1270 io_uring_prep_sendmsg(sqe, sock->fd, &sock->write_task.msg, flags);
1295 io_uring_prep_recv(sqe, sock->fd, NULL, URING_MAX_RECV_SIZE, 0);
1564 rc = setsockopt(sock->fd, SOL_SOCKET, SO_RCVLOWAT, &val, sizeof val);
1583 rc = getsockname(sock->fd, (struct sockaddr *) &sa, &salen);
1604 rc = getsockname(sock->fd, (struct sockaddr *) &sa, &salen);
1620 rc = recv(sock->fd, &byte, 1, MSG_PEEK | MSG_DONTWAIT);
2004 rc = sendmsg(sock->fd, &msg, flags | MSG_DONTWAIT);
2025 retval = recvmsg(sock->fd, &task->msg, MSG_ERRQUEUE);