/external/autotest/scheduler/ |
H A D | email_manager.py | 7 import socket namespace 59 body += "%s / %s / %s\n%s" % (socket.gethostname(), 69 subject = 'Scheduler notifications from ' + socket.gethostname()
|
/external/autotest/server/cros/ |
H A D | dnsname_mangler.py | 6 import socket namespace 34 socket.inet_aton(hostname) 36 except socket.error:
|
/external/compiler-rt/test/tsan/ |
H A D | fd_socket_connect_norace.cc | 7 #include <sys/socket.h> 15 int c = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP); 26 int s = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
|
H A D | fd_socket_norace.cc | 7 #include <sys/socket.h> 16 int c = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP); 30 int s = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
|
/external/ltp/include/ |
H A D | safe_net_fn.h | 23 #include <sys/socket.h> 45 int socket, const struct sockaddr *address, 49 int socket, int backlog);
|
/external/okhttp/okio/okio/src/main/java/okio/ |
H A D | Okio.java | 108 * Returns a sink that writes to {@code socket}. Prefer this over {@link 109 * #sink(OutputStream)} because this method honors timeouts. When the socket 110 * write times out, the socket is asynchronously closed by a watchdog thread. 112 public static Sink sink(Socket socket) throws IOException { argument 113 if (socket == null) throw new IllegalArgumentException("socket == null"); 114 AsyncTimeout timeout = timeout(socket); 115 Sink sink = sink(socket.getOutputStream(), timeout); 198 * Returns a source that reads from {@code socket}. Prefer this over {@link 199 * #source(InputStream)} because this method honors timeouts. When the socket 202 source(Socket socket) argument 209 timeout(final Socket socket) argument [all...] |
/external/python/cpython2/Demo/sockets/ |
H A D | udpecho.py | 9 from socket import * 35 s = socket(AF_INET, SOCK_DGRAM) 52 s = socket(AF_INET, SOCK_DGRAM)
|
/external/valgrind/memcheck/tests/ |
H A D | sendmsg.c | 5 #include <sys/socket.h> 19 fd = socket (AF_INET, SOCK_DGRAM, 0); 22 perror ("socket()"); 52 fd = socket (AF_INET, SOCK_DGRAM, 0); 55 perror ("socket()");
|
/external/webrtc/webrtc/base/ |
H A D | autodetectproxy.h | 70 void OnConnectEvent(AsyncSocket * socket); 71 void OnReadEvent(AsyncSocket * socket); 72 void OnCloseEvent(AsyncSocket * socket, int error);
|
H A D | testclient.h | 38 // Creates a client that will send and receive with the given socket and 40 explicit TestClient(AsyncPacketSocket* socket); 46 // Checks that the socket moves to the specified connect state. 49 // Checks that the socket is connected to the remote side. 54 // Sends using the clients socket. 57 // Sends using the clients socket to the given destination. 82 // Slot for packets read on the socket. 83 void OnPacket(AsyncPacketSocket* socket, const char* buf, size_t len, 86 void OnReadyToSend(AsyncPacketSocket* socket);
|
/external/autotest/client/bin/net/ |
H A D | net_utils_mock.py | 7 import socket namespace 57 def socket(self, family, type): member in class:socket_stub 73 raise socket.timeout 96 self._socket = socket_stub(iface, socket, socket)
|
/external/python/cpython2/Demo/pysvr/ |
H A D | pysvr.py | 15 import sys, os, string, getopt, thread, socket, traceback namespace 45 sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
|
/external/v8/tools/testrunner/server/ |
H A D | local_handler.py | 29 import socket namespace 38 sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
|
H A D | status_handler.py | 29 import socket namespace 37 sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
|
/external/vogar/src/vogar/monitor/ |
H A D | HostMonitor.java | 54 Socket socket = null; 56 socket = new Socket("localhost", port); 57 InputStream in = new BufferedInputStream(socket.getInputStream()); 59 log.verbose("action monitor connected to " + socket.getRemoteSocketAddress()); 65 IoUtils.closeQuietly(socket); 78 * Somewhere between the host and client process, broken socket connections
|
/external/webrtc/webrtc/test/channel_transport/ |
H A D | udp_transport_unittest.cc | 19 // We must mock the socket manager, for which we need its definition. 71 MockUdpSocketWrapper* socket = new MockUdpSocketWrapper(); local 72 // We instrument the socket with calls that are expected, but do 74 EXPECT_CALL(*socket, ValidHandle()).WillRepeatedly(Return(true)); 75 EXPECT_CALL(*socket, Bind(_)).WillOnce(Return(true)); 76 socket_counter_->push_back(socket); 77 return socket;
|
/external/autotest/client/deps/lansim/src/py/ |
H A D | simulator_unittest.py | 7 import socket namespace 35 self._sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM) 36 self._sock.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1) 65 sock = socket.socket(socket [all...] |
H A D | host.py | 6 import socket namespace 15 socket.inet_aton('255.255.255.255'): tools.inet_hwton('FF:FF:FF:FF:FF:FF'), 40 self._bin_ip_addr = socket.inet_aton(ip_addr) 174 self._tcp_fwd_ports[port] = socket.inet_aton(dest_addr), dest_port 229 def socket(self, family, sock_type): member in class:SimpleHost 230 """Creates an asynchronous socket on the simulated host. 232 This method creates an asynchronous socket object that can be used to 235 @param family: The socket family, only AF_INET is supported. 236 @param sock_type: The socket type, only SOCK_DGRAM is supported. 238 @raise SimpleHostError if socket famil [all...] |
/external/autotest/server/site_tests/network_EthCapsServer/ |
H A D | network_EthCapsServer.py | 5 import logging, os, re, socket, subprocess, tempfile, threading, time namespace 66 sock=socket.socket(socket.AF_INET, socket.SOCK_DGRAM) 67 sock.setsockopt(socket.SOL_SOCKET, socket.SO_BROADCAST, 1)
|
/external/webrtc/tools/network_emulator/ |
H A D | emulate.py | 15 import socket namespace 60 external_socket = socket.socket(socket.AF_INET, socket.SOCK_DGRAM) 111 socket.inet_aton(options.target_ip) 112 except socket.error:
|
/external/apache-harmony/support/src/test/java/tests/support/ |
H A D | Support_HttpServer.java | 115 Support_Socket socket = serversocket.accept(); 116 Thread thread = new Thread(new ServerThread(socket)); 178 Support_Socket socket; field in class:Support_HttpServer.ServerThread 181 socket = s; 218 InputStream in = socket.getInputStream(); 292 socket.close(); 304 OutputStream os = socket.getOutputStream(); 320 OutputStream os = socket.getOutputStream(); 341 OutputStream os = socket.getOutputStream(); 376 OutputStream os = socket [all...] |
/external/python/cpython2/Lib/test/ |
H A D | test_poplib.py | 9 import socket namespace 111 def __init__(self, address, af=socket.AF_INET): 114 self.create_socket(af, socket.SOCK_STREAM) 119 self.host, self.port = self.socket.getsockname()[:2] 238 self.socket = ssl.wrap_socket(self.socket, certfile=CERTFILE, 250 self.socket.do_handshake() 258 except socket.error, err: 290 self.sock = socket.socket(socke [all...] |
/external/syslinux/gpxe/src/net/tcp/ |
H A D | http.c | 41 #include <gpxe/socket.h> 72 struct xfer_interface socket; member in struct:http_request 128 xfer_nullify ( &http->socket ); 129 xfer_close ( &http->socket, rc ); 352 * @v socket Transport layer interface 357 static int http_socket_deliver_iob ( struct xfer_interface *socket, argument 361 container_of ( socket, struct http_request, socket ); 433 if ( xfer_window ( &http->socket ) ) { 454 if ( ( rc = xfer_printf ( &http->socket, 478 http_socket_close( struct xfer_interface *socket, int rc ) argument 539 struct xfer_interface *socket; local [all...] |
/external/mockwebserver/src/main/java/com/google/mockwebserver/ |
H A D | MockWebServer.java | 239 logger.log(Level.WARNING, "MockWebServer server socket close failed", e); 246 logger.log(Level.WARNING, "MockWebServer socket close failed", e); 263 Socket socket; 265 socket = serverSocket.accept(); 271 dispatchBookkeepingRequest(0, socket); 272 socket.close(); 274 openClientSockets.put(socket, true); 275 serveConnection(socket); 302 Socket socket; 313 socket 420 dispatchBookkeepingRequest(int sequenceNumber, Socket socket) argument 428 readRequest(Socket socket, InputStream in, OutputStream out, int sequenceNumber) argument [all...] |
/external/python/cpython2/Lib/logging/ |
H A D | handlers.py | 26 import errno, logging, socket, os, cPickle, struct, time, re namespace 435 a streaming socket. The socket is kept open across logging calls. 450 a socket error occurs, the socket is silently closed and then 469 type of socket they want. 471 s = socket.socket(socket.AF_INET, socket [all...] |