| /prebuilts/python/darwin-x86/2.7.5/lib/python2.7/test/ |
| test_socketserver.py | 40 def receive(sock, n, timeout=20):
41 r, w, x = _real_select([sock], [], [], timeout)
42 if sock in r:
43 return sock.recv(n)
45 raise RuntimeError, "timed out on %r" % (sock,)
|
| test_ssl.py | 418 self.sock = connsock
419 self.sock.setblocking(1)
438 self.sslconn = ssl.wrap_socket(self.sock, server_side=True,
451 str(self.sock.getpeername()) + ":\n")
463 return self.sock.recv(1024)
469 return self.sock.send(bytes)
475 self.sock._sock.close()
480 if isinstance(self.sock, ssl.SSLSocket):
481 self.sslconn = self.sock
544 self.sock = socket.socket(
[all...] |
| /prebuilts/python/linux-x86/2.7.5/lib/python2.7/test/ |
| test_asynchat.py | 24 self.sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
25 self.port = test_support.bind_port(self.sock)
31 self.sock.listen(1)
33 conn, client = self.sock.accept()
60 self.sock.close()
|
| test_socketserver.py | 40 def receive(sock, n, timeout=20):
41 r, w, x = _real_select([sock], [], [], timeout)
42 if sock in r:
43 return sock.recv(n)
45 raise RuntimeError, "timed out on %r" % (sock,)
|
| test_ssl.py | 418 self.sock = connsock
419 self.sock.setblocking(1)
438 self.sslconn = ssl.wrap_socket(self.sock, server_side=True,
451 str(self.sock.getpeername()) + ":\n")
463 return self.sock.recv(1024)
469 return self.sock.send(bytes)
475 self.sock._sock.close()
480 if isinstance(self.sock, ssl.SSLSocket):
481 self.sslconn = self.sock
544 self.sock = socket.socket(
[all...] |
| /external/chromium_org/third_party/mongoose/ |
| mongoose.c | 399 SOCKET sock; // Listening socket member in struct:socket
1580 int sock; local
3434 SOCKET sock; local
[all...] |
| /dalvik/vm/jdwp/ |
| JdwpSocket.cpp | 278 static bool isFdReadable(int sock)
285 FD_SET(sock, &readfds);
289 count = select(sock+1, &readfds, NULL, NULL, &tv);
293 if (FD_ISSET(sock, &readfds)) /* make sure it's our fd */
348 int sock; local
357 sock = accept(netState->listenSock, &addr.addrPlain, &addrlen);
358 if (sock < 0 && errno != EINTR) {
367 } while (sock < 0);
374 netState->clientSock = sock;
|
| /external/chromium/net/socket/ |
| transport_client_socket_unittest.cc | 57 virtual void DidClose(ListenSocket* sock) {}
102 ListenSocket *sock = NULL; local
111 sock = ListenSocket::Listen("127.0.0.1", port, this);
112 if (sock)
115 ASSERT_TRUE(sock != NULL);
116 listen_sock_ = sock;
|
| /external/chromium_org/net/socket/ |
| transport_client_socket_unittest.cc | 61 virtual void DidClose(StreamListenSocket* sock) OVERRIDE {}
106 scoped_refptr<TCPListenSocket> sock; local
115 sock = TCPListenSocket::CreateAndListen("127.0.0.1", port, this);
116 if (sock.get())
119 ASSERT_TRUE(sock.get() != NULL);
120 listen_sock_ = sock;
|
| stream_listen_socket.h | 68 virtual void DidClose(StreamListenSocket* sock) = 0;
|
| tcp_listen_socket_unittest.cc | 217 bool TCPListenSocketTester::Send(SocketDescriptor sock,
220 int send_len = HANDLE_EINTR(send(sock, str.data(), len, 0));
244 void TCPListenSocketTester::DidClose(StreamListenSocket* sock) {
|
| /external/chromium_org/chrome/browser/ |
| process_singleton_linux.cc | 215 int sock = socket(PF_UNIX, SOCK_STREAM, 0); local
216 PCHECK(sock >= 0) << "socket() failed";
218 int rv = SetNonBlocking(sock);
220 rv = SetCloseOnExec(sock);
223 return sock;
227 void SetupSocket(const std::string& path, int* sock, struct sockaddr_un* addr) {
228 *sock = SetupSocketOnly();
870 int sock; local
915 SetupSocket(socket_target_path.value(), &sock, &addr);
917 if (bind(sock, reinterpret_cast<sockaddr*>(&addr), sizeof(addr)) < 0)
[all...] |
| /external/wpa_supplicant_8/src/drivers/ |
| driver_hostap.c | 41 int sock; /* raw packet socket for driver access */ member in struct:hostap_driver_data
209 static void handle_read(int sock, void *eloop_ctx, void *sock_ctx)
215 len = recv(sock, buf, sizeof(buf), 0);
230 drv->sock = socket(PF_PACKET, SOCK_RAW, htons(ETH_P_ALL));
231 if (drv->sock < 0) {
236 if (eloop_register_read_sock(drv->sock, handle_read, drv, NULL)) {
243 if (ioctl(drv->sock, SIOCGIFINDEX, &ifr) != 0) {
258 if (bind(drv->sock, (struct sockaddr *) &addr, sizeof(addr)) < 0) {
263 return linux_get_ifhwaddr(drv->sock, drv->iface, own_addr);
275 res = send(drv->sock, msg, len, 0)
[all...] |
| /packages/apps/Nfc/src/com/android/nfc/ndefpush/ |
| NdefPushServer.java | 66 ConnectionThread(LlcpSocket sock) {
68 mSock = sock;
|
| /external/chromium/chrome/browser/debugger/ |
| devtools_remote_listen_socket_unittest.h | 99 virtual bool Send(SOCKET sock, const std::string& str);
|
| /external/chromium/net/base/ |
| listen_socket.h | 58 virtual void DidClose(ListenSocket *sock) = 0;
|
| listen_socket_unittest.cc | 177 bool ListenSocketTester::Send(SOCKET sock, const std::string& str) {
179 int send_len = HANDLE_EINTR(send(sock, str.data(), len, 0));
203 void ListenSocketTester::DidClose(ListenSocket *sock) {
|
| /external/chromium/net/server/ |
| http_server.h | 61 explicit Connection(HttpServer* server, ListenSocket* sock);
|
| /external/chromium_org/third_party/openssl/openssl/apps/ |
| s_apps.h | 159 int init_client(int *sock, char *server, int port, int type);
|
| /external/mdnsresponder/mDNSShared/ |
| dnsextd.h | 112 TCPSocket * sock; member in struct:EventSource
|
| /external/openssl/apps/ |
| s_apps.h | 159 int init_client(int *sock, char *server, int port, int type);
|
| /libcore/crypto/src/test/java/org/conscrypt/ |
| NativeCryptoTest.java | [all...] |
| /art/runtime/jdwp/ |
| jdwp_adb.cc | 369 int sock = ReceiveClientFd(); local
370 if (sock >= 0) {
372 close(sock);
|
| /external/apache-http/src/org/apache/http/impl/conn/ |
| AbstractClientConnAdapter.java | 333 Socket sock = conn.getSocket(); local
334 if (sock instanceof SSLSocket) {
335 result = ((SSLSocket)sock).getSession();
|
| /external/chromium/third_party/libjingle/source/talk/base/ |
| asynctcpsocket.cc | 52 AsyncSocket* sock = factory->CreateAsyncSocket(SOCK_STREAM); local
60 return (sock) ? new AsyncTCPSocket(sock, listen) : NULL;
|
