| /NextBSD/contrib/ntp/lib/isc/win32/ |
| HD | socket.c | 94 #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 …]
|
| /NextBSD/tools/regression/sockets/listen_backlog/ |
| HD | listen_backlog.c | 69 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 …]
|
| /NextBSD/contrib/ntp/lib/isc/unix/ |
| HD | socket.c | 471 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 …]
|
| /NextBSD/tools/regression/netinet/ipsockopt/ |
| HD | ipsockopt.c | 77 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 …]
|
| /NextBSD/contrib/apr/network_io/unix/ |
| HD | sockopt.c | 75 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 …]
|
| HD | sockets.c | 31 static apr_status_t socket_cleanup(void *sock) in socket_cleanup() argument
33 apr_socket_t *thesocket = sock; in socket_cleanup()
52 static void set_socket_vars(apr_socket_t *sock, int family, int type, int protocol) in set_socket_vars() argument
54 sock->type = type; in set_socket_vars()
55 sock->protocol = protocol; in set_socket_vars()
56 apr_sockaddr_vars_set(sock->local_addr, family, 0); in set_socket_vars()
57 apr_sockaddr_vars_set(sock->remote_addr, family, 0); in set_socket_vars()
58 sock->options = 0; in set_socket_vars()
63 sock->options |= APR_TCP_NODELAY; in set_socket_vars()
85 apr_status_t apr_socket_protocol_get(apr_socket_t *sock, int *protocol) in apr_socket_protocol_get() argument
[all …]
|
| HD | sendrecv.c | 30 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 …]
|
| HD | multicast.c | 95 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 …]
|
| /NextBSD/contrib/ntp/lib/isc/ |
| HD | socket_api.c | 105 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 …]
|
| /NextBSD/tools/regression/sockets/shutdown/ |
| HD | shutdown.c | 43 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 …]
|
| /NextBSD/tools/regression/sockets/sigpipe/ |
| HD | sigpipe.c | 88 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 …]
|
| /NextBSD/contrib/ntp/lib/isc/include/isc/ |
| HD | socket.h | 277 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 …]
|
| /NextBSD/usr.bin/sockstat/ |
| HD | sockstat.c | 100 struct sock { struct
111 struct sock *next; argument
115 static struct sock *sockhash[HASHSIZE];
272 free_socket(struct sock *sock) in free_socket() argument
276 cur = sock->laddr; in free_socket()
282 cur = sock->faddr; in free_socket()
288 free(sock); in free_socket()
294 struct sock *sock; in gather_sctp() local
330 if ((sock = calloc(1, sizeof *sock)) == NULL) in gather_sctp()
332 sock->socket = xinpcb->socket; in gather_sctp()
[all …]
|
| /NextBSD/contrib/wpa/wpa_supplicant/ |
| HD | ctrl_iface_unix.c | 52 int sock; member
60 int sock; member
67 const char *ifname, int sock,
79 static void wpas_ctrl_sock_debug(const char *title, int sock, const char *buf, in wpas_ctrl_sock_debug() argument
92 if (getsockopt(sock, SOL_SOCKET, SO_SNDBUF, &sndbuf, &optlen) < 0) in wpas_ctrl_sock_debug()
95 if (ioctl(sock, SIOCOUTQ, &outq) < 0) in wpas_ctrl_sock_debug()
100 title, sock, sndbuf, outq, (int) len); in wpas_ctrl_sock_debug()
184 static void wpa_supplicant_ctrl_iface_receive(int sock, void *eloop_ctx, in wpa_supplicant_ctrl_iface_receive() argument
197 res = recvfrom(sock, buf, sizeof(buf) - 1, 0, in wpa_supplicant_ctrl_iface_receive()
248 wpas_ctrl_sock_debug("ctrl_sock-sendto", sock, reply, in wpa_supplicant_ctrl_iface_receive()
[all …]
|
| HD | ctrl_iface_udp.c | 46 int sock; member
197 static void wpa_supplicant_ctrl_iface_receive(int sock, void *eloop_ctx, argument
218 res = recvfrom(sock, buf, sizeof(buf) - 1, 0,
309 sendto(sock, reply, reply_len, 0, (struct sockaddr *) &from,
313 sendto(sock, "FAIL\n", 5, 0, (struct sockaddr *) &from,
316 sendto(sock, "OK\n", 3, 0, (struct sockaddr *) &from,
353 priv->sock = -1;
359 priv->sock = socket(domain, SOCK_DGRAM, 0);
360 if (priv->sock < 0) {
387 if (bind(priv->sock, (struct sockaddr *) &addr, sizeof(addr)) < 0) {
[all …]
|
| /NextBSD/sbin/hastd/ |
| HD | proto_common.c | 53 blocking_socket(int sock) in blocking_socket() argument
57 flags = fcntl(sock, F_GETFL); in blocking_socket()
63 proto_descriptor_send(int sock, int fd) in proto_descriptor_send() argument
69 PJDLOG_ASSERT(sock >= 0); in proto_descriptor_send()
86 if (sendmsg(sock, &msg, 0) == -1) in proto_descriptor_send()
93 proto_common_send(int sock, const unsigned char *data, size_t size, int fd) in proto_common_send() argument
99 PJDLOG_ASSERT(sock >= 0); in proto_common_send()
106 if (shutdown(sock, SHUT_RD) == -1) in proto_common_send()
116 done = send(sock, data, sendsize, MSG_NOSIGNAL); in proto_common_send()
145 if (errno == EAGAIN && blocking_socket(sock)) in proto_common_send()
[all …]
|
| /NextBSD/contrib/openbsm/bin/auditdistd/ |
| HD | proto_common.c | 52 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 …]
|
| /NextBSD/contrib/apr/include/ |
| HD | apr_network_io.h | 321 APR_DECLARE(apr_status_t) apr_socket_bind(apr_socket_t *sock,
331 APR_DECLARE(apr_status_t) apr_socket_listen(apr_socket_t *sock,
346 apr_socket_t *sock,
355 APR_DECLARE(apr_status_t) apr_socket_connect(apr_socket_t *sock,
370 APR_DECLARE(apr_status_t) apr_socket_atreadeof(apr_socket_t *sock,
468 apr_socket_t *sock);
477 APR_DECLARE(apr_status_t) apr_socket_data_set(apr_socket_t *sock, void *data,
498 APR_DECLARE(apr_status_t) apr_socket_send(apr_socket_t *sock, const char *buf,
519 APR_DECLARE(apr_status_t) apr_socket_sendv(apr_socket_t *sock,
530 APR_DECLARE(apr_status_t) apr_socket_sendto(apr_socket_t *sock,
[all …]
|
| /NextBSD/usr.sbin/asl/ |
| HD | bsd_in.c | 43 static int sock = -1; variable
84 if (sock >= 0) return -1; in bsd_in_init()
125 sock = launch_data_get_fd(fd_dict); in bsd_in_init()
130 if (setsockopt(sock, SOL_SOCKET, SO_RCVBUF, &rbufsize, len) < 0) in bsd_in_init()
132 …asldebug("%s: couldn't set receive buffer size for socket %d (%s): %s\n", MY_ID, sock, _PATH_SYSLO… in bsd_in_init()
133 close(sock); in bsd_in_init()
134 sock = -1; in bsd_in_init()
138 if (fcntl(sock, F_SETFL, O_NONBLOCK) < 0) in bsd_in_init()
140 …asldebug("%s: couldn't set O_NONBLOCK for socket %d (%s): %s\n", MY_ID, sock, _PATH_SYSLOG_IN, str… in bsd_in_init()
141 close(sock); in bsd_in_init()
[all …]
|
| /NextBSD/lib/libnv/ |
| HD | msgio.c | 119 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 …]
|
| /NextBSD/tools/regression/sockets/rtsocket/ |
| HD | rtsocket.c | 46 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 …]
|
| /NextBSD/tools/regression/sockets/unix_socket/ |
| HD | unix_socket.c | 45 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 …]
|
| /NextBSD/crypto/heimdal/lib/kadm5/ |
| HD | send_recv.c | 44 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 …]
|
| /NextBSD/usr.sbin/bluetooth/hcsecd/ |
| HD | hcsecd.c | 49 (int sock, struct sockaddr_hci *addr, bdaddr_p bdaddr);
51 (int sock, struct sockaddr_hci *addr, bdaddr_p bdaddr);
53 (int sock, struct sockaddr_hci *addr, bdaddr_p bdaddr, char const *pin);
55 (int sock, struct sockaddr_hci *addr, bdaddr_p bdaddr, uint8_t *key);
57 (int sock, struct sockaddr_hci *addr, ng_hci_link_key_notification_ep *ep);
69 int n, detach, sock; in main() local
119 sock = socket(PF_BLUETOOTH, SOCK_RAW, BLUETOOTH_PROTO_HCI); in main()
120 if (sock < 0) in main()
128 if (setsockopt(sock, SOL_HCI_RAW, SO_HCI_RAW_FILTER, in main()
156 n = recvfrom(sock, buffer, sizeof(buffer), 0, in main()
[all …]
|
| /NextBSD/tools/regression/netinet/msocket/ |
| HD | msocket.c | 83 u_char modifiedv, u_char fakev, const char *socktype, int sock, in test_u_char() argument
96 ret = getsockopt(sock, IPPROTO_IP, optname, &uc, &socklen); in test_u_char()
111 ret = setsockopt(sock, IPPROTO_IP, optname, &uc, sizeof(uc)); in test_u_char()
121 ret = getsockopt(sock, IPPROTO_IP, optname, &uc, &socklen); in test_u_char()
140 int sock, int flags) in test_in_addr() argument
152 ret = getsockopt(sock, IPPROTO_IP, optname, &ia, &socklen); in test_in_addr()
168 ret = setsockopt(sock, IPPROTO_IP, optname, &ia, sizeof(ia)); in test_in_addr()
178 ret = getsockopt(sock, IPPROTO_IP, optname, &ia, &socklen); in test_in_addr()
242 test_add_multi(int sock, const char *socktype, struct ip_mreq imr, in test_add_multi() argument
248 ret = setsockopt(sock, IPPROTO_IP, IP_ADD_MEMBERSHIP, &imr, in test_add_multi()
[all …]
|