Searched defs:socket (Results 251 - 275 of 430) sorted by relevance

<<1112131415161718

/external/deqp/execserver/
H A DxsExecutionServer.cpp127 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 DtcuAndroidExecService.cpp297 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 Drun_nightly.py10 import socket namespace
248 s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
/external/javassist/src/main/javassist/tools/web/
H A DWebserver.java37 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 DMockWebServer.java239 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 DConnection.java70 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 DPlatform.java86 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 DUtil.java106 * 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 DMockSpdyPeer.java51 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 Dpicture_demo.cpp40 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 DFDInterposing.cpp62 #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 DDebugEventSocketProxy.cs46 * 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 DDebugEventSocketProxy.java39 /** 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 DHttpsURLConnectionTest.java131 // 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 Dstandalone.py121 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 Dstandalone.py121 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 Dadb_device_info_query.cc30 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 Ddevtools_android_bridge.h95 std::string socket() { return socket_; } function in class:DevToolsAndroidBridge::RemoteBrowser
/external/chromium_org/chrome/browser/local_discovery/
H A Dservice_discovery_host_client.cc11 #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 Dadb_client_socket.cc16 #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 Dservice_discovery_message_handler.cc13 #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 DSocketTunnelBase.java21 * 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 Dbluetooth_controller_pairing_controller.cc160 scoped_refptr<device::BluetoothSocket> socket) {
162 socket_ = socket;
159 OnConnectToService( scoped_refptr<device::BluetoothSocket> socket) argument
H A Dbluetooth_host_pairing_controller.cc171 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 Dsocket_dispatcher_host.cc229 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...]

Completed in 473 milliseconds

<<1112131415161718