| /system/core/fastboot/ |
| socket_mock.cpp | 120 std::unique_ptr<Socket> sock = std::move(events_.front().sock); local
122 return sock;
145 void SocketMock::AddAccept(std::unique_ptr<Socket> sock) {
146 events_.push(Event(EventType::kAccept, "", false, std::move(sock)));
151 : type(_type), message(_message), status(_status), sock(std::move(_sock)) {}
|
| socket_test.cpp | 64 static bool SendString(Socket* sock, const std::string& message) {
65 return sock->Send(message.c_str(), message.length());
70 static bool ReceiveString(Socket* sock, const std::string& message) {
72 ssize_t bytes = sock->ReceiveAll(&received[0], received.length(), kTestTimeoutMs);
175 std::unique_ptr<Socket> sock = Socket::NewServer(Socket::Protocol::kUdp, 0); local
184 sock->socket_send_buffers_function_ = [&buffers, &mock_return_value](
196 EXPECT_TRUE(sock->Send(buffers));
199 EXPECT_FALSE(sock->Send(buffers));
202 EXPECT_FALSE(sock->Send(buffers));
205 EXPECT_FALSE(sock->Send(buffers))
212 std::unique_ptr<Socket> sock = Socket::NewServer(Socket::Protocol::kTcp, 0); local
[all...] |
| /external/curl/lib/ |
| socks.c | 121 curl_socket_t sock = conn->sock[sockindex]; local
134 (void)curlx_nonblock(sock, FALSE);
244 code = Curl_write_plain(conn, sock, (char *)socksreq,
254 code = Curl_write_plain(conn, sock, (char *)hostname, hostnamelen,
265 result = Curl_blockread_all(conn, sock, (char *)socksreq, packetsize,
344 (void)curlx_nonblock(sock, TRUE);
383 curl_socket_t sock = conn->sock[sockindex]; local
413 (void)curlx_nonblock(sock, TRUE)
[all...] |
| /external/python/cpython3/Lib/asyncio/ |
| unix_events.py | 217 ssl=None, sock=None,
229 if sock is not None:
231 'path and sock can not be specified at the same time')
233 sock = socket.socket(socket.AF_UNIX, socket.SOCK_STREAM, 0)
235 sock.setblocking(False)
236 yield from self.sock_connect(sock, path)
238 sock.close()
242 if sock is None:
243 raise ValueError('no path and sock were specified')
244 if (sock.family != socket.AF_UNIX o
[all...] |
| /device/linaro/bootloader/edk2/AppPkg/Applications/Python/Python-2.7.2/Lib/test/ |
| test_poplib.py | 283 self.sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
284 self.sock.settimeout(3)
285 self.port = test_support.bind_port(self.sock)
286 threading.Thread(target=self.server, args=(self.evt,self.sock)).start()
312 self.assertEqual(pop.sock.gettimeout(), 30)
313 pop.sock.close()
322 self.assertTrue(pop.sock.gettimeout() is None)
323 pop.sock.close()
327 self.assertEqual(pop.sock.gettimeout(), 30)
328 pop.sock.close()
[all...] |
| /external/nist-sip/java/gov/nist/javax/sip/stack/ |
| UDPMessageProcessor.java | 79 protected DatagramSocket sock; field in class:UDPMessageProcessor
107 this.sock = sipStack.getNetworkLayer().createDatagramSocket(port,
110 sock.setReceiveBufferSize(sipStack.getReceiveUdpBufferSize());
111 sock.setSendBufferSize(sipStack.getSendUdpBufferSize());
115 * prevent sock.receive() from blocking forever
118 sock.setSoTimeout((int) sipStack.getThreadAuditor().getPingIntervalInMillisecs());
126 super.setIpAddress( sock.getLocalAddress() );
188 int bufsize = sock.getReceiveBufferSize();
191 sock.receive(packet);
282 sock.close()
[all...] |
| /external/python/cpython2/Lib/test/ |
| test_poplib.py | 290 self.sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
291 self.sock.settimeout(60) # Safety net. Look issue 11812
292 self.port = test_support.bind_port(self.sock)
293 self.thread = threading.Thread(target=self.server, args=(self.evt,self.sock))
321 self.assertEqual(pop.sock.gettimeout(), 30)
322 pop.sock.close()
331 self.assertIsNone(pop.sock.gettimeout())
332 pop.sock.close()
336 self.assertEqual(pop.sock.gettimeout(), 30)
337 pop.sock.close(
[all...] |
| /external/wpa_supplicant_8/src/radius/ |
| radius_das.c | 20 int sock; member in struct:radius_das_data
187 static void radius_das_receive(int sock, void *eloop_ctx, void *sock_ctx)
210 len = recvfrom(sock, buf, sizeof(buf), 0,
314 res = sendto(das->sock, wpabuf_head(rbuf),
384 das->sock = radius_das_open_socket(conf->port);
385 if (das->sock < 0) {
392 if (eloop_register_read_sock(das->sock, radius_das_receive, das, NULL))
407 if (das->sock >= 0) {
408 eloop_unregister_read_sock(das->sock);
409 close(das->sock);
[all...] |
| /prebuilts/gdb/darwin-x86/lib/python2.7/test/ |
| test_poplib.py | 283 self.sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
284 self.sock.settimeout(60) # Safety net. Look issue 11812
285 self.port = test_support.bind_port(self.sock)
286 self.thread = threading.Thread(target=self.server, args=(self.evt,self.sock))
314 self.assertEqual(pop.sock.gettimeout(), 30)
315 pop.sock.close()
324 self.assertTrue(pop.sock.gettimeout() is None)
325 pop.sock.close()
329 self.assertEqual(pop.sock.gettimeout(), 30)
330 pop.sock.close(
[all...] |
| /prebuilts/gdb/linux-x86/lib/python2.7/test/ |
| test_poplib.py | 283 self.sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
284 self.sock.settimeout(60) # Safety net. Look issue 11812
285 self.port = test_support.bind_port(self.sock)
286 self.thread = threading.Thread(target=self.server, args=(self.evt,self.sock))
314 self.assertEqual(pop.sock.gettimeout(), 30)
315 pop.sock.close()
324 self.assertTrue(pop.sock.gettimeout() is None)
325 pop.sock.close()
329 self.assertEqual(pop.sock.gettimeout(), 30)
330 pop.sock.close(
[all...] |
| /prebuilts/python/darwin-x86/2.7.5/lib/python2.7/test/ |
| test_poplib.py | 283 self.sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
284 self.sock.settimeout(60) # Safety net. Look issue 11812
285 self.port = test_support.bind_port(self.sock)
286 self.thread = threading.Thread(target=self.server, args=(self.evt,self.sock))
314 self.assertEqual(pop.sock.gettimeout(), 30)
315 pop.sock.close()
324 self.assertTrue(pop.sock.gettimeout() is None)
325 pop.sock.close()
329 self.assertEqual(pop.sock.gettimeout(), 30)
330 pop.sock.close(
[all...] |
| /prebuilts/python/linux-x86/2.7.5/lib/python2.7/test/ |
| test_poplib.py | 283 self.sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
284 self.sock.settimeout(60) # Safety net. Look issue 11812
285 self.port = test_support.bind_port(self.sock)
286 self.thread = threading.Thread(target=self.server, args=(self.evt,self.sock))
314 self.assertEqual(pop.sock.gettimeout(), 30)
315 pop.sock.close()
324 self.assertTrue(pop.sock.gettimeout() is None)
325 pop.sock.close()
329 self.assertEqual(pop.sock.gettimeout(), 30)
330 pop.sock.close(
[all...] |
| /external/python/cpython3/Lib/test/ |
| test_poplib.py | 336 self.assertIsNone(self.client.sock)
405 self.assertIsInstance(self.client.sock, ssl.SSLSocket)
406 self.assertIs(self.client.sock.context, ctx)
430 if self.client.file is not None and self.client.sock is not None:
454 self.sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
455 self.sock.settimeout(60) # Safety net. Look issue 11812
456 self.port = test_support.bind_port(self.sock)
457 self.thread = threading.Thread(target=self.server, args=(self.evt,self.sock))
485 self.assertEqual(pop.sock.gettimeout(), 30)
486 pop.sock.close(
[all...] |
| /kernel/tests/net/test/ |
| bpf_test.py | 59 sock = socket.socket(family, socket.SOCK_DGRAM, 0)
61 BpfProgAttachSocket(sock.fileno(), prog_fd)
62 net_test.SetNonBlocking(sock)
64 sock.bind((addr, 0))
65 addr = sock.getsockname()
68 sock.sendto("foo", addr)
69 data, retaddr = csocket.Recvfrom(sock, 4096, 0)
72 return sock
155 self.sock = None
162 if self.sock
[all...] |
| /external/autotest/client/profilers/powertop/src/ |
| wireless.c | 202 int sock; local
245 sock = socket(AF_INET, SOCK_DGRAM, 0);
246 if (sock<0)
252 ret = ioctl(sock, SIOCGIFFLAGS, &ifr);
254 close(sock);
265 ret = ioctl(sock, SIOCETHTOOL, &ifr);
269 close(sock);
|
| /external/iputils/ |
| rdisc.c | 87 static int join(int sock, struct sockaddr_in *sin);
1103 int sock; local
1112 sock = socket(AF_INET, SOCK_DGRAM, 0);
1113 if (sock < 0) {
1118 if (ioctl(sock, SIOCGIFNUM, (char *)&numifs) < 0) {
1128 (void) close(sock);
1137 (void) close(sock);
1145 if (ioctl(sock, SIOCGIFCONF, (char *)&ifc) < 0) {
1147 (void) close(sock);
1156 if (ioctl(sock, SIOCGIFFLAGS, (char *)&ifreq) < 0)
1264 int sock; local
1492 int sock; local
[all...] |
| /external/python/cpython3/Lib/ |
| ftplib.py | 102 sock = None variable in class:FTP
126 if self.sock is not None:
132 if self.sock is not None:
151 self.sock = socket.create_connection((self.host, self.port), self.timeout,
153 self.af = self.sock.family
154 self.file = self.sock.makefile('r', encoding=self.encoding)
192 self.sock.sendall(line.encode(self.encoding))
262 self.sock.sendall(line, MSG_OOB)
304 sock = None
308 sock = socket.socket(af, socktype, proto
[all...] |
| /device/linaro/bootloader/edk2/MdeModulePkg/Universal/Network/Tcp4Dxe/ |
| Tcp4Driver.c | 156 SOCKET *Sock;
165 Sock = NET_LIST_USER_STRUCT_S (Entry, SOCKET, Link, SOCK_SIGNATURE);
170 if (!NetIsInHandleBuffer (Sock->SockHandle, NumberOfChildren, ChildHandleBuffer)) {
174 return ServiceBinding->DestroyChild (ServiceBinding, Sock->SockHandle);
682 SOCKET *Sock;
700 // sock init data and TcpProto
706 Sock = SockCreateChild (&mTcp4DefaultSockData);
707 if (NULL == Sock) {
713 *ChildHandle = Sock->SockHandle;
751 SOCKET *Sock;
[all...] |
| /external/boringssl/src/tool/ |
| client.cc | 192 static bool WaitForSession(SSL *ssl, int sock) {
196 if (!SocketSetNonBlocking(sock, true)) {
206 FD_SET(static_cast<SOCKET>(sock), &read_fds);
208 FD_SET(sock, &read_fds);
210 int ret = select(sock + 1, &read_fds, NULL, NULL, NULL);
235 bool (*cb)(SSL *ssl, int sock)) {
236 int sock = -1; local
238 if (!Connect(&sock, args_map["-http-tunnel"]) ||
239 !DoHTTPTunnel(sock, args_map["-connect"])) {
242 } else if (!Connect(&sock, args_map["-connect"]))
[all...] |
| /external/wpa_supplicant_8/src/utils/ |
| eloop.h | 39 * @sock: File descriptor number for the socket
43 typedef void (*eloop_sock_handler)(int sock, void *eloop_ctx, void *sock_ctx);
78 * @sock: File descriptor number for the socket
90 int eloop_register_read_sock(int sock, eloop_sock_handler handler,
95 * @sock: File descriptor number for the socket
100 void eloop_unregister_read_sock(int sock);
104 * @sock: File descriptor number for the socket
117 int eloop_register_sock(int sock, eloop_event_type type,
123 * @sock: File descriptor number for the socket
124 * @type: Type of event for which sock was registere
[all...] |
| /external/sl4a/Utils/src/com/googlecode/android_scripting/ |
| SimpleServer.java | 267 Socket sock = mServer.accept();
269 startConnectionThread(sock);
271 sock.close();
290 private void startConnectionThread(final Socket sock) throws IOException, JSONException {
292 new BufferedReader(new InputStreamReader(sock.getInputStream()), 8192);
293 PrintWriter writer = new PrintWriter(sock.getOutputStream(), true);
306 ConnectionThread networkThread = new ConnectionThread(sock,true,mUID,reader,writer);
321 ConnectionThread networkThread = new ConnectionThread(sock,true,uid,reader,writer);
338 ConnectionThread networkThread = new ConnectionThread(sock,false,0,reader,writer);
|
| /external/toybox/toys/pending/ |
| ping.c | 55 int sock;
61 int rc = sendto(TT.sock, buf, len, 0, dest,
152 TT.sock = xsocket(ai->ai_family, SOCK_DGRAM,
154 if (TT.I && bind(TT.sock, sa, sizeof(src_addr))) perror_exit("bind");
160 setsockopt(TT.sock, IPPROTO_IP, IP_TTL, &len, 4);
161 else setsockopt(TT.sock, IPPROTO_IPV6, IPV6_UNICAST_HOPS, &len, 4);
202 xsendto(TT.sock, toybuf, TT.s+sizeof(*ih), ai->ai_addr);
219 pfd.fd = TT.sock;
225 len = recvfrom(TT.sock, toybuf, sizeof(toybuf), 0, sa2, (void *)&len);
|
| /device/linaro/bootloader/edk2/NetworkPkg/TcpDxe/ |
| TcpDispatcher.c | 75 SOCKET *Sock;
81 Sock = Tcb->Sk;
83 if (!SOCK_IS_CONFIGURED (Sock) && (Mode->Tcp4ConfigData != NULL)) {
158 SOCKET *Sock;
164 Sock = Tcb->Sk;
166 if (!SOCK_IS_CONFIGURED (Sock) && (Mode->Tcp6ConfigData != NULL)) {
307 SOCKET *Sock;
311 Sock = Tcb->Sk;
313 if (SOCK_IS_CONFIGURED (Sock)) {
316 if (Sock->DevicePath != NULL) {
[all...] |
| /external/autotest/client/site_tests/kernel_CryptoAPI/ |
| kernel_CryptoAPI.py | 105 sock = libc.socket(AF_ALG, SOCK_SEQPACKET, 0)
106 if sock == -1:
111 if libc.bind(sock, ctypes.addressof(alg), ctypes.sizeof(alg)) == -1:
115 fd = libc.accept(sock, None, 0)
133 libc.close(sock)
|
| /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)
|
