Searched defs:socket (Results 101 - 125 of 430) sorted by relevance

1234567891011>>

/external/chromium_org/third_party/webrtc/base/
H A Dnatserver.h64 void OnInternalPacket(AsyncPacketSocket* socket, const char* buf,
67 void OnExternalPacket(AsyncPacketSocket* socket, const char* buf,
74 /* Records a translation and the associated external socket. */
83 AsyncUDPSocket* socket; member in struct:rtc::NATServer::TransEntry
H A Dproxyserver.h37 void OnConnectRequest(AsyncProxyServerSocket* socket,
39 void OnInternalRead(AsyncSocket* socket);
40 void OnInternalWrite(AsyncSocket* socket);
41 void OnInternalClose(AsyncSocket* socket, int err);
42 void OnExternalConnect(AsyncSocket* socket);
43 void OnExternalRead(AsyncSocket* socket);
44 void OnExternalWrite(AsyncSocket* socket);
45 void OnExternalClose(AsyncSocket* socket, int err);
47 static void Read(AsyncSocket* socket, FifoBuffer* buffer);
48 static void Write(AsyncSocket* socket, FifoBuffe
88 WrapSocket(AsyncSocket* socket) argument
[all...]
H A Dsocketstream.cc15 SocketStream::SocketStream(AsyncSocket* socket) : socket_(NULL) { argument
16 Attach(socket);
23 void SocketStream::Attach(AsyncSocket* socket) { argument
26 socket_ = socket;
36 AsyncSocket* socket = socket_; local
44 return socket;
100 void SocketStream::OnConnectEvent(AsyncSocket* socket) { argument
101 ASSERT(socket == socket_);
105 void SocketStream::OnReadEvent(AsyncSocket* socket) { argument
106 ASSERT(socket
110 OnWriteEvent(AsyncSocket* socket) argument
115 OnCloseEvent(AsyncSocket* socket, int err) argument
[all...]
H A Dsslsocketfactory.cc23 // the socket adapter is the more appropriate idiom for automatic proxy
125 AsyncSocket* socket = factory_->CreateAsyncSocket(family, type); local
126 if (!socket)
131 socket = new LoggingSocketAdapter(socket, logging_level_,
138 proxy_socket = new AsyncSocksProxySocket(socket, proxy.address,
143 new AsyncHttpsProxySocket(socket, agent_, proxy.address,
149 delete socket;
152 socket = proxy_socket; // for our purposes the proxy is now the socket
[all...]
H A Dtestechoserver.h43 void OnAccept(AsyncSocket* socket) { argument
44 AsyncSocket* raw_socket = socket->Accept(NULL);
52 void OnPacket(AsyncPacketSocket* socket, const char* buf, size_t size, argument
56 socket->Send(buf, size, options);
58 void OnClose(AsyncPacketSocket* socket, int err) { argument
60 std::find(client_sockets_.begin(), client_sockets_.end(), socket);
62 Thread::Current()->Dispose(socket);
/external/chromium_org/tools/android/forwarder2/
H A Dhost_controller.cc16 #include "tools/android/forwarder2/socket.h"
33 LOG(ERROR) << "Could not connect HostController socket on port: "
103 LOG(ERROR) << "Could not Connect HostServerData socket on port: "
155 Socket socket; local
156 if (!socket.ConnectTcp("", adb_port_)) {
160 if (!SendCommand(command::UNLISTEN, device_port_, &socket)) {
164 if (!ReceivedCommand(command::UNLISTEN_SUCCESS, &socket)) {
/external/chromium_org/tools/findit/common/
H A Dhttp_client_local.py22 import socket namespace
100 'SSL socket or SSL context with either '
142 sock = socket.create_connection(*args)
148 # Wrap the socket for verification with the root certs.
158 self.sock.shutdown(socket.SHUT_RDWR)
/external/chromium_org/tools/perf/profile_creators/
H A Dextensions_profile_creator.py10 import socket namespace
165 hostname = socket.gethostname()
/external/chromium_org/tools/telemetry/telemetry/core/platform/
H A Dcros_interface_unittest.py9 import socket namespace
117 sock = socket.socket()
/external/chromium_org/tools/telemetry/telemetry/core/
H A Dutil.py9 import socket namespace
100 tmp = socket.socket()
/external/chromium_org/v8/tools/testrunner/network/
H A Dnetwork_execution.py30 import socket namespace
93 self.local_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
171 sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
/external/conscrypt/src/main/java/org/conscrypt/
H A DKeyManagerImpl.java45 * from socket or engine.
88 public String chooseClientAlias(String[] keyTypes, Principal[] issuers, Socket socket) { argument
94 public String chooseServerAlias(String keyType, Principal[] issuers, Socket socket) { argument
/external/google-tv-pairing-protocol/java/src/com/google/polo/pairing/
H A DPairingContext.java80 * @param socket the socket to use
84 * @throws IOException if the socket's streams could not be obtained
86 public static PairingContext fromSslSocket(SSLSocket socket, boolean isServer) argument
88 Certificate localCert = PoloUtil.getLocalCert(socket.getSession());
89 Certificate peerCert = PoloUtil.getPeerCert(socket.getSession());
90 InputStream input = socket.getInputStream();
91 OutputStream output = socket.getOutputStream();
/external/lldb/test/pexpect-2.4/examples/
H A Dbd_serv.py5 This exposes an shell terminal on a socket.
18 import time, sys, os, getopt, getpass, traceback, threading, socket namespace
191 s = socket.socket(socket.AF_UNIX, socket.SOCK_STREAM)
198 #s = socket.socket(socket.AF_INET, socket
[all...]
/external/mesa3d/src/gallium/auxiliary/rbug/
H A Drbug_connection.c32 int socket; member in struct:rbug_connection
39 * Create a rbug connection from a socket created with u_socket.
42 * A new allocated connection using socket as communication path
45 rbug_from_socket(int socket) argument
48 c->socket = socket;
53 * Free a connection, also closes socket.
58 u_socket_close(c->socket);
80 ret = u_socket_peek(c->socket, &header, sizeof(header));
94 ret = u_socket_recv(c->socket, pt
[all...]
/external/okhttp/mockwebserver/src/main/java/com/squareup/okhttp/internal/spdy/
H A DSpdyServer.java56 Socket socket = serverSocket.accept();
58 socket = doSsl(socket);
60 new SpdyConnection.Builder(false, socket).handler(this).build();
64 private Socket doSsl(Socket socket) throws IOException { argument
66 (SSLSocket) sslSocketFactory.createSocket(socket, socket.getInetAddress().getHostAddress(),
67 socket.getPort(), true);
/external/okhttp/mockwebserver/src/main/java/com/squareup/okhttp/mockwebserver/
H A DRecordedRequest.java38 long bodySize, byte[] body, int sequenceNumber, Socket socket) {
45 this.sslProtocol = socket instanceof SSLSocket
46 ? ((SSLSocket) socket).getSession().getProtocol()
37 RecordedRequest(String requestLine, List<String> headers, List<Integer> chunkSizes, long bodySize, byte[] body, int sequenceNumber, Socket socket) argument
/external/srtp/test/
H A Drtp.c18 # include <sys/socket.h>
50 octets_sent = sendto(sender->socket, (void*)&sender->message,
69 octets_recvd = recvfrom(receiver->socket, (void *)&receiver->message,
103 int socket,
119 sender->socket = socket;
127 int socket,
143 rcvr->socket = socket;
102 rtp_sender_init(rtp_sender_t sender, int socket, struct sockaddr_in addr, unsigned int ssrc) argument
126 rtp_receiver_init(rtp_receiver_t rcvr, int socket, struct sockaddr_in addr, unsigned int ssrc) argument
/external/chromium_org/remoting/webapp/js_proto/
H A Dchrome_proto.js617 chrome.socket = {};
620 chrome.socket.CreateInfo = function() {
628 * @param {function(chrome.socket.CreateInfo):void} callback
630 chrome.socket.create = function(socketType, options, callback) {};
638 chrome.socket.connect =
642 chrome.socket.WriteInfo = function() {
650 * @param {function(chrome.socket.WriteInfo):void} callback
652 chrome.socket.write = function(socketId, data, callback) {};
655 chrome.socket.ReadInfo = function() {
665 * @param {function(chrome.socket
[all...]
/external/antlr/antlr-3.4/runtime/Python/tests/
H A Dt059debug.py9 import socket namespace
21 # create listening socket
26 s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
29 except socket.error, exc:
65 except socket.timeout:
67 except socket.error, exc:
/external/apache-http/src/org/apache/http/conn/ssl/
H A DSSLSocketFactory.java59 * Layered socket factory for TLS/SSL connections, based on JSSE.
70 * certificates. The client secure socket will reject the connection during
85 * pair. The client secure socket will use the private key to authenticate
245 * Creates the default SSL socket factory.
336 // close the socket before re-throwing the exception
346 * Checks whether a socket connection is secure.
347 * This factory creates TLS/SSL socket connections
353 * @param sock the connected socket
382 final Socket socket,
388 socket,
381 createSocket( final Socket socket, final String host, final int port, final boolean autoClose ) argument
[all...]
/external/apache-http/src/org/apache/http/impl/conn/
H A DDefaultClientConnection.java78 /** The unconnected socket */
79 private volatile Socket socket; field in class:DefaultClientConnection
109 return this.socket;
115 this.socket = sock;
118 // Check for shutdown after assigning socket, so that
134 bind(this.socket, params);
142 * socket that is being connected to a remote address will be closed.
144 * the socket.
156 Socket sock = this.socket; // copy volatile attribute
172 final Socket socket,
171 createSessionInputBuffer( final Socket socket, int buffersize, final HttpParams params) argument
187 createSessionOutputBuffer( final Socket socket, int buffersize, final HttpParams params) argument
[all...]
/external/chromium_org/base/
H A Dasync_socket_io_handler_unittest.cc21 TestSocketReader(base::CancelableSyncSocket* socket, argument
25 : socket_(socket), buffer_(),
70 void SendData(base::CancelableSyncSocket* socket, argument
73 socket->Send(buffer, length);
78 // Tests doing a pending read from a socket and use an IO handler to get
95 // Tests doing a read from a socket when we know that there is data in the
96 // socket. Here we want to make sure that any async 'can read' notifications
/external/chromium_org/chrome/browser/android/
H A Ddev_tools_server.cc44 #include "net/socket/unix_domain_listen_socket_posix.h"
45 #include "net/socket/unix_domain_server_socket_posix.h"
137 // Factory for UnixDomainServerSocket. It tries a fallback socket when
138 // original socket doesn't work.
158 scoped_ptr<net::ServerSocket> socket = Create(); variable
159 if (!socket)
162 if (socket->ListenWithAddressAndPort(address_, port_, backlog_) == net::OK)
163 return socket.Pass();
165 // Try a fallback socket name.
168 if (socket
[all...]
/external/chromium_org/chrome/browser/devtools/device/usb/
H A Dusb_device_provider.cc13 #include "net/socket/stream_socket.h"
24 scoped_ptr<net::StreamSocket> socket(socket_raw);
26 socket.reset();
27 callback.Run(result, socket.Pass());
30 void OnRead(net::StreamSocket* socket, argument
37 delete socket;
43 socket->Read(buffer.get(),
45 base::Bind(&OnRead, socket, buffer, new_data, callback));
47 OnRead(socket, buffer, new_data, callback, result);
51 net::StreamSocket* socket,
50 OpenedForCommand(const UsbDeviceProvider::CommandCallback& callback, net::StreamSocket* socket, int result) argument
69 net::StreamSocket* socket = device->CreateSocket(command); local
120 net::StreamSocket* socket = it->second->CreateSocket(socket_name); local
[all...]

Completed in 496 milliseconds

1234567891011>>