/external/deqp/execserver/ |
H A D | xsExecutionServer.cpp | 127 ConnectionHandler* ExecutionServer::createHandler (de::Socket* socket, const de::SocketAddress& clientAddress) argument 130 return new ExecutionRequestHandler(this, socket); 141 ExecutionRequestHandler::ExecutionRequestHandler (ExecutionServer* server, de::Socket* socket) argument 142 : ConnectionHandler (server, socket) 219 // Read from socket to buffer.
|
/external/deqp/framework/platform/android/ |
H A D | tcuAndroidExecService.cpp | 297 xs::ConnectionHandler* ExecutionServer::createHandler (de::Socket* socket, const de::SocketAddress& clientAddress) argument 300 return new ConnectionHandler(m_vm, this, socket); 305 ConnectionHandler::ConnectionHandler (JavaVM* vm, xs::ExecutionServer* server, de::Socket* socket) argument 306 : xs::ExecutionRequestHandler (server, socket)
|
/external/deqp/scripts/ |
H A D | run_nightly.py | 10 import socket namespace 248 s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
|
/external/javassist/src/main/javassist/tools/web/ |
H A D | Webserver.java | 37 private ServerSocket socket; field in class:Webserver 102 socket = new ServerSocket(port); 132 * Closes the socket. 135 socket.close(); 180 ServiceThread th = new ServiceThread(this, socket.accept());
|
/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/okhttp/okhttp/src/main/java/com/squareup/okhttp/ |
H A D | Connection.java | 70 private Socket socket; field in class:Connection 138 socket.close(); 146 socket = route.address.socketFactory.createSocket(); 148 socket = new Socket(route.proxy); 151 socket.setSoTimeout(readTimeout); 152 Platform.get().connectSocket(socket, route.inetSocketAddress, connectTimeout); 157 httpConnection = new HttpConnection(pool, this, socket); 174 // Create the wrapper over connected socket. 175 socket = route.address.sslSocketFactory 176 .createSocket(socket, rout [all...] |
/external/okhttp/okhttp/src/main/java/com/squareup/okhttp/internal/ |
H A D | Platform.java | 86 public void tagSocket(Socket socket) throws SocketException { argument 89 public void untagSocket(Socket socket) throws SocketException { argument 101 public void enableTlsExtensions(SSLSocket socket, String uriHost) { argument 108 public void supportTlsIntolerantServer(SSLSocket socket) { argument 109 socket.setEnabledProtocols(new String[] {"SSLv3"}); 113 public ByteString getNpnSelectedProtocol(SSLSocket socket) { argument 118 * Sets client-supported protocols on a socket to send to a server. The 119 * protocols are only sent if the socket implementation supports NPN. 121 public void setNpnProtocols(SSLSocket socket, List<Protocol> npnProtocols) { argument 124 public void connectSocket(Socket socket, InetSocketAddres argument 233 connectSocket(Socket socket, InetSocketAddress address, int connectTimeout) argument 246 enableTlsExtensions(SSLSocket socket, String uriHost) argument 259 setNpnProtocols(SSLSocket socket, List<Protocol> npnProtocols) argument 272 getNpnSelectedProtocol(SSLSocket socket) argument 302 setNpnProtocols(SSLSocket socket, List<Protocol> npnProtocols) argument 318 getNpnSelectedProtocol(SSLSocket socket) argument [all...] |
H A D | Util.java | 106 * Closes {@code socket}, ignoring any checked exceptions. Does nothing if 107 * {@code socket} is null. 109 public static void closeQuietly(Socket socket) { argument 110 if (socket != null) { 112 socket.close();
|
/external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/internal/spdy/ |
H A D | MockSpdyPeer.java | 51 private Socket socket; field in class:MockSpdyPeer 117 if (socket != null) throw new IllegalStateException(); 118 socket = serverSocket.accept(); 119 OutputStream out = socket.getOutputStream(); 120 InputStream in = socket.getInputStream(); 153 Util.closeQuietly(socket); 162 Socket socket = this.socket; 163 if (socket != null) { 164 Util.closeQuietly(socket); [all...] |
/external/skia/experimental/nanomsg/ |
H A D | picture_demo.cpp | 40 static void send_picture(int socket, const PictureHeader& header, const SkData& skp) { argument 53 nn_sendmsg(socket, &msg, 0/*flags*/); 56 static SkPicture* recv_picture(int socket, PictureHeader* header) { argument 60 int size = nn_recv(socket, &msg, NN_MSG, 0/*flags*/); 96 int socket = nn_socket(AF_SP, NN_REQ); local 98 // Clients connect a socket to an endpoint. 99 nn_connect(socket, dataEndpoint); 103 send_picture(socket, header, *skp); 107 nn_recv(socket, &ack, sizeof(ack), 0/*flags*/); 132 // Servers bind a socket t [all...] |
/external/lldb/examples/interposing/darwin/fd_interposing/ |
H A D | FDInterposing.cpp | 62 #include <sys/socket.h> 661 // socket() interpose function 664 socket$__interposed__ (int domain, int type, int protocol) 670 const int fd = ::socket (domain, type, protocol); 674 description_sp->printf("pid=%i: socket (domain = %i, type = %i, protocol = %i) => fd=%i errno = %i", pid, domain, type, protocol, fd, fd_errno.get_errno()); 676 description_sp->printf("pid=%i: socket (domain = %i, type = %i, protocol = %i) => fd=%i", pid, domain, type, protocol, fd); 685 return ::socket (domain, type, protocol); 859 accept$__interposed__ (int socket, struct sockaddr *address, socklen_t *address_len) argument 865 const int fd = ::accept (socket, address, address_len); 867 StringSP description_sp(new String ("pid=%i: accept (socket 885 accept$NOCANCEL$__interposed__(int socket, struct sockaddr *address, socklen_t *address_len) argument [all...] |
/external/antlr/antlr-3.4/runtime/CSharp2/Sources/Antlr3.Runtime/Antlr.Runtime.Debug/ |
H A D | DebugEventSocketProxy.cs | 46 * A proxy debug event listener that forwards events over a socket to 48 * one event per line. ANTLRWorks listens on server socket with a 50 * be kept in sync. New events must be handled on both sides of socket. 57 protected Socket socket; field in class:Antlr.Runtime.Debug.DebugEventSocketProxy 99 socket = serverSocket.AcceptSocket(); 100 socket.NoDelay = true; 103 socket.Send(encoding.GetBytes("ANTLR " + DebugEventListenerConstants.ProtocolVersion + "\n")); 104 socket.Send(encoding.GetBytes("grammar \"" + grammarFileName + "\n")); 108 //socket = serverSocket.accept(); 109 //socket [all...] |
/external/antlr/antlr-3.4/runtime/Java/src/main/java/org/antlr/runtime/debug/ |
H A D | DebugEventSocketProxy.java | 39 /** A proxy debug event listener that forwards events over a socket to 41 * one event per line. ANTLRWorks listens on server socket with a 43 * be kept in sync. New events must be handled on both sides of socket. 49 protected Socket socket; field in class:DebugEventSocketProxy 76 socket = serverSocket.accept(); 77 socket.setTcpNoDelay(true); 78 OutputStream os = socket.getOutputStream(); 81 InputStream is = socket.getInputStream(); 99 socket.close();
|
/external/apache-harmony/luni/src/test/api/common/org/apache/harmony/luni/tests/internal/net/www/protocol/https/ |
H A D | HttpsURLConnectionTest.java | 131 // create the SSL server socket acting as a server 171 // create the SSL server socket acting as a server 209 // create the SSL server socket acting as a server 838 * Builds and returns the context used for secure socket creation. 1149 // the server socket used for connection 1152 // the socket connected with client peer 1179 * @param serverSocket the server socket to be used during connection 1189 // will act as a proxy server if the specified server socket 1190 // is not a secure server socket 1206 public void closeSocket(Socket socket) { argument [all...] |
/external/chromium-trace/trace-viewer/examples/stream_server/ |
H A D | standalone.py | 121 import socket namespace 269 return socket._fileobject(self._connection, mode, bufsize) 282 socket object to self.socket before server_bind and server_activate, 315 (socket.AF_INET6, socket.SOCK_STREAM, '', '', ''), 316 (socket.AF_INET, socket.SOCK_STREAM, '', '', '')] 318 addrinfo_array = socket.getaddrinfo(self.server_name, 320 socket [all...] |
/external/chromium-trace/trace-viewer/third_party/pywebsocket/src/mod_pywebsocket/ |
H A D | standalone.py | 121 import socket namespace 265 return socket._fileobject(self._connection, mode, bufsize) 278 socket object to self.socket before server_bind and server_activate, 311 (socket.AF_INET6, socket.SOCK_STREAM, '', '', ''), 312 (socket.AF_INET, socket.SOCK_STREAM, '', '', '')] 314 addrinfo_array = socket.getaddrinfo(self.server_name, 316 socket [all...] |
/external/chromium_org/chrome/browser/devtools/device/adb/ |
H A D | adb_device_info_query.cc | 30 const char* socket; member in struct:__anon3532::BrowserDescriptor 113 // 00000000: 00000002 00000000 00010000 0001 01 331813 /dev/socket/zygote 117 // We need to find records with paths starting from '@' (abstract socket) 136 std::string socket = path_field.substr(1); local 144 socket_to_pid[socket] = pid; 153 AdbDeviceInfoQuery::GetBrowserType(const std::string& socket) { argument 154 if (socket.find(kChromeDefaultSocket) == 0) 157 if (socket.find(kWebViewSocketPrefix) == 0) 164 std::string AdbDeviceInfoQuery::GetDisplayName(const std::string& socket, argument 167 // Derive a fallback display name from the socket nam 306 std::string socket = it->first; local [all...] |
/external/chromium_org/chrome/browser/devtools/device/ |
H A D | devtools_android_bridge.h | 95 std::string socket() { return socket_; } function in class:DevToolsAndroidBridge::RemoteBrowser
|
/external/chromium_org/chrome/browser/local_discovery/ |
H A D | service_discovery_host_client.cc | 11 #include "net/socket/socket_descriptor.h" 38 << "Can't create socket, family=" << interfaces[i].second; 40 LocalDiscoveryMsg_SocketInfo socket; local 41 socket.descriptor = socket_descriptor; 42 socket.interface_index = interfaces[i].first; 43 socket.address_family = interfaces[i].second; 44 sockets.push_back(socket);
|
/external/chromium_org/chrome/test/chromedriver/net/ |
H A D | adb_client_socket.cc | 16 #include "net/socket/tcp_client_socket.h" 134 net::StreamSocket* socket) { 138 socket_.reset(socket); 306 net::StreamSocket* socket, 308 callback.Run(result, socket); 319 // Use plain socket for remote debugging on Desktop (debugging purposes). 329 net::TCPClientSocket* socket = new net::TCPClientSocket( 331 socket->Connect(base::Bind(&UseTransportQueryForDesktop, callback, socket)); 133 OnSocketAvailable(int result, net::StreamSocket* socket) argument
|
/external/chromium_org/chrome/utility/local_discovery/ |
H A D | service_discovery_message_handler.cc | 13 #include "net/socket/socket_descriptor.h" 20 void ClosePlatformSocket(net::SocketDescriptor socket); 22 // Sets socket factory used by |net::CreatePlatformSocket|. Implemetation 23 // keeps single socket that will be returned to the first call to 27 explicit ScopedSocketFactory(net::SocketDescriptor socket) : socket_(socket) { argument 52 SocketInfo(net::SocketDescriptor socket, argument 55 : socket(socket), 59 net::SocketDescriptor socket; member in struct:local_discovery::__anon6027::SocketInfo 108 ClosePlatformSocket(net::SocketDescriptor socket) argument 128 ClosePlatformSocket(net::SocketDescriptor socket) argument [all...] |
/external/chromium_org/components/devtools_bridge/android/java/src/org/chromium/components/devtools_bridge/ |
H A D | SocketTunnelBase.java | 21 * Base class for client and server that tunnels DevToolsServer's UNIX socket 24 * Server runs on a android device with Chromium (or alike). Client runs where socket 25 * needed to be accesses (it could be the same device if socket names are different; this 30 * server tries to connect to DevToolsServer socket. If succeeded it sends back SERVER_OPEN_ACK 82 // For writing in socket without blocking signaling thread. 286 private ConnectionBase(int id, LocalSocket socket, boolean preconnected) { argument 288 mSocket = socket; 292 protected ConnectionBase(int id, LocalSocket socket) { argument 293 this(id, socket, true);
|
/external/chromium_org/components/pairing/ |
H A D | bluetooth_controller_pairing_controller.cc | 160 scoped_refptr<device::BluetoothSocket> socket) { 162 socket_ = socket; 159 OnConnectToService( scoped_refptr<device::BluetoothSocket> socket) argument
|
H A D | bluetooth_host_pairing_controller.cc | 171 scoped_refptr<device::BluetoothSocket> socket) { 173 service_socket_ = socket; 191 scoped_refptr<device::BluetoothSocket> socket) { 200 controller_socket_ = socket; 170 OnCreateService( scoped_refptr<device::BluetoothSocket> socket) argument 189 OnAccept( const device::BluetoothDevice* device, scoped_refptr<device::BluetoothSocket> socket) argument
|
/external/chromium_org/content/browser/renderer_host/p2p/ |
H A D | socket_dispatcher_host.cc | 229 LOG(ERROR) << "Received P2PHostMsg_CreateSocket for socket " 234 scoped_ptr<P2PSocketHost> socket(P2PSocketHost::Create( 237 if (!socket) { 242 if (socket->Init(local_address, remote_address)) { 243 sockets_[socket_id] = socket.release(); 256 P2PSocketHost* socket = LookupSocket(listen_socket_id); local 257 if (!socket) { 263 socket->AcceptIncomingTcpConnection(remote_address, connected_socket_id); 274 P2PSocketHost* socket = LookupSocket(socket_id); local 275 if (!socket) { 295 P2PSocketHost* socket = LookupSocket(socket_id); local [all...] |