| /dports/games/libretro-gambatte/gambatte-libretro-22abc24/libgambatte/libretro/ |
| H A D | net_serial.cpp | 29 , sockfd_(-1) in NetSerial()
62 close(sockfd_); in stop()
63 sockfd_ = -1; in stop()
193 sockfd_ = fd; in startClientSocket()
224 close(sockfd_); in send()
225 sockfd_ = -1; in send()
237 close(sockfd_); in send()
238 sockfd_ = -1; in send()
290 close(sockfd_); in check()
291 sockfd_ = -1; in check()
[all …]
|
| /dports/multimedia/zoneminder/zoneminder-1.36.5/dep/RtspServer/src/net/ |
| H A D | TcpSocket.cpp | 12 : sockfd_(sockfd) in TcpSocket()
24 sockfd_ = ::socket(AF_INET, SOCK_STREAM, 0); in Create()
25 return sockfd_; in Create()
45 if(::listen(sockfd_, backlog) == SOCKET_ERROR) { in Listen()
46 LOG_DEBUG("<socket=%d> listen failed.\n", sockfd_); in Listen()
65 LOG_DEBUG("<socket=%d> connect failed.\n", sockfd_); in Connect()
75 ::close(sockfd_); in Close()
77 closesocket(sockfd_); in Close()
81 sockfd_ = 0; in Close()
86 shutdown(sockfd_, SHUT_WR); in ShutdownWrite()
[all …]
|
| H A D | Channel.h | 33 : sockfd_(sockfd) in Channel()
52 SOCKET GetSocket() const { return sockfd_; } in GetSocket()
99 SOCKET sockfd_ = 0; variable
|
| /dports/www/slowhttptest/slowhttptest-1.8.2/src/ |
| H A D | slowsocket.cc | 46 : sockfd_(-1), in SlowSocket()
83 if(-1 == (flags = fcntl(sockfd_, F_GETFL, 0))) { in set_nonblocking()
86 return fcntl(sockfd_, F_SETFL, flags | O_NONBLOCK); in set_nonblocking()
109 if(-1 == sockfd_) { in init()
133 maxfd = std::max(sockfd_, maxfd); in init()
175 SSL_set_fd(ssl_, sockfd_); in connect_ssl()
190 : recv(sockfd_, buf, len, 0); in recv_slow()
244 : send(sockfd_, buf_, offset_, 0); in send_slow()
263 if (-1 == sockfd_) return; in close()
274 ::close(sockfd_); in close()
[all …]
|
| H A D | slowsocket.h | 56 return -1 == sockfd_ && !ssl_; in isEmpty()
67 return sockfd_; in get_sockfd()
128 int sockfd_; variable
|
| /dports/net/kea/kea-2.0.1/src/lib/dhcp/tests/ |
| H A D | pkt_filter_lpf_unittest.cc | 72 ASSERT_GE(sock_info_.sockfd_, 0); in TEST_F()
79 ASSERT_EQ(0, getsockname(sock_info_.sockfd_, in TEST_F()
90 ASSERT_EQ(0, getsockopt(sock_info_.sockfd_, SOL_SOCKET, SO_TYPE, in TEST_F()
110 ASSERT_GE(sock_info_.sockfd_, 0); in TEST_F()
113 ASSERT_NO_THROW(pkt_filter.send(iface, sock_info_.sockfd_, test_message_)); in TEST_F()
118 FD_SET(sock_info_.sockfd_, &readfds); in TEST_F()
123 int result = select(sock_info_.sockfd_ + 1, &readfds, NULL, NULL, &timeout); in TEST_F()
129 result = recv(sock_info_.sockfd_, rcv_buf, RECV_BUF_SIZE, 0); in TEST_F()
167 ASSERT_GE(sock_info_.sockfd_, 0); in TEST_F()
201 ASSERT_GE(sock_info_.sockfd_, 0); in TEST_F()
[all …]
|
| H A D | pkt_filter_bpf_unittest.cc | 75 ASSERT_GE(sock_info_.sockfd_, 0); in TEST_F()
101 ASSERT_GE(sock_info_.sockfd_, 0); in TEST_F()
104 ASSERT_NO_THROW(pkt_filter.send(iface, sock_info_.sockfd_, test_message_)); in TEST_F()
109 FD_SET(sock_info_.sockfd_, &readfds); in TEST_F()
114 int result = select(sock_info_.sockfd_ + 1, &readfds, NULL, NULL, &timeout); in TEST_F()
120 result = read(sock_info_.sockfd_, rcv_buf, RECV_BUF_SIZE); in TEST_F()
179 ASSERT_GE(sock_info_.sockfd_, 0); in TEST_F()
214 ASSERT_GE(sock_info_.sockfd_, 0); in TEST_F()
226 FD_SET(sock_info_.sockfd_, &readfds); in TEST_F()
231 int result = select(sock_info_.sockfd_ + 1, &readfds, NULL, NULL, &timeout); in TEST_F()
|
| H A D | pkt_filter_inet6_unittest.cc | 50 testDgramSocket(sock_info_.sockfd_); in TEST_F()
66 ASSERT_GE(sock_info_.sockfd_, 0); in TEST_F()
70 ASSERT_NO_THROW(result = pkt_filter.send(iface, sock_info_.sockfd_, test_message_)); in TEST_F()
76 FD_SET(sock_info_.sockfd_, &readfds); in TEST_F()
81 result = select(sock_info_.sockfd_ + 1, &readfds, NULL, NULL, &timeout); in TEST_F()
87 result = recv(sock_info_.sockfd_, rcv_buf, RECV_BUF_SIZE, 0); in TEST_F()
116 ASSERT_GE(sock_info_.sockfd_, 0); in TEST_F()
|
| H A D | pkt_filter_inet_unittest.cc | 64 testDgramSocket(sock_info_.sockfd_); in TEST_F()
80 ASSERT_GE(sock_info_.sockfd_, 0); in TEST_F()
84 ASSERT_NO_THROW(result = pkt_filter.send(iface, sock_info_.sockfd_, test_message_)); in TEST_F()
90 FD_SET(sock_info_.sockfd_, &readfds); in TEST_F()
95 result = select(sock_info_.sockfd_ + 1, &readfds, NULL, NULL, &timeout); in TEST_F()
101 result = recv(sock_info_.sockfd_, rcv_buf, RECV_BUF_SIZE, 0); in TEST_F()
130 ASSERT_GE(sock_info_.sockfd_, 0); in TEST_F()
|
| /dports/net/libzmq4/zeromq-4.3.4/src/ |
| H A D | vmci.cpp | 39 fd_t sockfd_, in tune_vmci_buffer_size() argument
48 int rc = setsockopt (sockfd_, family, SO_VMCI_BUFFER_SIZE, in tune_vmci_buffer_size()
58 int rc = setsockopt (sockfd_, family, SO_VMCI_BUFFER_SIZE, in tune_vmci_buffer_size()
68 int rc = setsockopt (sockfd_, family, SO_VMCI_BUFFER_SIZE, in tune_vmci_buffer_size()
80 fd_t sockfd_, in tune_vmci_connect_timeout() argument
84 fd_t sockfd_, in tune_vmci_connect_timeout()
91 int rc = setsockopt (sockfd_, family, SO_VMCI_CONNECT_TIMEOUT, in tune_vmci_connect_timeout()
|
| H A D | tcp.cpp | 80 int zmq::set_tcp_send_buffer (fd_t sockfd_, int bufsize_) in set_tcp_send_buffer() argument
83 setsockopt (sockfd_, SOL_SOCKET, SO_SNDBUF, in set_tcp_send_buffer()
85 assert_success_or_recoverable (sockfd_, rc); in set_tcp_send_buffer()
89 int zmq::set_tcp_receive_buffer (fd_t sockfd_, int bufsize_) in set_tcp_receive_buffer() argument
92 setsockopt (sockfd_, SOL_SOCKET, SO_RCVBUF, in set_tcp_receive_buffer()
94 assert_success_or_recoverable (sockfd_, rc); in set_tcp_receive_buffer()
187 int zmq::tune_tcp_maxrt (fd_t sockfd_, int timeout_) in tune_tcp_maxrt() argument
192 LIBZMQ_UNUSED (sockfd_); in tune_tcp_maxrt()
198 setsockopt (sockfd_, IPPROTO_TCP, TCP_MAXRT, in tune_tcp_maxrt()
200 assert_success_or_recoverable (sockfd_, rc); in tune_tcp_maxrt()
[all …]
|
| H A D | vmci.hpp | 50 fd_t sockfd_,
56 void tune_vmci_connect_timeout (ctx_t *context_, fd_t sockfd_, DWORD timeout_);
59 fd_t sockfd_,
|
| H A D | tcp.hpp | 44 int set_tcp_send_buffer (fd_t sockfd_, int bufsize_);
47 int set_tcp_receive_buffer (fd_t sockfd_, int bufsize_);
57 int tune_tcp_maxrt (fd_t sockfd_, int timeout_);
|
| /dports/net/py-pyzmq/pyzmq-22.3.0/bundled/zeromq/src/ |
| H A D | vmci.cpp | 39 fd_t sockfd_, in tune_vmci_buffer_size() argument
48 int rc = setsockopt (sockfd_, family, SO_VMCI_BUFFER_SIZE, in tune_vmci_buffer_size()
58 int rc = setsockopt (sockfd_, family, SO_VMCI_BUFFER_SIZE, in tune_vmci_buffer_size()
68 int rc = setsockopt (sockfd_, family, SO_VMCI_BUFFER_SIZE, in tune_vmci_buffer_size()
80 fd_t sockfd_, in tune_vmci_connect_timeout() argument
84 fd_t sockfd_, in tune_vmci_connect_timeout()
91 int rc = setsockopt (sockfd_, family, SO_VMCI_CONNECT_TIMEOUT, in tune_vmci_connect_timeout()
|
| H A D | tcp.cpp | 80 int zmq::set_tcp_send_buffer (fd_t sockfd_, int bufsize_) in set_tcp_send_buffer() argument
83 setsockopt (sockfd_, SOL_SOCKET, SO_SNDBUF, in set_tcp_send_buffer()
85 assert_success_or_recoverable (sockfd_, rc); in set_tcp_send_buffer()
89 int zmq::set_tcp_receive_buffer (fd_t sockfd_, int bufsize_) in set_tcp_receive_buffer() argument
92 setsockopt (sockfd_, SOL_SOCKET, SO_RCVBUF, in set_tcp_receive_buffer()
94 assert_success_or_recoverable (sockfd_, rc); in set_tcp_receive_buffer()
187 int zmq::tune_tcp_maxrt (fd_t sockfd_, int timeout_) in tune_tcp_maxrt() argument
192 LIBZMQ_UNUSED (sockfd_); in tune_tcp_maxrt()
198 setsockopt (sockfd_, IPPROTO_TCP, TCP_MAXRT, in tune_tcp_maxrt()
200 assert_success_or_recoverable (sockfd_, rc); in tune_tcp_maxrt()
[all …]
|
| H A D | vmci.hpp | 50 fd_t sockfd_,
56 void tune_vmci_connect_timeout (ctx_t *context_, fd_t sockfd_, DWORD timeout_);
59 fd_t sockfd_,
|
| H A D | tcp.hpp | 44 int set_tcp_send_buffer (fd_t sockfd_, int bufsize_);
47 int set_tcp_receive_buffer (fd_t sockfd_, int bufsize_);
57 int tune_tcp_maxrt (fd_t sockfd_, int timeout_);
|
| /dports/net/measurement-kit/measurement-kit-0.10.14/src/libmeasurement_kit/traceroute/ |
| H A D | android.cpp | 63 if (sockfd_ >= 0) { in init()
89 sockfd_ = mk::net::socket_create(family, SOCK_DGRAM, 0, logger); in init()
90 if (sockfd_ == -1) { in init()
109 if (bind(sockfd_, (sockaddr *)&ss, sslen) != 0) { in init()
128 if (sockfd_ < 0) { in send_probe()
149 if (setsockopt(sockfd_, ipproto, ip_ttl, &ttl, sizeof(ttl)) != 0) { in send_probe()
178 reactor->pollin_once(sockfd_, timeout, [this](Error err) { in send_probe()
222 if ((r.recv_bytes = recvmsg(sockfd_, &msg, MSG_ERRQUEUE)) < 0) { in on_socket_readable()
364 if (sockfd_ >= 0) { in cleanup()
365 ::close(sockfd_); in cleanup()
[all …]
|
| /dports/www/aria2/aria2-1.36.0/src/ |
| H A D | SocketCore.cc | 217 sockfd_ = fd; in create()
295 sockfd_ = fd; in bindWithFamily()
314 sockfd_ = fd; in bind()
336 sockfd_ = fd; in bind()
360 sockfd_ = fd; in bind()
488 sockfd_ = fd; in establishConnection()
652 CLOSE(sockfd_); in closeConnection()
653 sockfd_ = -1; in closeConnection()
670 p.fd = sockfd_; in isWritable()
685 CHECK_FD(sockfd_); in isWritable()
[all …]
|
| H A D | SocketCore.h | 71 sock_t sockfd_; variable
126 sock_t getSockfd() const { return sockfd_; } in getSockfd()
128 bool isOpen() const { return sockfd_ != (sock_t)-1; } in isOpen()
319 bool operator==(const SocketCore& s) { return sockfd_ == s.sockfd_; }
323 bool operator<(const SocketCore& s) { return sockfd_ < s.sockfd_; }
|
| /dports/devel/opendht/opendht-1.10.1/src/ |
| H A D | peer_discovery.cpp | 102 int sockfd_ {-1}; member in dht::PeerDiscovery::DomainPeerDiscovery
149 : domain_(domain), port_(port), sockfd_(initialize_socket(domain)) in DomainPeerDiscovery()
151 socketJoinMulticast(sockfd_, domain); in DomainPeerDiscovery()
160 if (sockfd_ != -1) in ~DomainPeerDiscovery()
161 close(sockfd_); in ~DomainPeerDiscovery()
195 if (setsockopt(sockfd_, SOL_SOCKET, SO_REUSEADDR, (char*)&opt, sizeof(opt)) < 0) { in listener_setup()
199 if (setsockopt(sockfd_, SOL_SOCKET, SO_REUSEPORT, (char*)&opt, sizeof(opt)) < 0) { in listener_setup()
205 if (bind(sockfd_, sockAddrListen_.get(), sockAddrListen_.getLength()) < 0){ in listener_setup()
284 sockfd_, in recvFrom()
319 FD_SET(sockfd_, &readfds); in listenerpack_thread()
[all …]
|
| /dports/devel/py-opendht/opendht-1.10.1/src/ |
| H A D | peer_discovery.cpp | 102 int sockfd_ {-1}; member in dht::PeerDiscovery::DomainPeerDiscovery
149 : domain_(domain), port_(port), sockfd_(initialize_socket(domain)) in DomainPeerDiscovery()
151 socketJoinMulticast(sockfd_, domain); in DomainPeerDiscovery()
160 if (sockfd_ != -1) in ~DomainPeerDiscovery()
161 close(sockfd_); in ~DomainPeerDiscovery()
195 if (setsockopt(sockfd_, SOL_SOCKET, SO_REUSEADDR, (char*)&opt, sizeof(opt)) < 0) { in listener_setup()
199 if (setsockopt(sockfd_, SOL_SOCKET, SO_REUSEPORT, (char*)&opt, sizeof(opt)) < 0) { in listener_setup()
205 if (bind(sockfd_, sockAddrListen_.get(), sockAddrListen_.getLength()) < 0){ in listener_setup()
284 sockfd_, in recvFrom()
319 FD_SET(sockfd_, &readfds); in listenerpack_thread()
[all …]
|
| /dports/net/kea/kea-2.0.1/src/lib/dhcpsrv/ |
| H A D | fuzz.cc | 43 sockfd_(-1) { in Fuzz()
89 sockfd_ = socket((ipversion == 4) ? AF_INET : AF_INET6, SOCK_DGRAM, 0); in Fuzz()
90 if (sockfd_ < 0) { in Fuzz()
109 static_cast<void>(close(sockfd_)); in ~Fuzz()
190 ssize_t sent = sendto(sockfd_, buf, send_len, 0, sockaddr_ptr_, in transfer()
|
| /dports/net/kea/kea-2.0.1/src/bin/perfdhcp/ |
| H A D | perf_socket.cc | 24 sockfd_ = openSocket(options); in PerfSocket()
131 iface->delSocket(sockfd_); in ~PerfSocket()
139 if (s.sockfd_ == sockfd_) { in initSocketData()
|
| /dports/net/kea/kea-2.0.1/src/lib/dhcp/ |
| H A D | socket_info.h | 26 int sockfd_; member
61 sockfd_(sockfd), fallbackfd_(fallbackfd) { } in addr_()
|