| /external/python/cpython3/Lib/test/ |
| test_ftplib.py | 135 with socket.socket() as sock:
136 sock.bind((self.socket.getsockname()[0], 0))
137 sock.listen()
138 sock.settimeout(TIMEOUT)
139 ip, port = sock.getsockname()[:2]
142 conn, addr = sock.accept()
153 with socket.socket(socket.AF_INET6) as sock:
154 sock.bind((self.socket.getsockname()[0], 0))
155 sock.listen()
156 sock.settimeout(TIMEOUT
[all...] |
| /device/linaro/bootloader/edk2/AppPkg/Applications/Python/Python-2.7.2/Lib/test/ |
| test_telnetlib.py | 49 self.sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
50 self.sock.settimeout(3)
51 self.port = test_support.bind_port(self.sock)
52 self.thread = threading.Thread(target=server, args=(self.evt,self.sock))
65 telnet.sock.close()
74 self.assertEqual(telnet.sock.gettimeout(), 30)
75 telnet.sock.close()
85 self.assertTrue(telnet.sock.gettimeout() is None)
86 telnet.sock.close()
90 self.assertEqual(telnet.sock.gettimeout(), 30)
[all...] |
| /external/autotest/venv/lucifer/ |
| leasing_unittest.py | 80 """Test leases_iter() ignores sock files."""
82 tmpdir.join('124.sock').write('')
90 tmpdir.join('123.sock').write('')
91 sock_path = str(tmpdir.join('123.sock'))
102 tmpdir.join('123.sock').write('')
103 sock_path = str(tmpdir.join('123.sock'))
186 path = os.path.join(str(tmpdir), '%d.sock' % job_id)
|
| /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/ltp/testcases/network/rpc/rpc-tirpc/tests_pack/tirpc_svc_5/ |
| tirpc_svc_5.c | 50 int sock; member in struct:server_def_t
81 this->sock = bound_socket(this->domain, this->type);
82 if (this->sock < 0) {
88 if (listen(this->sock, 10) < 0) {
94 this->transp = this->svc_func(this->sock, 1024, 1024);
121 if (this->sock >= 0)
122 close(this->sock);
|
| /external/ppp/pppd/plugins/rp-pppoe/ |
| if.c | 195 * sock -- socket to send to
204 sendPacket(PPPoEConnection *conn, int sock, PPPoEPacket *pkt, int size)
211 err = send(sock, pkt, size, 0);
216 err = sendto(sock, pkt, size, 0, &sa, sizeof(sa));
228 * sock -- socket to read from
237 receivePacket(int sock, PPPoEPacket *pkt, int *size)
239 if ((*size = recv(sock, pkt, sizeof(PPPoEPacket), 0)) < 0) {
|
| /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();
|
| /art/tools/ |
| dt_fds_forward.py | 70 def send_fds(sock, remote_read, remote_write, remote_event):
74 sock.sendmsg([NEED_HANDSHAKE_MESSAGE], # We want the transport to handle the handshake.
90 with socket.socket() as sock:
91 sock.bind((host, port))
92 sock.listen()
94 sources = [local_sock, finish_event, sock]
101 print("listening on " + str(sock))
114 elif sock in rf:
115 (conn, addr) = sock.accept()
|
| /external/nist-sip/java/gov/nist/javax/sip/stack/ |
| TLSMessageProcessor.java | 75 private ServerSocket sock; field in class:TLSMessageProcessor
106 this.sock = sipStack.getNetworkLayer().createSSLServerSocket(this.getPort(), 0,
108 ((SSLServerSocket) this.sock).setNeedClientAuth(false);
109 ((SSLServerSocket) this.sock).setUseClientMode(false);
110 ((SSLServerSocket) this.sock).setWantClientAuth(true);
112 ((SSLServerSocket) this.sock).setEnabledCipherSuites(enabledCiphers);
113 ((SSLServerSocket)this.sock).setWantClientAuth(true);
147 Socket newsock = sock.accept();
197 sock.close();
|
| /test/vts/runners/host/tcp_server/ |
| callback_server_test.py | 73 sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
77 sock.connect((host, ERROR_PORT))
87 sock.close()
115 sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
116 sock.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
123 sock.connect((host, port))
126 sock.sendall(str(len(message)) + "\n" + message)
130 received_message = sock.recv(1024)
137 sock.close()
|
| /device/generic/goldfish-opengl/shared/OpenglCodecCommon/ |
| TcpStream.cpp | 68 TcpStream::TcpStream(int sock, size_t bufSize) :
69 SocketStream(sock, bufSize)
79 setsockopt( sock, IPPROTO_TCP, TCP_NODELAY, (const char*)&flag, sizeof(flag) );
|
| TcpStream.h | 29 TcpStream(int sock, size_t bufSize);
|
| /device/google/cuttlefish_common/common/commands/wifi_relay/ |
| nl_client.cpp | 25 sock_(nullptr, [](nl_sock* sock) { free(sock); }) {}
93 nl_sock* NlClient::Sock() const { return sock_.get(); }
|
| /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_svctcp_create/ |
| rpc_svctcp_create_stress.c | 52 int sock = 600; local
59 sock = socket(AF_UNIX, SOCK_DGRAM, IPPROTO_TCP);
61 svcr = svctcp_create(sock, 0, 0);
|
| /external/ltp/testcases/network/rpc/rpc-tirpc/tests_pack/rpc_suite/rpc/rpc_createdestroy_svcudp_bufcreate/ |
| rpc_svcudp_bufcreate.c | 51 int sock = 600; local
56 sock = socket(AF_UNIX, SOCK_SEQPACKET, IPPROTO_UDP);
57 svcr = svcudp_bufcreate(sock, 1500, 1500);
|
| /external/ltp/testcases/network/rpc/rpc-tirpc/tests_pack/rpc_suite/rpc/rpc_createdestroy_svcudp_create/ |
| rpc_svcudp_create_stress.c | 52 int sock = 600; local
60 sock = socket(AF_UNIX, SOCK_SEQPACKET, IPPROTO_UDP);
62 svcr = svcudp_create(sock);
|
| /system/netd/tests/benchmarks/ |
| connect_benchmark.cpp | 134 int sock = socket(AF_INET, SOCK_STREAM, 0); local
135 if (sock < 0) {
143 if (connect(sock, (sockaddr*) &server, sizeof(server))) {
145 close(sock);
161 close(sock);
166 close(sock);
191 int sock = socket(AF_INET6, SOCK_STREAM, 0); local
192 if (sock < 0) {
200 if (connect(sock, (sockaddr*) &server, sizeof(server))) {
202 close(sock);
[all...] |
| /external/wpa_supplicant_8/src/utils/ |
| eloop_win.c | 18 int sock; member in struct:eloop_sock
113 int eloop_register_read_sock(int sock, eloop_sock_handler handler,
128 if (WSAEventSelect(sock, event, FD_READ)) {
136 WSAEventSelect(sock, event, 0);
141 tmp[eloop.reader_count].sock = sock;
148 if (sock > eloop.max_sock)
149 eloop.max_sock = sock;
156 void eloop_unregister_read_sock(int sock)
164 if (eloop.readers[i].sock == sock
[all...] |
| /external/python/cpython3/Lib/test/test_asyncio/ |
| test_base_events.py | [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...] |
| /device/linaro/bootloader/edk2/AppPkg/Applications/Python/Python-2.7.2/Lib/ |
| 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...] |
| /device/linaro/bootloader/edk2/MdeModulePkg/Universal/Network/Tcp4Dxe/ |
| Tcp4Dispatcher.c | 78 SOCKET *Sock;
84 Sock = Tcb->Sk;
86 if (!SOCK_IS_CONFIGURED (Sock) && (Mode->Tcp4ConfigData != NULL)) {
219 SOCKET *Sock;
223 Sock = Tcb->Sk;
225 if (SOCK_IS_CONFIGURED (Sock)) {
231 if (Sock->DevicePath != NULL) {
233 Sock->SockHandle,
235 Sock->DevicePath
237 FreePool (Sock->DevicePath);
[all...] |
| /external/libnl/include/netlink/route/link/ |
| veth.h | 29 extern int rtnl_link_veth_add(struct nl_sock *sock, const char *name,
|
