Searched defs:socket (Results 226 - 250 of 430) sorted by relevance

1234567891011>>

/external/chromium_org/third_party/WebKit/Tools/Scripts/webkitpy/thirdparty/mod_pywebsocket/
H A Dutil.py55 import socket namespace
373 """A wrapper class for socket object to intercept send and recv to perform
380 def __init__(self, socket):
381 self._socket = socket
389 """Receives data from the socket specified on the construction up
/external/chromium_org/third_party/libjingle/source/talk/examples/peerconnection/server/
H A Dpeer_channel.cc70 ChannelMember::ChannelMember(DataSocket* socket) argument
73 assert(socket);
74 assert(socket->method() == DataSocket::GET);
75 assert(socket->PathEquals("/sign_in"));
76 name_ = socket->request_arguments(); // TODO: urldecode
151 printf("Failed to deliver data to waiting socket\n");
/external/chromium_org/third_party/libjingle/source/talk/p2p/base/
H A Drelayport_unittest.cc80 void OnReadPacket(rtc::AsyncPacketSocket* socket, argument
84 received_packet_count_[socket]++;
106 // The relay server needs an external socket to work properly.
128 // Add a UDP socket to the relay server.
167 // Create a server socket for the RelayServer.
200 // Create a ssl server socket for the RelayServer.
206 // Create a tcp server socket that listens on the fake address so
233 rtc::AsyncSocket* socket = local
236 rtc::AsyncUDPSocket::Create(socket, addr);
243 rtc::AsyncSocket* socket local
[all...]
H A Drelayserver.h64 void AddInternalSocket(rtc::AsyncPacketSocket* socket);
65 void RemoveInternalSocket(rtc::AsyncPacketSocket* socket);
70 void AddExternalSocket(rtc::AsyncPacketSocket* socket);
71 void RemoveExternalSocket(rtc::AsyncPacketSocket* socket);
75 // internal socket will be added.
76 void AddInternalServerSocket(rtc::AsyncSocket* socket,
79 // Removes this server socket from the list.
80 void RemoveInternalServerSocket(rtc::AsyncSocket* socket);
105 void OnInternalPacket(rtc::AsyncPacketSocket* socket,
109 void OnExternalPacket(rtc::AsyncPacketSocket* socket,
158 rtc::AsyncPacketSocket* socket() { return socket_; } function in class:cricket::RelayServerConnection
[all...]
H A Dstunport.h51 rtc::AsyncPacketSocket* socket,
54 UDPPort* port = new UDPPort(thread, factory, network, socket,
102 rtc::AsyncPacketSocket* socket, const char* data, size_t size,
106 OnReadPacket(socket, data, size, remote_addr, packet_time);
124 rtc::Network* network, rtc::AsyncPacketSocket* socket,
134 void OnLocalAddressReady(rtc::AsyncPacketSocket* socket,
136 void OnReadPacket(rtc::AsyncPacketSocket* socket,
141 void OnReadyToSend(rtc::AsyncPacketSocket* socket);
48 Create(rtc::Thread* thread, rtc::PacketSocketFactory* factory, rtc::Network* network, rtc::AsyncPacketSocket* socket, const std::string& username, const std::string& password) argument
101 HandleIncomingPacket( rtc::AsyncPacketSocket* socket, const char* data, size_t size, const rtc::SocketAddress& remote_addr, const rtc::PacketTime& packet_time) argument
H A Dtcpport.cc53 // Treat failure to create or bind a TCP socket as fatal. This
59 LOG_J(LS_ERROR, this) << "TCP socket creation failed.";
72 delete it->socket;
110 if (rtc::AsyncPacketSocket* socket =
112 socket->SignalReadPacket.disconnect(this);
113 conn = new TCPConnection(this, address, socket);
123 // If socket isn't bound yet the address will be added in
125 // failed, we still want to add the socket address.
149 rtc::AsyncPacketSocket * socket = NULL; local
151 socket
190 OnNewConnection(rtc::AsyncPacketSocket* socket, rtc::AsyncPacketSocket* new_socket) argument
207 rtc::AsyncPacketSocket* socket = NULL; local
220 OnReadPacket(rtc::AsyncPacketSocket* socket, const char* data, size_t size, const rtc::SocketAddress& remote_addr, const rtc::PacketTime& packet_time) argument
227 OnReadyToSend(rtc::AsyncPacketSocket* socket) argument
231 OnAddressReady(rtc::AsyncPacketSocket* socket, const rtc::SocketAddress& address) argument
238 TCPConnection(TCPPort* port, const Candidate& candidate, rtc::AsyncPacketSocket* socket) argument
301 OnConnect(rtc::AsyncPacketSocket* socket) argument
318 OnClose(rtc::AsyncPacketSocket* socket, int error) argument
325 OnReadPacket( rtc::AsyncPacketSocket* socket, const char* data, size_t size, const rtc::SocketAddress& remote_addr, const rtc::PacketTime& packet_time) argument
333 OnReadyToSend(rtc::AsyncPacketSocket* socket) argument
[all...]
H A Dturnport.h56 rtc::AsyncPacketSocket* socket,
62 return new TurnPort(thread, factory, network, socket,
101 rtc::AsyncPacketSocket* socket, const char* data, size_t size,
104 OnReadPacket(socket, data, size, remote_addr, packet_time);
107 virtual void OnReadPacket(rtc::AsyncPacketSocket* socket,
112 virtual void OnReadyToSend(rtc::AsyncPacketSocket* socket);
114 void OnSocketConnect(rtc::AsyncPacketSocket* socket);
115 void OnSocketClose(rtc::AsyncPacketSocket* socket, int error);
125 rtc::AsyncPacketSocket* socket() const { function in class:cricket::TurnPort
144 rtc::AsyncPacketSocket* socket,
53 Create(rtc::Thread* thread, rtc::PacketSocketFactory* factory, rtc::Network* network, rtc::AsyncPacketSocket* socket, const std::string& username, const std::string& password, const ProtocolAddress& server_address, const RelayCredentials& credentials, int server_priority) argument
100 HandleIncomingPacket( rtc::AsyncPacketSocket* socket, const char* data, size_t size, const rtc::SocketAddress& remote_addr, const rtc::PacketTime& packet_time) argument
[all...]
H A Dturnserver.h74 // The core TURN server class. Give it a socket to listen on via
101 void AddInternalSocket(rtc::AsyncPacketSocket* socket,
103 // Starts listening for the connections on this socket. When someone tries
104 // to connect, the connection will be accepted and a new internal socket
106 void AddInternalServerSocket(rtc::AsyncSocket* socket,
119 rtc::AsyncPacketSocket* socket);
121 rtc::AsyncPacketSocket* socket() { return socket_; } function in class:cricket::TurnServer::Connection
137 void OnInternalPacket(rtc::AsyncPacketSocket* socket, const char* data,
141 void OnNewInternalConnection(rtc::AsyncSocket* socket);
143 // Accept connections on this server socket
[all...]
/external/chromium_org/third_party/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/chromium_org/third_party/tlslite/tests/
H A Dtlstest.py16 import socket namespace
88 sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
253 connection.sock.close() #Close the socket without a close_notify!
266 if hasattr(socket, "timeout"):
267 timeoutEx = socket.timeout
269 timeoutEx = socket.error
422 except socket
[all...]
/external/chromium_org/third_party/tlslite/tlslite/
H A Dtlsconnection.py14 import socket namespace
126 This class wraps a socket and provides TLS handshaking and data
130 socket into the constructor. Then call some handshake function.
133 connection as if it were a socket.
151 @param sock: The socket data will be transmitted on. The
152 socket should already be connected. It may be in blocking or
155 @type sock: L{socket.socket}
203 return 0 if it is waiting to read from the socket, 1 if it is
204 waiting to write to the socket, o
[all...]
H A Dtlsrecordlayer.py21 import socket namespace
48 @type sock: socket.socket
49 @ivar sock: The underlying socket object.
76 @ivar closeSocket: If the socket should be closed when the
80 closing the socket when the TLS Connection is shutdown (either
85 @ivar ignoreAbruptClose: If an abrupt close of the socket should
90 socket is unexpectedly closed. Such an unexpected closure could be
140 #On a call to close(), do we close the socket? (writeable)
143 #If the socket i
[all...]
/external/chromium_org/third_party/webrtc/base/
H A Dasyncsocket.h16 #include "webrtc/base/socket.h"
22 // Provides the ability to perform socket I/O asynchronously.
46 // The adapted socket may explicitly be NULL, and later assigned using Attach.
50 explicit AsyncSocketAdapter(AsyncSocket* socket);
52 void Attach(AsyncSocket* socket);
106 virtual void OnConnectEvent(AsyncSocket* socket) { argument
109 virtual void OnReadEvent(AsyncSocket* socket) { argument
112 virtual void OnWriteEvent(AsyncSocket* socket) { argument
115 virtual void OnCloseEvent(AsyncSocket* socket, int err) { argument
H A Dasynctcpsocket.cc34 // Binds and connects |socket|
36 rtc::AsyncSocket* socket,
39 rtc::scoped_ptr<rtc::AsyncSocket> owned_socket(socket);
40 if (socket->Bind(bind_address) < 0) {
41 LOG(LS_ERROR) << "Bind() failed with error " << socket->GetError();
44 if (socket->Connect(remote_address) < 0) {
45 LOG(LS_ERROR) << "Connect() failed with error " << socket->GetError();
51 AsyncTCPSocketBase::AsyncTCPSocketBase(AsyncSocket* socket, bool listen, argument
53 : socket_(socket),
173 void AsyncTCPSocketBase::OnConnectEvent(AsyncSocket* socket) { argument
35 ConnectSocket( rtc::AsyncSocket* socket, const rtc::SocketAddress& bind_address, const rtc::SocketAddress& remote_address) argument
177 OnReadEvent(AsyncSocket* socket) argument
216 OnWriteEvent(AsyncSocket* socket) argument
228 OnCloseEvent(AsyncSocket* socket, int error) argument
236 Create( AsyncSocket* socket, const SocketAddress& bind_address, const SocketAddress& remote_address) argument
244 AsyncTCPSocket(AsyncSocket* socket, bool listen) argument
295 HandleIncomingConnection(AsyncSocket* socket) argument
[all...]
H A Dfirewallsocketserver.cc24 FirewallSocket(FirewallSocketServer* server, AsyncSocket* socket, int type) argument
25 : AsyncSocketAdapter(socket), server_(server), type_(type) {
197 LOG(LS_VERBOSE) << "FirewallSocketServer socket creation denied";
H A Dhttpserver.cc269 void HttpListenServer::OnReadEvent(AsyncSocket* socket) { argument
270 ASSERT(socket == listener_.get());
H A Dnatserver.cc92 AsyncPacketSocket* socket, const char* buf, size_t size,
113 iter->second->socket->SendTo(buf + length, size - length, dest_addr, options);
117 AsyncPacketSocket* socket, const char* buf, size_t size,
120 SocketAddress local_addr = socket->GetLocalAddress();
147 AsyncUDPSocket* socket = AsyncUDPSocket::Create(external_, external_ip_); local
149 if (!socket) {
154 TransEntry* entry = new TransEntry(route, socket, nat_);
156 (*ext_map_)[socket->GetLocalAddress()] = entry;
157 socket->SignalReadPacket.connect(this, &NATServer::OnExternalPacket);
167 : route(r), socket(
91 OnInternalPacket( AsyncPacketSocket* socket, const char* buf, size_t size, const SocketAddress& addr, const PacketTime& packet_time) argument
116 OnExternalPacket( AsyncPacketSocket* socket, const char* buf, size_t size, const SocketAddress& remote_addr, const PacketTime& packet_time) argument
[all...]
H A Dsocketadapters.cc41 BufferedReadAdapter::BufferedReadAdapter(AsyncSocket* socket, size_t size) argument
42 : AsyncSocketAdapter(socket), buffer_size_(size),
92 void BufferedReadAdapter::OnReadEvent(AsyncSocket * socket) { argument
93 ASSERT(socket == socket_);
96 AsyncSocketAdapter::OnReadEvent(socket);
160 AsyncSSLSocket::AsyncSSLSocket(AsyncSocket* socket) argument
161 : BufferedReadAdapter(socket, 1024) {
171 void AsyncSSLSocket::OnConnectEvent(AsyncSocket * socket) { argument
172 ASSERT(socket == socket_);
197 // FIX: if SignalConnect causes the socket t
202 AsyncSSLServerSocket(AsyncSocket* socket) argument
233 AsyncHttpsProxySocket(AsyncSocket* socket, const std::string& user_agent, const SocketAddress& proxy, const std::string& username, const CryptString& password) argument
284 OnConnectEvent(AsyncSocket * socket) argument
294 OnCloseEvent(AsyncSocket * socket, int err) argument
500 AsyncSocksProxySocket(AsyncSocket* socket, const SocketAddress& proxy, const std::string& username, const CryptString& password) argument
538 OnConnectEvent(AsyncSocket* socket) argument
[all...]
H A Dsocketadapters.h28 // Implements a socket adapter that can buffer and process data internally,
30 // protocol before commencing normal socket behavior.
33 BufferedReadAdapter(AsyncSocket* socket, size_t buffer_size);
47 virtual void OnReadEvent(AsyncSocket * socket);
61 AsyncProxyServerSocket(AsyncSocket* socket, size_t buffer_size) argument
62 : BufferedReadAdapter(socket, buffer_size) {}
70 // Implements a socket adapter that performs the client side of a
74 explicit AsyncSSLSocket(AsyncSocket* socket);
79 virtual void OnConnectEvent(AsyncSocket* socket);
84 // Implements a socket adapte
[all...]
H A Dssladapter_unittest.cc26 rtc::AsyncSocket* socket = rtc::Thread::Current()-> local
30 socket->Bind(address);
32 return socket;
43 rtc::AsyncSocket* socket = CreateSocket(ssl_mode_); local
45 ssl_adapter_.reset(rtc::SSLAdapter::Create(socket));
89 void OnSSLAdapterReadEvent(rtc::AsyncSocket* socket) { argument
93 int read = socket->Recv(buffer, sizeof(buffer) - 1);
103 void OnSSLAdapterCloseEvent(rtc::AsyncSocket* socket, int error) { argument
105 // closing the socket! Let's close the socket her
173 OnServerSocketReadEvent(rtc::AsyncSocket* socket) argument
[all...]
/external/chromium_org/tools/
H A Dcheck_git_config.py29 import socket namespace
89 return socket.getfqdn().endswith('.corp.google.com')
90 except socket.error:
475 except (urllib2.URLError, socket.error, ssl.SSLError) as exc:
/external/chromium_org/tools/telemetry/telemetry/core/backends/chrome/
H A Dchrome_browser_backend.py11 import socket namespace
210 except (socket.error, httplib.BadStatusLine, urllib2.URLError) as e:
/external/chromium_org/tools/telemetry/telemetry/core/forwarders/
H A Dandroid_forwarder.py8 import socket namespace
305 return struct.unpack('!L', socket.inet_aton(addr))[0]
360 return socket.inet_ntoa(struct.pack('!L', value))
/external/conscrypt/src/main/java/org/conscrypt/
H A DOpenSSLSocketImplWrapper.java27 * This class wraps the SSL functionality over an existing connected socket.
31 private Socket socket; field in class:OpenSSLSocketImplWrapper
33 protected OpenSSLSocketImplWrapper(Socket socket, String hostname, int port, argument
35 super(socket, hostname, port, autoClose, sslParameters);
36 if (!socket.isConnected()) {
39 this.socket = socket;
45 throw new IOException("Underlying socket is already connected.");
50 throw new IOException("Underlying socket is already connected.");
55 throw new IOException("Underlying socket i
[all...]
/external/deqp/execserver/tools/
H A DxsClient.cpp63 void sendMessage (de::Socket& socket, const Message& message) argument
69 // Write to socket.
75 deSocketResult result = socket.send(&buf[pos], numLeft, &numSent);
84 void readBytes (de::Socket& socket, vector<deUint8>& dst, int numBytes) argument
92 deSocketResult result = socket.receive(&dst[numRead], numLeft, &curNumRead);
101 Message* readMessage (de::Socket& socket) argument
105 readBytes(socket, header, MESSAGE_HEADER_SIZE);
121 readBytes(socket, messageBuf, messageSize-MESSAGE_HEADER_SIZE);

Completed in 1691 milliseconds

1234567891011>>