| /external/wpa_supplicant_8/src/common/ |
| ctrl_iface_common.h | 28 void sockaddr_print(int level, const char *msg, struct sockaddr_storage *sock,
|
| /prebuilts/gdb/darwin-x86/lib/python2.7/ |
| poplib.py | 83 self.sock = socket.create_connection((host, port), timeout)
84 self.file = self.sock.makefile('rb')
91 self.sock.sendall('%s%s' % (line, CRLF))
255 self.sock.close()
256 del self.file, self.sock
337 self.sock = None
341 self.sock = socket.socket(af, socktype, proto)
342 self.sock.connect(sa)
344 if self.sock:
345 self.sock.close(
[all...] |
| /prebuilts/gdb/linux-x86/lib/python2.7/ |
| poplib.py | 83 self.sock = socket.create_connection((host, port), timeout)
84 self.file = self.sock.makefile('rb')
91 self.sock.sendall('%s%s' % (line, CRLF))
255 self.sock.close()
256 del self.file, self.sock
337 self.sock = None
341 self.sock = socket.socket(af, socktype, proto)
342 self.sock.connect(sa)
344 if self.sock:
345 self.sock.close(
[all...] |
| /prebuilts/python/darwin-x86/2.7.5/lib/python2.7/ |
| poplib.py | 83 self.sock = socket.create_connection((host, port), timeout)
84 self.file = self.sock.makefile('rb')
91 self.sock.sendall('%s%s' % (line, CRLF))
255 self.sock.close()
256 del self.file, self.sock
337 self.sock = None
341 self.sock = socket.socket(af, socktype, proto)
342 self.sock.connect(sa)
344 if self.sock:
345 self.sock.close(
[all...] |
| /prebuilts/python/linux-x86/2.7.5/lib/python2.7/ |
| poplib.py | 83 self.sock = socket.create_connection((host, port), timeout)
84 self.file = self.sock.makefile('rb')
91 self.sock.sendall('%s%s' % (line, CRLF))
255 self.sock.close()
256 del self.file, self.sock
337 self.sock = None
341 self.sock = socket.socket(af, socktype, proto)
342 self.sock.connect(sa)
344 if self.sock:
345 self.sock.close(
[all...] |
| /system/core/fastboot/ |
| tcp.h | 53 std::unique_ptr<Transport> Connect(std::unique_ptr<Socket> sock, std::string* error);
|
| /system/core/libsysutils/include/sysutils/ |
| FrameworkListener.h | 40 FrameworkListener(int sock);
|
| /external/autotest/client/common_lib/cros/bluetooth/ |
| bluetooth_gatt_server.py | 34 sock, addr = btsocket.create_le_gatt_server_socket()
37 asyncore.dispatcher.__init__(self, sock=sock)
|
| /external/ltp/testcases/network/rpc/rpc-tirpc/tests_pack/rpc_suite/rpc/rpc_createdestroy_clnttcp_create/ |
| rpc_clnttcp_create_limits.c | 67 int sock = RPC_ANYSOCK; local
89 sock = socket(AF_UNIX, SOCK_DGRAM, IPPROTO_TCP);
101 clnttcp_create(&server_addr, progNum, VERSNUM, &sock,
|
| /external/libpcap/ |
| sockutils.c | 285 SOCKET sock; local
287 sock = socket(addrinfo->ai_family, addrinfo->ai_socktype, addrinfo->ai_protocol);
288 if (sock == -1)
309 if (setsockopt(sock, IPPROTO_IPV6, IPV6_BINDV6ONLY, (char *)&on, sizeof (int)) == -1)
319 if (bind(sock, addrinfo->ai_addr, (int) addrinfo->ai_addrlen) != 0)
326 if (listen(sock, nconn) == -1)
333 return sock;
354 if (connect(sock, tempaddrinfo->ai_addr, (int) tempaddrinfo->ai_addrlen) == -1)
393 closesocket(sock);
397 return sock;
[all...] |
| /external/wpa_supplicant_8/src/drivers/ |
| driver_wired.c | 120 static void handle_read(int sock, void *eloop_ctx, void *sock_ctx)
125 len = recv(sock, buf, sizeof(buf), 0);
135 static void handle_dhcp(int sock, void *eloop_ctx, void *sock_ctx)
143 len = recv(sock, buf, sizeof(buf), 0);
176 drv->common.sock = socket(PF_PACKET, SOCK_RAW, htons(ETH_P_PAE));
177 if (drv->common.sock < 0) {
183 if (eloop_register_read_sock(drv->common.sock, handle_read,
191 if (ioctl(drv->common.sock, SIOCGIFINDEX, &ifr) != 0) {
203 if (bind(drv->common.sock, (struct sockaddr *) &addr, sizeof(addr)) < 0)
210 if (wired_multicast_membership(drv->common.sock, ifr.ifr_ifindex
[all...] |
| /external/boringssl/src/tool/ |
| transport_common.cc | 56 static int closesocket(int sock) {
57 return close(sock);
304 bool SocketSetNonBlocking(int sock, bool is_non_blocking) {
309 ok = 0 == ioctlsocket(sock, FIONBIO, &arg);
311 int flags = fcntl(sock, F_GETFL, 0);
320 ok = 0 == fcntl(sock, F_SETFL, flags);
328 static bool SocketSelect(int sock, bool stdin_open, bool *socket_ready,
336 FD_SET(sock, &read_fds);
337 if (select(sock + 1, &read_fds, NULL, NULL, NULL) <= 0) {
345 if (FD_ISSET(sock, &read_fds))
[all...] |
| /system/core/liblog/ |
| logd_reader.c | 264 int sock = socket_local_client("logd", ANDROID_SOCKET_NAMESPACE_RESERVED, local
266 if (sock < 0) {
267 return sock;
275 ret = TEMP_FAILURE_RETRY(write(sock, buf, len));
282 while ((ret = TEMP_FAILURE_RETRY(read(sock, cp, len))) > 0) {
293 p.fd = sock;
317 close(sock);
468 int e, ret, remaining, sock; local
474 sock = atomic_load(&transp->context.sock);
656 int sock = atomic_exchange(&transp->context.sock, -1); local
[all...] |
| /external/curl/tests/server/ |
| sockfilt.c | 702 curl_socket_t sock; local
820 sock = data[idx].fd;
821 fds = curlx_sktosi(sock);
829 FD_CLR(sock, writefds);
830 FD_CLR(sock, exceptfds);
834 FD_CLR(sock, readfds);
835 FD_CLR(sock, exceptfds);
844 FD_CLR(sock, readfds);
848 FD_CLR(sock, writefds);
861 FD_CLR(sock, exceptfds)
1342 curl_socket_t sock = CURL_SOCKET_BAD; local
[all...] |
| /external/libnl/src/lib/ |
| utils.c | 101 struct nl_sock *sock; local
103 if (!(sock = nl_socket_alloc()))
106 return sock;
168 struct nl_cache *nl_cli_alloc_cache(struct nl_sock *sock, const char *name,
174 if ((err = ac(sock, &cache)) < 0)
|
| /external/libnl/src/ |
| nl-class-add.c | 53 struct nl_sock *sock; local
66 sock = nl_cli_alloc_socket();
67 nl_cli_connect(sock, NETLINK_ROUTE);
69 link_cache = nl_cli_link_alloc_cache(sock);
151 if ((err = rtnl_class_add(sock, class, flags)) < 0)
|
| nl-cls-add.c | 53 struct nl_sock *sock; local
66 sock = nl_cli_alloc_socket();
67 nl_cli_connect(sock, NETLINK_ROUTE);
69 link_cache = nl_cli_link_alloc_cache(sock);
159 if ((err = rtnl_cls_add(sock, cls, flags)) < 0)
|
| /frameworks/base/cmds/statsd/src/socket/ |
| StatsSocketListener.cpp | 121 int sock = android_get_control_socket(socketName); local
123 if (sock < 0) { // statsd started up in init.sh
124 sock = socket_local_server(socketName, ANDROID_SOCKET_NAMESPACE_RESERVED, SOCK_DGRAM);
127 if (setsockopt(sock, SOL_SOCKET, SO_PASSCRED, &on, sizeof(on))) {
131 return sock;
|
| /external/curl/tests/libtest/ |
| libntlmconnect.c | 42 curl_socket_t sock; local
60 sock = CURL_SOCKET_BAD;
62 sock = (curl_socket_t)longdata;
64 if(sock != CURL_SOCKET_BAD) {
68 sockets[idx] = sock;
70 else if(sock != sockets[idx]) {
74 curlx_sztosi(idx), (int)sockets[idx], (int)sock);
|
| /external/v8/tools/testrunner/network/ |
| endpoint.py | 43 def __init__(self, sock, server, ctx):
45 self.sock = sock
80 compression.Send(result, self.sock)
89 def Execute(workspace, ctx, tests, sock, server):
112 progress_indicator = EndpointProgress(sock, server, ctx)
122 compression.Send([[-1, message]], sock)
|
| /libcore/luni/src/test/java/libcore/java/net/ |
| SocketTimeoutTest.java | 108 try (Socket sock = new Socket();
111 sock.setSoTimeout(TIMEOUT_MILLIS);
114 sock.setSendBufferSize(1);
116 int actualSize = sock.getSendBufferSize() + serverSocket.getReceiveBufferSize();
118 sock.connect(serverSocket.getLocalSocketAddress());
126 sock.getOutputStream().write(new byte[actualSize + 1]);
146 sock.close();
|
| /external/python/cpython3/Lib/asyncio/ |
| base_events.py | 76 def _set_reuseport(sock):
81 sock.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEPORT, 1)
87 def _is_stream_socket(sock):
91 return (sock.type & socket.SOCK_STREAM) == socket.SOCK_STREAM
94 def _is_dgram_socket(sock):
98 return (sock.type & socket.SOCK_DGRAM) == socket.SOCK_DGRAM
212 for sock in sockets:
213 self._loop._stop_serving(sock)
309 def _make_socket_transport(self, sock, protocol, waiter=None, *,
320 def _make_datagram_transport(self, sock, protocol
[all...] |
| /external/python/cpython3/Tools/ccbench/ |
| ccbench.py | 271 def _sendto(sock, s, addr):
272 sock.sendto(s.encode('ascii'), addr)
274 def _recv(sock, n):
275 return sock.recv(n).decode('ascii')
278 sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
283 _sendto(sock, "%r\n" % _time(), addr)
291 _sendto(sock, LAT_END + "\n", addr)
293 sock.close()
304 sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
305 sock.bind(("127.0.0.1", 0)
[all...] |
| /kernel/tests/net/test/ |
| sock_diag_test.py | 101 def assertSocketClosed(self, sock):
102 self.assertRaisesErrno(ENOTCONN, sock.getpeername)
104 def assertSocketConnected(self, sock):
105 sock.getpeername() # No errors? Socket is alive and connected.
108 for sock in socketpair:
109 self.assertSocketClosed(sock)
140 def _EventDuringBlockingCall(self, sock, call, expected_errno, event):
141 """Simulates an external event during a blocking call on sock.
144 sock: The socket to use.
145 call: A function, the call to make. Takes one parameter, sock
[all...] |
| /external/wpa_supplicant_8/src/utils/ |
| eloop.c | 43 int sock; member in struct:eloop_sock
194 static int eloop_sock_queue(int sock, eloop_event_type type)
215 ev.data.fd = sock;
216 if (epoll_ctl(eloop.epollfd, EPOLL_CTL_ADD, sock, &ev) < 0) {
218 __func__, sock, strerror(errno));
227 static int eloop_sock_queue(int sock, eloop_event_type type)
242 EV_SET(&ke, sock, filter, EV_ADD, 0, 0, 0);
245 __func__, sock, strerror(errno));
254 int sock, eloop_sock_handler handler,
270 if (sock > eloop.max_sock
[all...] |
