Home
last modified time | relevance | path

Searched refs:sock (Results 1 – 25 of 383) sorted by relevance

12345678910>>...16

/freebsd-11-stable/contrib/ntp/lib/isc/win32/
HDsocket.c94 #define CONSISTENT(sock) consistent(sock) argument
96 #define CONSISTENT(sock) do {} while (0) argument
98 static void consistent(isc_socket_t *sock);
278 #define _set_state(sock, _state) do { (sock)->state = (_state); (sock)->state_lineno = __LINE__; } … argument
362 static isc_boolean_t senddone_is_active(isc_socket_t *sock, isc_socketevent_t *dev);
363 static isc_boolean_t acceptdone_is_active(isc_socket_t *sock, isc_socket_newconnev_t *dev);
364 static isc_boolean_t connectdone_is_active(isc_socket_t *sock, isc_socket_connev_t *dev);
365 static void send_recvdone_event(isc_socket_t *sock, isc_socketevent_t **dev);
366 static void send_senddone_event(isc_socket_t *sock, isc_socketevent_t **dev);
367 static void send_acceptdone_event(isc_socket_t *sock, isc_socket_newconnev_t **adev);
[all …]
/freebsd-11-stable/tools/regression/sockets/listen_backlog/
HDlisten_backlog.c69 socket_get_backlog(int sock, int *backlogp, const char *testclass, in socket_get_backlog() argument
76 if (getsockopt(sock, SOL_SOCKET, SO_LISTENQLIMIT, &i, &len) < 0) { in socket_get_backlog()
105 int backlog_retrieved, sock; in socket_listen() local
107 sock = socket(domain, type, protocol); in socket_listen()
108 if (sock < 0) { in socket_listen()
111 close(sock); in socket_listen()
115 if (socket_get_backlog(sock, &backlog_retrieved, testclass, test, in socket_listen()
117 close(sock); in socket_listen()
125 close(sock); in socket_listen()
129 if (listen(sock, backlog) < 0) { in socket_listen()
[all …]
/freebsd-11-stable/contrib/ntp/lib/isc/unix/
HDsocket.c471 isc__socket_attach(isc_socket_t *sock, isc_socket_t **socketp);
482 isc__socket_recvv(isc_socket_t *sock, isc_bufferlist_t *buflist,
486 isc__socket_recv(isc_socket_t *sock, isc_region_t *region,
490 isc__socket_recv2(isc_socket_t *sock, isc_region_t *region,
494 isc__socket_send(isc_socket_t *sock, isc_region_t *region,
497 isc__socket_sendto(isc_socket_t *sock, isc_region_t *region,
501 isc__socket_sendv(isc_socket_t *sock, isc_bufferlist_t *buflist,
504 isc__socket_sendtov(isc_socket_t *sock, isc_bufferlist_t *buflist,
508 isc__socket_sendto2(isc_socket_t *sock, isc_region_t *region,
518 isc__socket_bind(isc_socket_t *sock, isc_sockaddr_t *sockaddr,
[all …]
/freebsd-11-stable/tools/regression/netinet/ipsockopt/
HDipsockopt.c77 int sock; in get_socket_priv() local
86 sock = socket(PF_INET, type, 0); in get_socket_priv()
91 return (sock); in get_socket_priv()
114 test_ip_options(int sock, const char *socktypename) in test_ip_options() argument
124 if (getsockopt(sock, IPPROTO_IP, IP_OPTIONS, test_options, &len) < 0) in test_ip_options()
140 if (setsockopt(sock, IPPROTO_IP, IP_OPTIONS, &new_options, in test_ip_options()
154 if (getsockopt(sock, IPPROTO_IP, IP_OPTIONS, test_options, &len) < 0) in test_ip_options()
184 if (setsockopt(sock, IPPROTO_IP, IP_OPTIONS, NULL, 0) < 0) in test_ip_options()
194 if (getsockopt(sock, IPPROTO_IP, IP_OPTIONS, test_options, &len) < 0) in test_ip_options()
217 int flag[2], sock; in test_ip_hdrincl() local
[all …]
/freebsd-11-stable/contrib/apr/network_io/unix/
HDsockopt.c75 apr_status_t apr_socket_timeout_set(apr_socket_t *sock, apr_interval_time_t t) in apr_socket_timeout_set() argument
86 if (t >= 0 && sock->timeout < 0) { in apr_socket_timeout_set()
87 if (apr_is_option_set(sock, APR_SO_NONBLOCK) != 1) { in apr_socket_timeout_set()
88 if ((stat = sononblock(sock->socketdes)) != APR_SUCCESS) { in apr_socket_timeout_set()
91 apr_set_option(sock, APR_SO_NONBLOCK, 1); in apr_socket_timeout_set()
94 else if (t < 0 && sock->timeout >= 0) { in apr_socket_timeout_set()
95 if (apr_is_option_set(sock, APR_SO_NONBLOCK) != 0) { in apr_socket_timeout_set()
96 if ((stat = soblock(sock->socketdes)) != APR_SUCCESS) { in apr_socket_timeout_set()
99 apr_set_option(sock, APR_SO_NONBLOCK, 0); in apr_socket_timeout_set()
106 sock->options &= ~APR_INCOMPLETE_READ; in apr_socket_timeout_set()
[all …]
HDsockets.c38 static apr_status_t socket_cleanup(void *sock) in socket_cleanup() argument
40 apr_socket_t *thesocket = sock; in socket_cleanup()
65 static apr_status_t socket_child_cleanup(void *sock) in socket_child_cleanup() argument
67 apr_socket_t *thesocket = sock; in socket_child_cleanup()
77 static void set_socket_vars(apr_socket_t *sock, int family, int type, int protocol) in set_socket_vars() argument
79 sock->type = type; in set_socket_vars()
80 sock->protocol = protocol; in set_socket_vars()
81 apr_sockaddr_vars_set(sock->local_addr, family, 0); in set_socket_vars()
82 apr_sockaddr_vars_set(sock->remote_addr, family, 0); in set_socket_vars()
83 sock->options = 0; in set_socket_vars()
[all …]
HDsendrecv.c30 apr_status_t apr_socket_send(apr_socket_t *sock, const char *buf, in apr_socket_send() argument
35 if (sock->options & APR_INCOMPLETE_WRITE) { in apr_socket_send()
36 sock->options &= ~APR_INCOMPLETE_WRITE; in apr_socket_send()
41 rv = write(sock->socketdes, buf, (*len)); in apr_socket_send()
45 && (sock->timeout > 0)) { in apr_socket_send()
48 arv = apr_wait_for_io_or_timeout(NULL, sock, 0); in apr_socket_send()
55 rv = write(sock->socketdes, buf, (*len)); in apr_socket_send()
63 if ((sock->timeout > 0) && (rv < *len)) { in apr_socket_send()
64 sock->options |= APR_INCOMPLETE_WRITE; in apr_socket_send()
70 apr_status_t apr_socket_recv(apr_socket_t *sock, char *buf, apr_size_t *len) in apr_socket_recv() argument
[all …]
HDmulticast.c95 static int sock_is_ipv4(apr_socket_t *sock) in sock_is_ipv4() argument
97 if (sock->local_addr->family == APR_INET) in sock_is_ipv4()
103 static int sock_is_ipv6(apr_socket_t *sock) in sock_is_ipv6() argument
105 if (sock->local_addr->family == APR_INET6) in sock_is_ipv6()
111 static apr_status_t do_mcast(int type, apr_socket_t *sock, in do_mcast() argument
127 if (sock_is_ipv4(sock)) { in do_mcast()
131 else if (sock_is_ipv6(sock)) { in do_mcast()
150 if (setsockopt(sock->socketdes, ip_proto, type, (const void *) &mip, in do_mcast()
160 if (sock_is_ipv4(sock)) { in do_mcast()
164 if (setsockopt(sock->socketdes, IPPROTO_IP, type, in do_mcast()
[all …]
/freebsd-11-stable/contrib/ntp/lib/isc/
HDsocket_api.c105 isc_socket_attach(isc_socket_t *sock, isc_socket_t **socketp) { in isc_socket_attach() argument
106 REQUIRE(ISCAPI_SOCKET_VALID(sock)); in isc_socket_attach()
109 sock->methods->attach(sock, socketp); in isc_socket_attach()
111 ENSURE(*socketp == sock); in isc_socket_attach()
124 isc_socket_bind(isc_socket_t *sock, isc_sockaddr_t *sockaddr, in isc_socket_bind() argument
127 REQUIRE(ISCAPI_SOCKET_VALID(sock)); in isc_socket_bind()
129 return (sock->methods->bind(sock, sockaddr, options)); in isc_socket_bind()
133 isc_socket_sendto(isc_socket_t *sock, isc_region_t *region, isc_task_t *task, in isc_socket_sendto() argument
137 REQUIRE(ISCAPI_SOCKET_VALID(sock)); in isc_socket_sendto()
139 return (sock->methods->sendto(sock, region, task, action, arg, address, in isc_socket_sendto()
[all …]
/freebsd-11-stable/tools/regression/sockets/shutdown/
HDshutdown.c43 struct sockaddr_in sock; in main() local
61 bzero(&sock, sizeof(sock)); in main()
62 sock.sin_len = sizeof(sock); in main()
63 sock.sin_family = AF_INET; in main()
64 sock.sin_addr.s_addr = htonl(INADDR_LOOPBACK); in main()
65 sock.sin_port = 0; in main()
67 if (bind(listen_sock, (struct sockaddr *)&sock, sizeof(sock)) < 0) in main()
69 inet_ntoa(sock.sin_addr), sock.sin_port, strerror(errno)); in main()
71 len = sizeof(sock); in main()
72 if (getsockname(listen_sock, (struct sockaddr *)&sock, &len) < 0) in main()
[all …]
/freebsd-11-stable/tools/regression/sockets/sigpipe/
HDsigpipe.c88 test_send(const char *testname, int sock) in test_send() argument
94 len = send(sock, &ch, sizeof(ch), 0); in test_send()
104 test_write(const char *testname, int sock) in test_write() argument
110 len = write(sock, &ch, sizeof(ch)); in test_write()
218 tcp_pair(u_short port, int sock[2]) in tcp_pair()
246 sock[0] = accept_sock; in tcp_pair()
247 sock[1] = connect_sock; in tcp_pair()
254 int sock[2]; in main() local
271 if (socketpair(PF_LOCAL, SOCK_STREAM, 0, sock) < 0) in main()
273 test_send_wantsignal("test_send_wantsignal(PF_LOCAL)", sock[0], in main()
[all …]
/freebsd-11-stable/contrib/ntp/lib/isc/include/isc/
HDsocket.h277 void (*attach)(isc_socket_t *sock,
280 isc_result_t (*bind)(isc_socket_t *sock, isc_sockaddr_t *sockaddr,
282 isc_result_t (*sendto)(isc_socket_t *sock, isc_region_t *region,
286 isc_result_t (*connect)(isc_socket_t *sock, isc_sockaddr_t *addr,
289 isc_result_t (*recv)(isc_socket_t *sock, isc_region_t *region,
292 void (*cancel)(isc_socket_t *sock, isc_task_t *task,
294 isc_result_t (*getsockname)(isc_socket_t *sock,
296 isc_sockettype_t (*gettype)(isc_socket_t *sock);
297 void (*ipv6only)(isc_socket_t *sock, isc_boolean_t yes);
298 isc_result_t (*fdwatchpoke)(isc_socket_t *sock, int flags);
[all …]
/freebsd-11-stable/contrib/wpa/wpa_supplicant/
HDctrl_iface_unix.c36 int sock; member
46 int sock; member
64 const char *ifname, int sock,
76 static void wpas_ctrl_sock_debug(const char *title, int sock, const char *buf, in wpas_ctrl_sock_debug() argument
89 if (getsockopt(sock, SOL_SOCKET, SO_SNDBUF, &sndbuf, &optlen) < 0) in wpas_ctrl_sock_debug()
92 if (ioctl(sock, TIOCOUTQ, &outq) < 0) in wpas_ctrl_sock_debug()
97 title, sock, sndbuf, outq, (int) len); in wpas_ctrl_sock_debug()
129 static void wpa_supplicant_ctrl_iface_receive(int sock, void *eloop_ctx, in wpa_supplicant_ctrl_iface_receive() argument
142 res = recvfrom(sock, buf, sizeof(buf) - 1, 0, in wpa_supplicant_ctrl_iface_receive()
193 wpas_ctrl_sock_debug("ctrl_sock-sendto", sock, reply, in wpa_supplicant_ctrl_iface_receive()
[all …]
/freebsd-11-stable/usr.bin/sockstat/
HDsockstat.c103 struct sock { struct
114 struct sock *next; argument
118 static struct sock *sockhash[HASHSIZE];
271 free_socket(struct sock *sock) in free_socket() argument
275 cur = sock->laddr; in free_socket()
281 cur = sock->faddr; in free_socket()
287 free(sock); in free_socket()
293 struct sock *sock; in gather_sctp() local
329 if ((sock = calloc(1, sizeof *sock)) == NULL) in gather_sctp()
331 sock->socket = xinpcb->socket; in gather_sctp()
[all …]
/freebsd-11-stable/contrib/sendmail/contrib/
HDsocketmapClient.pl14 my $sock;
17 $sock = new IO::Socket::INET (
23 $sock = new IO::Socket::UNIX (
31 die "Could not create socket: $!\n" unless $sock;
35 netstringWrite($sock, $request);
36 $sock->flush();
37 my $response = netstringRead($sock);
42 $sock->close();
45 my $sock = shift;
48 print $sock length($data).':'.$data.',';
[all …]
HDsocketmapServer.pl11 my $sock;
14 $sock = new IO::Socket::INET (
23 $sock = new IO::Socket::UNIX (
32 while(my $client = $sock->accept()) {
38 $sock->close();
45 $sock->close();
76 my $sock = shift;
79 print $sock length($data).':'.$data.',';
83 my $sock = shift;
86 my $dataLength = <$sock>;
[all …]
/freebsd-11-stable/contrib/openbsm/bin/auditdistd/
HDproto_common.c52 blocking_socket(int sock) in blocking_socket() argument
56 flags = fcntl(sock, F_GETFL); in blocking_socket()
62 proto_descriptor_send(int sock, int fd) in proto_descriptor_send() argument
68 PJDLOG_ASSERT(sock >= 0); in proto_descriptor_send()
85 if (sendmsg(sock, &msg, 0) == -1) in proto_descriptor_send()
92 proto_common_send(int sock, const unsigned char *data, size_t size, int fd) in proto_common_send() argument
98 PJDLOG_ASSERT(sock >= 0); in proto_common_send()
105 if (shutdown(sock, SHUT_RD) == -1) in proto_common_send()
115 done = send(sock, data, sendsize, MSG_NOSIGNAL); in proto_common_send()
144 if (errno == EAGAIN && blocking_socket(sock)) in proto_common_send()
[all …]
/freebsd-11-stable/sbin/hastd/
HDproto_common.c55 blocking_socket(int sock) in blocking_socket() argument
59 flags = fcntl(sock, F_GETFL); in blocking_socket()
65 proto_descriptor_send(int sock, int fd) in proto_descriptor_send() argument
71 PJDLOG_ASSERT(sock >= 0); in proto_descriptor_send()
88 if (sendmsg(sock, &msg, 0) == -1) in proto_descriptor_send()
95 proto_common_send(int sock, const unsigned char *data, size_t size, int fd) in proto_common_send() argument
101 PJDLOG_ASSERT(sock >= 0); in proto_common_send()
108 if (shutdown(sock, SHUT_RD) == -1) in proto_common_send()
118 done = send(sock, data, sendsize, MSG_NOSIGNAL); in proto_common_send()
147 if (errno == EAGAIN && blocking_socket(sock)) in proto_common_send()
[all …]
/freebsd-11-stable/lib/libnv/
HDmsgio.c119 msg_recv(int sock, struct msghdr *msg) in msg_recv() argument
123 PJDLOG_ASSERT(sock >= 0); in msg_recv()
132 fd_wait(sock, true); in msg_recv()
133 if (recvmsg(sock, msg, flags) == -1) { in msg_recv()
145 msg_send(int sock, const struct msghdr *msg) in msg_send() argument
148 PJDLOG_ASSERT(sock >= 0); in msg_send()
151 fd_wait(sock, false); in msg_send()
152 if (sendmsg(sock, msg, 0) == -1) { in msg_send()
164 cred_send(int sock) in cred_send() argument
197 if (msg_send(sock, &msg) == -1) in cred_send()
[all …]
/freebsd-11-stable/contrib/apr/include/
HDapr_network_io.h351 APR_DECLARE(apr_status_t) apr_socket_bind(apr_socket_t *sock,
361 APR_DECLARE(apr_status_t) apr_socket_listen(apr_socket_t *sock,
376 apr_socket_t *sock,
385 APR_DECLARE(apr_status_t) apr_socket_connect(apr_socket_t *sock,
400 APR_DECLARE(apr_status_t) apr_socket_atreadeof(apr_socket_t *sock,
534 apr_socket_t *sock);
543 APR_DECLARE(apr_status_t) apr_socket_data_set(apr_socket_t *sock, void *data,
564 APR_DECLARE(apr_status_t) apr_socket_send(apr_socket_t *sock, const char *buf,
585 APR_DECLARE(apr_status_t) apr_socket_sendv(apr_socket_t *sock,
596 APR_DECLARE(apr_status_t) apr_socket_sendto(apr_socket_t *sock,
[all …]
/freebsd-11-stable/contrib/netbsd-tests/net/
HDnet_common.sh110 local sock=$1
114 export RUMP_SERVER=$sock
146 local sock=$1
152 atf_check -s exit:0 rump_server $libs $sock
154 echo $sock >> $_rump_server_socks
160 local sock=$1
171 _rump_server_start_common $sock $libs
178 local sock=$1
189 _rump_server_start_common $sock $libs
196 local sock=$1
[all …]
/freebsd-11-stable/tools/regression/sockets/rtsocket/
HDrtsocket.c46 int sock, socks[2]; in main() local
48 sock = socket(PF_ROUTE, SOCK_STREAM, 0); in main()
49 if (sock >= 0) { in main()
50 close(sock); in main()
52 sock); in main()
58 sock = socket(PF_ROUTE, SOCK_DGRAM, 0); in main()
59 if (sock >= 0) { in main()
60 close(sock); in main()
62 sock); in main()
68 sock = socket(PF_ROUTE, SOCK_RAW, 0); in main()
[all …]
/freebsd-11-stable/tools/regression/sockets/unix_socket/
HDunix_socket.c45 int sock, socks[2]; in main() local
47 sock = socket(PF_LOCAL, SOCK_STREAM, 0); in main()
48 if (sock < 0) in main()
50 close(sock); in main()
52 sock = socket(PF_LOCAL, SOCK_DGRAM, 0); in main()
53 if (sock < 0) in main()
55 close(sock); in main()
57 sock = socket(PF_LOCAL, SOCK_RAW, 0); in main()
58 if (sock >= 0) { in main()
59 close(sock); in main()
[all …]
/freebsd-11-stable/crypto/heimdal/lib/kadm5/
HDsend_recv.c44 krb5_storage *sock; in _kadm5_client_send() local
46 assert(context->sock != -1); in _kadm5_client_send()
62 sock = krb5_storage_from_fd(context->sock); in _kadm5_client_send()
63 if(sock == NULL) { in _kadm5_client_send()
69 ret = krb5_store_data(sock, out); in _kadm5_client_send()
72 krb5_storage_free(sock); in _kadm5_client_send()
82 krb5_storage *sock; in _kadm5_client_recv() local
84 sock = krb5_storage_from_fd(context->sock); in _kadm5_client_recv()
85 if(sock == NULL) { in _kadm5_client_recv()
89 ret = krb5_ret_data(sock, &data); in _kadm5_client_recv()
[all …]
/freebsd-11-stable/lib/libcasper/libcasper/
HDlibcasper.c79 int sock[2], serrno, pfd; in cap_init() local
84 sock) == -1) { in cap_init()
91 close(sock[0]); in cap_init()
92 casper_main_loop(sock[1]); in cap_init()
96 close(sock[1]); in cap_init()
97 chan = cap_wrap(sock[0]); in cap_init()
100 close(sock[0]); in cap_init()
112 close(sock[0]); in cap_init()
113 close(sock[1]); in cap_init()
119 cap_wrap(int sock) in cap_wrap() argument
[all …]

12345678910>>...16