/external/chromium_org/third_party/WebKit/Tools/Scripts/webkitpy/thirdparty/mod_pywebsocket/ |
H A D | util.py | 55 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 D | peer_channel.cc | 70 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 D | relayport_unittest.cc | 80 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 D | relayserver.h | 64 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 D | stunport.h | 51 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 D | tcpport.cc | 53 // 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 D | turnport.h | 56 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 D | turnserver.h | 74 // 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 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/chromium_org/third_party/tlslite/tests/ |
H A D | tlstest.py | 16 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 D | tlsconnection.py | 14 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 D | tlsrecordlayer.py | 21 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 D | asyncsocket.h | 16 #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 D | asynctcpsocket.cc | 34 // 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 D | firewallsocketserver.cc | 24 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 D | httpserver.cc | 269 void HttpListenServer::OnReadEvent(AsyncSocket* socket) { argument 270 ASSERT(socket == listener_.get());
|
H A D | natserver.cc | 92 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 D | socketadapters.cc | 41 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 D | socketadapters.h | 28 // 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 D | ssladapter_unittest.cc | 26 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 D | check_git_config.py | 29 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 D | chrome_browser_backend.py | 11 import socket namespace 210 except (socket.error, httplib.BadStatusLine, urllib2.URLError) as e:
|
/external/chromium_org/tools/telemetry/telemetry/core/forwarders/ |
H A D | android_forwarder.py | 8 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 D | OpenSSLSocketImplWrapper.java | 27 * 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 D | xsClient.cpp | 63 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);
|