Home
last modified time | relevance | path

Searched refs:sock (Results 101 - 125 of 465) sorted by relevance

12345678910>>...19

/third_party/python/Lib/asyncio/
H A Dunix_events.py231 ssl=None, sock=None,
251 if sock is not None:
253 'path and sock can not be specified at the same time')
256 sock = socket.socket(socket.AF_UNIX, socket.SOCK_STREAM, 0)
258 sock.setblocking(False)
259 await self.sock_connect(sock, path)
261 sock.close()
265 if sock is None:
266 raise ValueError('no path and sock were specified')
267 if (sock
[all...]
/third_party/curl/tests/libtest/
H A Dlibntlmconnect.c44 curl_socket_t sock; in callback() local
64 sock = CURL_SOCKET_BAD; in callback()
66 sock = (curl_socket_t)longdata; in callback()
68 if(sock != CURL_SOCKET_BAD) { in callback()
72 sockets[idx] = sock; in callback()
74 else if(sock != sockets[idx]) { in callback()
78 curlx_sztosi(idx), (int)sockets[idx], (int)sock); in callback()
/third_party/libwebsockets/minimal-examples/raw/minimal-raw-netcat/
H A Dminimal-raw-netcat.c144 lws_sock_file_fd_type sock; in main() local
207 sock.sockfd = socket(rp->ai_family, rp->ai_socktype, in main()
209 if (sock.sockfd != LWS_SOCK_INVALID) in main()
220 if (connect(sock.sockfd, rp->ai_addr, sizeof(*rp->ai_addr)) < 0) { in main()
232 raw_wsi = lws_adopt_descriptor_vhost(vhost, LWS_ADOPT_SOCKET, sock, in main()
239 sock.filefd = 0; in main()
241 sock, protocols[0].name, NULL); in main()
/third_party/rust/crates/nix/src/
H A Difaddrs.rs196 let sock = if let Some(sock) = iface.netmask { in test_getifaddrs_netmask_correct()
197 sock in test_getifaddrs_netmask_correct()
201 if sock.family() == Some(crate::sys::socket::AddressFamily::Inet) { in test_getifaddrs_netmask_correct()
202 let _ = sock.as_sockaddr_in().unwrap(); in test_getifaddrs_netmask_correct()
204 } else if sock.family() in test_getifaddrs_netmask_correct()
207 let _ = sock.as_sockaddr_in6().unwrap(); in test_getifaddrs_netmask_correct()
/third_party/node/test/parallel/
H A Dtest-http-chunked-smuggling.js19 const sock = net.connect(server.address().port);
21 sock.write('' +
39 sock.resume();
40 sock.on('end', common.mustCall(function() {
H A Dtest-net-connect-memleak.js42 const sock = net.createConnection(
47 setImmediate(done, sock);
51 function done(sock) {
55 sock.end();
H A Dtest-tls-connect-memleak.js49 const sock = tls.connect(
55 setImmediate(done, sock);
59 function done(sock) {
63 sock.end();
/drivers/peripheral/wlan/wpa/interfaces/hdi_service/service_common/
H A Dwpa_hdi_util.c116 int sock = socket(AF_INET, SOCK_DGRAM, 0); in GetIfaceState() local
117 if (sock < 0) { in GetIfaceState()
126 close(sock); in GetIfaceState()
129 if (ioctl(sock, SIOCGIFFLAGS, &ifr) < 0) { in GetIfaceState()
131 close(sock); in GetIfaceState()
136 close(sock); in GetIfaceState()
/third_party/lwip/src/core/distributed_net/
H A Dudp_transmit.c63 ssize_t udp_transmit_sendto(int sock, const void *buf, size_t buf_len, const struct sockaddr_in *dest_addr) in udp_transmit_sendto() argument
93 return lwip_sendmsg_internal(sock, &send_hdr, 0); in udp_transmit_sendto()
95 return lwip_sendmsg(sock, &send_hdr, 0); in udp_transmit_sendto()
99 ssize_t udp_transmit_sendmsg(int sock, const struct msghdr *hdr) in udp_transmit_sendmsg() argument
139 ssize_t ret = lwip_sendmsg_internal(sock, &send_hdr, 0); in udp_transmit_sendmsg()
141 ssize_t ret = lwip_sendmsg(sock, &send_hdr, 0); in udp_transmit_sendmsg()
/third_party/mesa3d/src/vulkan/overlay-layer/
H A Dmesa-overlay-control.py22 sock = socket.socket(socket.AF_UNIX, socket.SOCK_STREAM)
24 sock.connect(path)
29 self.sock = sock
33 epoll.register(sock, EPOLLIN | EPOLLPRI | EPOLLERR)
47 if fd != self.sock.fileno():
55 msg = self.sock.recv(4096)
66 self.sock.send(msg)
/third_party/toybox/toys/net/
H A Dping.c54 int sock;
172 TT.sock = socket(ai->ai_family, SOCK_DGRAM, in ping_main()
174 if (TT.sock == -1) { in ping_main()
182 if (TT.I) xbind(TT.sock, sa, sizeof(srcaddr)); in ping_main()
185 xsetsockopt(TT.sock, SOL_IP, IP_RECVTTL, &len, sizeof(len)); in ping_main()
189 xsetsockopt(TT.sock, SOL_SOCKET, SO_MARK, &len, sizeof(len)); in ping_main()
195 xsetsockopt(TT.sock, IPPROTO_IP, IP_TTL, &len, 4); in ping_main()
196 else xsetsockopt(TT.sock, IPPROTO_IPV6, IPV6_UNICAST_HOPS, &len, sizeof(len)); in ping_main()
255 xsendto(TT.sock, toybuf, TT.s+sizeof(*ih), TT.sa); in ping_main()
272 if (!(len = xrecvmsgwait(TT.sock, in ping_main()
[all...]
/third_party/curl/tests/server/
H A Drtspd.c656 static int get_request(curl_socket_t sock, struct httprequest *req) in get_request() argument
706 got = sread(sock, reqbuf + req->offset, req->cl); in get_request()
708 got = sread(sock, reqbuf + req->offset, REQBUFSIZ-1 - req->offset); in get_request()
767 static int send_doc(curl_socket_t sock, struct httprequest *req) in send_doc() argument
797 written = swrite(sock, STREAMTHIS, count); in send_doc()
944 written = swrite(sock, buffer, num); in send_doc()
969 written = swrite(sock, req->rtp_buffer + (req->rtp_buffersize - count), in send_doc()
1057 curl_socket_t sock = CURL_SOCKET_BAD; in main() local
1163 sock = socket(AF_INET, SOCK_STREAM, 0); in main()
1166 sock in main()
[all...]
H A Dsockfilt.c1206 static curl_socket_t sockdaemon(curl_socket_t sock, in sockdaemon() argument
1222 rc = setsockopt(sock, SOL_SOCKET, SO_REUSEADDR, in sockdaemon()
1235 sclose(sock); in sockdaemon()
1240 sclose(sock); in sockdaemon()
1265 rc = bind(sock, &listener.sa, sizeof(listener.sa4)); in sockdaemon()
1273 rc = bind(sock, &listener.sa, sizeof(listener.sa6)); in sockdaemon()
1280 sclose(sock); in sockdaemon()
1298 if(getsockname(sock, &localaddr.sa, &la_size) < 0) { in sockdaemon()
1302 sclose(sock); in sockdaemon()
1323 sclose(sock); in sockdaemon()
1351 curl_socket_t sock = CURL_SOCKET_BAD; main() local
[all...]
/third_party/libbpf/src/
H A Dnetlink.c57 int sock; in libbpf_netlink_open() local
62 sock = socket(AF_NETLINK, SOCK_RAW | SOCK_CLOEXEC, proto); in libbpf_netlink_open()
63 if (sock < 0) in libbpf_netlink_open()
66 if (setsockopt(sock, SOL_NETLINK, NETLINK_EXT_ACK, in libbpf_netlink_open()
71 if (bind(sock, (struct sockaddr *)&sa, sizeof(sa)) < 0) { in libbpf_netlink_open()
77 if (getsockname(sock, (struct sockaddr *)&sa, &addrlen) < 0) { in libbpf_netlink_open()
88 return sock; in libbpf_netlink_open()
91 close(sock); in libbpf_netlink_open()
95 static void libbpf_netlink_close(int sock) in libbpf_netlink_close() argument
97 close(sock); in libbpf_netlink_close()
106 netlink_recvmsg(int sock, struct msghdr *mhdr, int flags) netlink_recvmsg() argument
132 libbpf_netlink_recv(int sock, __u32 nl_pid, int seq, __dump_nlmsg_t _fn, libbpf_dump_nlmsg_t fn, void *cookie) libbpf_netlink_recv() argument
228 int sock, ret; libbpf_netlink_send_recv() local
[all...]
/third_party/wpa_supplicant/wpa_supplicant-2.9/src/utils/
H A Deloop_win.c18 int sock; member
113 int eloop_register_read_sock(int sock, eloop_sock_handler handler, in eloop_register_read_sock() argument
128 if (WSAEventSelect(sock, event, FD_READ)) { in eloop_register_read_sock()
136 WSAEventSelect(sock, event, 0); in eloop_register_read_sock()
141 tmp[eloop.reader_count].sock = sock; in eloop_register_read_sock()
148 if (sock > eloop.max_sock) in eloop_register_read_sock()
149 eloop.max_sock = sock; in eloop_register_read_sock()
156 void eloop_unregister_read_sock(int sock) in eloop_unregister_read_sock() argument
164 if (eloop.readers[i].sock in eloop_unregister_read_sock()
675 eloop_wait_for_read_sock(int sock) eloop_wait_for_read_sock() argument
[all...]
/third_party/wpa_supplicant/wpa_supplicant-2.9_standard/src/utils/
H A Deloop_win.c18 int sock; member
113 int eloop_register_read_sock(int sock, eloop_sock_handler handler, in eloop_register_read_sock() argument
128 if (WSAEventSelect(sock, event, FD_READ)) { in eloop_register_read_sock()
136 WSAEventSelect(sock, event, 0); in eloop_register_read_sock()
141 tmp[eloop.reader_count].sock = sock; in eloop_register_read_sock()
148 if (sock > eloop.max_sock) in eloop_register_read_sock()
149 eloop.max_sock = sock; in eloop_register_read_sock()
156 void eloop_unregister_read_sock(int sock) in eloop_unregister_read_sock() argument
164 if (eloop.readers[i].sock in eloop_unregister_read_sock()
675 eloop_wait_for_read_sock(int sock) eloop_wait_for_read_sock() argument
[all...]
/third_party/libcoap/src/
H A Dcoap_io_riot.c53 coap_socket_send(coap_socket_t *sock, in coap_socket_send() argument
61 } else if (sock->flags & COAP_SOCKET_CONNECTED) { in coap_socket_send()
62 bytes_written = send(sock->fd, data, datalen, 0); in coap_socket_send()
64 bytes_written = sendto(sock->fd, data, datalen, 0, in coap_socket_send()
/third_party/pulseaudio/src/modules/bluetooth/
H A Dbackend-native.c253 int sock; in sco_do_connect() local
267 sock = socket(PF_BLUETOOTH, SOCK_SEQPACKET, BTPROTO_SCO); in sco_do_connect()
268 if (sock < 0) { in sco_do_connect()
278 if (bind(sock, (struct sockaddr *) &addr, len) < 0) { in sco_do_connect()
283 if (t->setsockopt && t->setsockopt(t, sock) < 0) in sco_do_connect()
291 err = connect(sock, (struct sockaddr *) &addr, len); in sco_do_connect()
296 return sock; in sco_do_connect()
299 close(sock); in sco_do_connect()
307 int sock; in sco_do_accept() local
313 sock in sco_do_accept()
326 int sock; sco_acquire_cb() local
465 int sock, i; sco_listen() local
[all...]
/third_party/wpa_supplicant/wpa_supplicant-2.9_standard/src/common/
H A Ddpp_tcp.c31 int sock; member
70 int sock; member
80 static void dpp_conn_tx_ready(int sock, void *eloop_ctx, void *sock_ctx);
90 if (conn->sock >= 0) { in dpp_connection_free()
92 conn->sock); in dpp_connection_free()
93 eloop_unregister_sock(conn->sock, EVENT_TYPE_READ); in dpp_connection_free()
94 eloop_unregister_sock(conn->sock, EVENT_TYPE_WRITE); in dpp_connection_free()
95 close(conn->sock); in dpp_connection_free()
204 eloop_unregister_sock(conn->sock, EVENT_TYPE_WRITE); in dpp_tcp_send()
208 res = send(conn->sock, in dpp_tcp_send()
329 dpp_conn_tx_ready(int sock, void *eloop_ctx, void *sock_ctx) dpp_conn_tx_ready() argument
[all...]
/third_party/node/test/async-hooks/
H A Dtest-udpsendwrap.js15 const sock = dgram
21 sock.send(
22 Buffer.alloc(2), 0, 2, sock.address().port,
42 sock.close(common.mustCall(onsockClosed));
46 checkInvocations(send, { init: 1, before: 1, after: 1 }, 'when sock closed');
/third_party/toybox/porting/liteos_a/toys/net/
H A Dping.c48 int sock;
152 TT.sock = socket(ai->ai_family, SOCK_RAW, in ping_main()
155 if (TT.sock == -1) { in ping_main()
163 if (TT.I) xbind(TT.sock, sa, sizeof(srcaddr)); in ping_main()
168 xsetsockopt(TT.sock, SOL_SOCKET, SO_MARK, &mark, sizeof(mark)); in ping_main()
175 xsetsockopt(TT.sock, IPPROTO_IP, IP_TTL, &len, 4); in ping_main()
176 else xsetsockopt(TT.sock, IPPROTO_IPV6, IPV6_UNICAST_HOPS, &len, 4); in ping_main()
222 xsendto(TT.sock, toybuf, TT.s+sizeof(*ih), TT.sa); in ping_main()
238 len = xrecvwait(TT.sock, toybuf, sizeof(toybuf), &srcaddr2, waitms); in ping_main()
/third_party/toybox/toys/pending/
H A Dwget.c86 int sock;
137 TT.sock = xconnectany(a); in wget_connect()
167 TT.sock = xconnectany(a); in wget_connect()
177 SSL_set_fd(TT.ssl, TT.sock); in wget_connect()
188 if (WGET_IS_HTTP) return xread(TT.sock, buf, len); in wget_read()
206 xwrite(TT.sock, buf, len); in wget_write()
220 if (TT.sock) { in wget_close()
221 xclose(TT.sock); in wget_close()
222 TT.sock = 0; in wget_close()
/third_party/python/Lib/idlelib/
H A Drpc.py132 def __init__(self, sock, objtable=None, debugging=None):
136 self.sock = sock
144 sock = self.sock
145 self.sock = None
146 if sock is not None:
147 sock.close()
342 r, w, x = select.select([], [self.sock], [])
343 n = self.sock
[all...]
/third_party/libwebsockets/minimal-examples/raw/minimal-raw-adopt-tcp/
H A Dminimal-raw-adopt-tcp.c94 lws_sock_file_fd_type sock; in main() local
153 sock.sockfd = socket(rp->ai_family, rp->ai_socktype, rp->ai_protocol); in main()
154 if (sock.sockfd != LWS_SOCK_INVALID) in main()
165 if (connect(sock.sockfd, rp->ai_addr, sizeof(*rp->ai_addr)) < 0) { in main()
177 if (!lws_adopt_descriptor_vhost(vhost, LWS_ADOPT_SOCKET, sock, in main()
/third_party/python/Lib/logging/
H A Dhandlers.py557 self.sock = None
600 self.sock = self.makeSocket()
619 if self.sock is None:
621 #self.sock can be None either because we haven't reached the retry
624 if self.sock:
626 self.sock.sendall(s)
628 self.sock.close()
629 self.sock = None # so we can call createSocket next time
661 if self.closeOnError and self.sock:
662 self.sock
[all...]

Completed in 16 milliseconds

12345678910>>...19