Home
last modified time | relevance | path

Searched refs:socket (Results 1 – 25 of 1428) sorted by relevance

12345678910>>...58

/netbsd-src/sys/sys/
H A Dsocketvar.h81 TAILQ_HEAD(soqhead, socket);
84 * Variables for socket buffering.
89 struct socket *sb_so; /* back pointer to socket */
101 socket buffer */
117 #define SB_AUTOSIZE 0x800 /* automatically size socket buffer */
120 * Kernel structure per socket.
133 struct socket { struct
136 short so_type; /* generic type, see socket.h */ argument
137 short so_options; /* from socket cal argument
146 so_protosocket global() argument
154 so_headsocket global() argument
158 so_qsocket global() argument
172 so_upcallsocket global() argument
174 so_sendsocket global() argument
177 so_receivesocket global() argument
181 so_mownersocket global() argument
182 so_uidinfosocket global() argument
186 so_credsocket global() argument
[all...]
H A Dprotosw.h63 struct socket;
83 (int, struct socket *, struct sockopt *);
239 int (*pr_attach)(struct socket *, int);
240 void (*pr_detach)(struct socket *);
241 int (*pr_accept)(struct socket *, struct sockaddr *);
242 int (*pr_connect)(struct socket *, struct sockaddr *, struct lwp *);
243 int (*pr_connect2)(struct socket *, struct socket *);
244 int (*pr_bind)(struct socket *, struct sockaddr *, struct lwp *);
245 int (*pr_listen)(struct socket *, struct lwp *);
246 int (*pr_disconnect)(struct socket *);
[all …]
/netbsd-src/external/mpl/bind/dist/bin/tests/system/timeouts/
H A Dtests_tcp_timeouts.py16 import socket
55 with socket.socket(socket.AF_INET, socket.SOCK_STREAM) as sock:
75 with socket.socket(socket.AF_INET, socket.SOCK_STREAM) as sock:
106 with socket
[all...]
/netbsd-src/sys/rump/net/lib/libsockin/
H A Dsockin.c70 static int sockin_attach(struct socket *, int);
71 static void sockin_detach(struct socket *);
72 static int sockin_accept(struct socket *, struct sockaddr *);
73 static int sockin_connect2(struct socket *, struct socket *);
74 static int sockin_bind(struct socket *, struct sockaddr *, struct lwp *);
75 static int sockin_listen(struct socket *, struct lwp *);
76 static int sockin_connect(struct socket *, struct sockaddr *, struct lwp *);
77 static int sockin_disconnect(struct socket *);
78 static int sockin_shutdown(struct socket *);
79 static int sockin_abort(struct socket *);
[all …]
/netbsd-src/sys/net/
H A Dlink_proto.c51 static int link_attach(struct socket *, int);
52 static void link_detach(struct socket *);
53 static int link_accept(struct socket *, struct sockaddr *);
54 static int link_bind(struct socket *, struct sockaddr *, struct lwp *);
55 static int link_listen(struct socket *, struct lwp *);
56 static int link_connect(struct socket *, struct sockaddr *, struct lwp *);
57 static int link_connect2(struct socket *, struct socket *);
58 static int link_disconnect(struct socket *);
59 static int link_shutdown(struct socket *);
60 static int link_abort(struct socket *);
[all …]
/netbsd-src/external/mpl/bind/dist/bin/tests/system/pipelined/ans5/
H A Dans.py41 import socket
75 self.cconn = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
123 self.csock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
187 usock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
188 usock.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
194 sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
195 sock.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
207 except socket.timeout:
/netbsd-src/sys/netbt/
H A Dl2cap_socket.c86 l2cap_attach(struct socket *so, int proto) in l2cap_attach()
112 l2cap_detach(struct socket *so) in l2cap_detach()
120 l2cap_accept(struct socket *so, struct sockaddr *nam) in l2cap_accept()
134 l2cap_bind(struct socket *so, struct sockaddr *nam, struct lwp *l) in l2cap_bind()
155 l2cap_listen(struct socket *so, struct lwp *l) in l2cap_listen()
168 l2cap_connect(struct socket *so, struct sockaddr *nam, struct lwp *l) in l2cap_connect()
190 l2cap_connect2(struct socket *so, struct socket *so2) in l2cap_connect2()
201 l2cap_disconnect(struct socket *so) in l2cap_disconnect()
215 l2cap_shutdown(struct socket *so) in l2cap_shutdown()
224 l2cap_abort(struct socket *so) in l2cap_abort()
[all …]
H A Dsco_socket.c82 sco_attach(struct socket *so, int proto) in sco_attach()
103 sco_detach(struct socket *so) in sco_detach()
111 sco_accept(struct socket *so, struct sockaddr *nam) in sco_accept()
125 sco_bind(struct socket *so, struct sockaddr *nam, struct lwp *l) in sco_bind()
146 sco_listen(struct socket *so, struct lwp *l) in sco_listen()
159 sco_connect(struct socket *so, struct sockaddr *nam, struct lwp *l) in sco_connect()
181 sco_connect2(struct socket *so, struct socket *so2) in sco_connect2()
194 sco_disconnect(struct socket *so) in sco_disconnect()
208 sco_shutdown(struct socket *so) in sco_shutdown()
217 sco_abort(struct socket *so) in sco_abort()
[all …]
H A Drfcomm_socket.c85 rfcomm_attach(struct socket *so, int proto) in rfcomm_attach()
120 rfcomm_detach(struct socket *so) in rfcomm_detach()
128 rfcomm_accept(struct socket *so, struct sockaddr *nam) in rfcomm_accept()
142 rfcomm_bind(struct socket *so, struct sockaddr *nam, struct lwp *l) in rfcomm_bind()
163 rfcomm_listen(struct socket *so, struct lwp *l) in rfcomm_listen()
176 rfcomm_connect(struct socket *so, struct sockaddr *nam, struct lwp *l) in rfcomm_connect()
198 rfcomm_connect2(struct socket *so, struct socket *so2) in rfcomm_connect2()
211 rfcomm_disconnect(struct socket *so) in rfcomm_disconnect()
225 rfcomm_shutdown(struct socket *so) in rfcomm_shutdown()
234 rfcomm_abort(struct socket *so) in rfcomm_abort()
[all …]
H A Dhci_socket.c67 struct socket *hp_socket; /* socket */
321 struct socket *so = arg; in hci_drop()
333 hci_cmdwait_flush(struct socket *so) in hci_cmdwait_flush()
336 struct socket *ctx; in hci_cmdwait_flush()
344 ctx = M_GETCTX(m, struct socket *); in hci_cmdwait_flush()
354 hci_attach(struct socket *so, int proto) in hci_attach()
392 hci_detach(struct socket *so) in hci_detach()
411 hci_accept(struct socket *so, struct sockaddr *nam) in hci_accept()
419 hci_bind(struct socket *so, struct sockaddr *nam, struct lwp *l) in hci_bind()
445 hci_listen(struct socket *so, struct lwp *l) in hci_listen()
[all …]
/netbsd-src/external/mpl/bind/dist/bin/tests/system/digdelv/ans8/
H A Dans.py16 import socket
79 query4_udp = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
82 query4_tcp = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
83 query4_tcp.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
87 ctrl4_tcp = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
88 ctrl4_tcp.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
114 except socket.error as e:
182 except socket.error as e:
/netbsd-src/external/mpl/bind/dist/bin/tests/system/tcp/ans6/
H A Dans.py38 import socket
57 socket.inet_aton(host)
58 family = socket.AF_INET
59 except socket.error:
60 family = socket.AF_INET6
65 sock = socket.socket(family, socket.SOCK_STREAM)
83 err = sock.getsockopt(socket.SOL_SOCKET, socket.SO_ERROR)
133 ctlsock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
134 ctlsock.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
/netbsd-src/external/mpl/dhcp/dist/omapip/
H A Dlistener.c93 obj->socket = -1; in omapi_listen_addr()
124 obj -> socket = socket (PF_INET, SOCK_STREAM, IPPROTO_TCP); in omapi_listen_addr()
125 if (obj->socket == -1) { in omapi_listen_addr()
135 if (fcntl (obj -> socket, F_SETFD, 1) < 0) { in omapi_listen_addr()
144 if (setsockopt (obj -> socket, SOL_SOCKET, SO_REUSEADDR, in omapi_listen_addr()
152 i = bind (obj -> socket, in omapi_listen_addr()
166 if (listen (obj -> socket, max)) { in omapi_listen_addr()
171 if (fcntl (obj -> socket, F_SETFL, O_NONBLOCK) < 0) { in omapi_listen_addr()
196 if (obj->socket != -1) { in omapi_listen_addr()
197 close(obj->socket); in omapi_listen_addr()
[all …]
/netbsd-src/sys/netinet/
H A Dsctp_var.h88 int sctp_usrreq(struct socket *, int, struct mbuf *, struct mbuf *,
146 int sctp_ctloutput(int, struct socket *, struct sockopt *);
150 int sctp_shutdown(struct socket *);
154 int sctp_rcvd(struct socket *, int, struct lwp *);
155 int sctp_send(struct socket *, struct mbuf *, struct sockaddr *,
162 int sctp_bindx(struct socket *, int, struct sockaddr_storage *,
164 int sctp_do_connect_x(struct socket *, struct sctp_connectx_addrs *,
168 int sctp_peeloff(struct socket *, struct socket *, int, vaddr_t, int *);
172 int sctp_sockaddr(struct socket *, struct sockaddr *);
173 int sctp_peeraddr(struct socket *, struct sockaddr *);
[all …]
/netbsd-src/sys/netmpls/
H A Dmpls_proto.c55 static int mpls_attach(struct socket *, int);
84 mpls_attach(struct socket *so, int proto) in mpls_attach()
96 mpls_detach(struct socket *so) in mpls_detach()
101 mpls_accept(struct socket *so, struct sockaddr *nam) in mpls_accept()
109 mpls_bind(struct socket *so, struct sockaddr *nam, struct lwp *l) in mpls_bind()
117 mpls_listen(struct socket *so, struct lwp *l) in mpls_listen()
125 mpls_connect(struct socket *so, struct sockaddr *nam, struct lwp *l) in mpls_connect()
133 mpls_connect2(struct socket *so, struct socket *so2) in mpls_connect2()
141 mpls_disconnect(struct socket *so) in mpls_disconnect()
149 mpls_shutdown(struct socket *so) in mpls_shutdown()
[all …]
/netbsd-src/external/gpl2/xcvs/dist/src/
H A Dsocket-client.c56 int socket; member
94 nbytes = recv (sb->socket, data + *got, size - *got, 0); in socket_buffer_input()
135 if (send (sb->socket, data, have, 0) < 0) in socket_buffer_output()
143 nbytes = send (sb->socket, data, have, 0); in socket_buffer_output()
182 || (err = recv (n->socket, &tmp, 1, 0)) > 0) in socket_buffer_shutdown()
193 if (shutdown (n->socket, 0) < 0) in socket_buffer_shutdown()
209 SHUTDOWN_SERVER (n->socket); in socket_buffer_shutdown()
212 if (shutdown (n->socket, 1) < 0) in socket_buffer_shutdown()
229 socket_buffer_initialize (int socket, int input, in socket_buffer_initialize() argument
233 sbuf->socket = socket; in socket_buffer_initialize()
/netbsd-src/external/mit/libuv/dist/src/win/
H A Dtcp.c48 static int uv__tcp_nodelay(uv_tcp_t* handle, SOCKET socket, int enable) { in uv__tcp_nodelay() argument
49 if (setsockopt(socket, in uv__tcp_nodelay()
60 static int uv__tcp_keepalive(uv_tcp_t* handle, SOCKET socket, int enable, unsigned int delay) { in uv__tcp_keepalive() argument
61 if (setsockopt(socket, in uv__tcp_keepalive()
69 if (enable && setsockopt(socket, in uv__tcp_keepalive()
83 SOCKET socket, in uv__tcp_set_socket() argument
90 if (handle->socket != INVALID_SOCKET) in uv__tcp_set_socket()
94 if (ioctlsocket(socket, FIONBIO, &yes) == SOCKET_ERROR) { in uv__tcp_set_socket()
99 if (!SetHandleInformation((HANDLE) socket, HANDLE_FLAG_INHERIT, 0)) in uv__tcp_set_socket()
104 if (CreateIoCompletionPort((HANDLE)socket, in uv__tcp_set_socket()
[all …]
/netbsd-src/external/mpl/bind/dist/bin/tests/system/forward/ans11/
H A Dans.py16 import socket
39 udp = socket.socket(
40 socket.AF_INET6 if is_ipv6 else socket.AF_INET, socket.SOCK_DGRAM
51 raise socket.error("Can not create an IPv4 UDP listener")
59 tcp = socket.socket(
60 socket.AF_INET6 if is_ipv6 else socket.AF_INET, socket.SOCK_STREAM
63 tcp.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
73 raise socket.error("Can not create an IPv4 TCP listener")
197 except socket.error as e:
251 except socket.error as e:
/netbsd-src/sys/netinet6/
H A Ddccp6_usrreq.c115 dccp6_bind(struct socket *so, struct sockaddr *nam, struct lwp *td) in dccp6_bind()
147 dccp6_connect(struct socket *so, struct sockaddr *nam, struct lwp *l) in dccp6_connect()
233 dccp6_listen(struct socket *so, struct lwp *l) in dccp6_listen()
264 dccp6_accept(struct socket *so, struct sockaddr *nam) in dccp6_accept()
293 dccp6_ioctl(struct socket *so, u_long cmd, void *nam, struct ifnet *ifp) in dccp6_ioctl()
310 dccp6_stat(struct socket *so, struct stat *ub) in dccp6_stat()
316 dccp6_purgeif(struct socket *so, struct ifnet *ifp) in dccp6_purgeif()
338 dccp6_attach(struct socket *so, int proto) in dccp6_attach()
344 dccp6_detach(struct socket *so) in dccp6_detach()
350 dccp6_connect2(struct socket *so, struct socket *so2) in dccp6_connect2()
[all …]
/netbsd-src/external/mpl/bind/dist/bin/tests/system/dispatch/ans3/
H A Dans.py15 import socket
34 udp = socket.socket(type=socket.SOCK_DGRAM)
41 tcp = socket.socket(type=socket.SOCK_STREAM)
42 tcp.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
88 except socket.error:
/netbsd-src/usr.sbin/ldpd/
H A Dldp_command.c136 csockets[i].socket = -1; in init_command_sockets()
152 s = socket(PF_INET, SOCK_STREAM, 6); in create_command_socket()
200 if (s == csockets[i].socket) in is_command_socket()
211 if (csockets[i].socket == -1) { in add_command_socket()
212 csockets[i].socket = s; in add_command_socket()
224 int r = recv(cs->socket, recvspace, MAX_COMMAND_SIZE, MSG_PEEK); in command_dispatch()
227 command_close(cs->socket); in command_dispatch()
231 recv(cs->socket, recvspace, r, MSG_WAITALL); in command_dispatch()
236 send_prompt(cs->socket); in command_dispatch()
238 writestr(cs->socket, "Bad password\n"); in command_dispatch()
[all …]
/netbsd-src/external/bsd/libevent/dist/sample/
H A Devent-read-fifo.c91 HANDLE socket; in main() local
93 socket = CreateFileA("test.txt", /* open File */ in main()
101 if (socket == INVALID_HANDLE_VALUE) in main()
108 int socket; in main() local
124 socket = open(fifo, O_RDONLY | O_NONBLOCK, 0); in main()
126 if (socket == -1) { in main()
138 evfifo = event_new(base, (evutil_socket_t)socket, EV_READ|EV_PERSIST, fifo_read, in main()
145 evfifo = event_new(base, socket, EV_READ|EV_PERSIST, fifo_read, in main()
155 CloseHandle(socket); in main()
157 close(socket); in main()
/netbsd-src/sys/netipsec/
H A Dkeysock.c107 key_output(struct mbuf *m, struct socket *so) in key_output()
222 _key_sendup_mbuf(struct socket *so, struct mbuf *m, in _key_sendup_mbuf()
275 struct socket * kso = rp->rcb_socket; in _key_sendup_mbuf()
355 key_sendup_mbuf(struct socket *so, struct mbuf *m, in key_sendup_mbuf()
373 key_attach(struct socket *so, int proto) in key_attach()
416 key_detach(struct socket *so) in key_detach()
435 key_accept(struct socket *so, struct sockaddr *nam) in key_accept()
445 key_bind(struct socket *so, struct sockaddr *nam, struct lwp *l) in key_bind()
453 key_listen(struct socket *so, struct lwp *l) in key_listen()
461 key_connect(struct socket *so, struct sockaddr *nam, struct lwp *l) in key_connect()
[all …]
/netbsd-src/external/gpl3/gdb/dist/gnulib/import/m4/
H A Dsys_socket_h.m421 of socket functions.])
26 AC_CACHE_CHECK([whether <sys/socket.h> is self-contained],
29 AC_COMPILE_IFELSE([AC_LANG_PROGRAM([[#include <sys/socket.h>]], [[]])],
34 dnl If the shutdown function exists, <sys/socket.h> should define
38 AC_CACHE_CHECK([whether <sys/socket.h> defines the SHUT_* macros],
42 [AC_LANG_PROGRAM([[#include <sys/socket.h>]],
56 sys/socket.h in i386-unknown-freebsd4.10 and
60 #include <sys/socket.h>
78 #include <sys/socket.h>
96 #include <sys/socket.h>
[all …]
/netbsd-src/external/mpl/bind/dist/lib/isc/netmgr/
H A Dhttp.c213 nghttp2_session *ngsession, isc_nmsocket_t *socket);
229 server_call_cb(isc_nmsocket_t *socket, const isc_result_t result,
530 /* detach from server socket */ in on_client_data_chunk_recv_callback()
672 * the socket gets marked as inactive, allowing the HTTP/2 data in on_server_stream_close_callback()
675 * An HTTP/2 stream socket will normally be marked as inactive in in on_server_stream_close_callback()
981 * Read callback from TLS socket. in http_readcb()
1688 isc_nmsocket_t *socket = NULL; in server_handle_path_header()
1707 socket = isc_mempool_get(worker->nmsocket_pool); in server_handle_path_header()
1709 isc__nmsocket_init(socket, worker, isc_nm_httpsocket, &local, NULL); in server_handle_path_header()
1710 http_initsocket(socket); in server_handle_path_header()
1632 isc_nmsocket_t *socket = NULL; server_on_begin_headers_callback() local
1687 server_handle_path_header(isc_nmsocket_t * socket,const uint8_t * value,const size_t valuelen) server_handle_path_header() argument
1753 server_handle_method_header(isc_nmsocket_t * socket,const uint8_t * value,const size_t valuelen) server_handle_method_header() argument
1769 server_handle_scheme_header(isc_nmsocket_t * socket,const uint8_t * value,const size_t valuelen) server_handle_scheme_header() argument
1785 server_handle_content_length_header(isc_nmsocket_t * socket,const uint8_t * value,const size_t valuelen) server_handle_content_length_header() argument
1803 server_handle_content_type_header(isc_nmsocket_t * socket,const uint8_t * value,const size_t valuelen) server_handle_content_type_header() argument
1817 server_handle_header(isc_nmsocket_t * socket,const uint8_t * name,size_t namelen,const uint8_t * value,const size_t valuelen) server_handle_header() argument
1855 isc_nmsocket_t *socket = NULL; server_on_header_callback() local
1901 isc_nmsocket_t *socket = (isc_nmsocket_t *)source->ptr; server_read_callback() local
1930 server_send_response(nghttp2_session * ngsession,int32_t stream_id,const nghttp2_nv * nva,size_t nvlen,isc_nmsocket_t * socket) server_send_response() argument
1983 log_server_error_response(const isc_nmsocket_t * socket,const struct http_error_responses * response) log_server_error_response() argument
2007 server_send_error_response(const isc_http_error_responses_t error,nghttp2_session * ngsession,isc_nmsocket_t * socket) server_send_error_response() argument
2037 server_call_cb(isc_nmsocket_t * socket,isc_nm_http_session_t * session,const isc_result_t result,isc_region_t * data) server_call_cb() argument
2069 server_on_request_recv(nghttp2_session * ngsession,isc_nm_http_session_t * session,isc_nmsocket_t * socket) server_on_request_recv() argument
2331 isc_nmsocket_t *socket = NULL; server_on_frame_recv_callback() local
[all...]

12345678910>>...58