/external/chromium_org/v8/tools/testrunner/server/ |
H A D | presence_handler.py | 29 import socket namespace 47 s = socket.socket(socket.AF_INET, socket.SOCK_DGRAM) 104 sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM) 109 sock = socket [all...] |
/external/google-tv-pairing-protocol/java/src/com/google/polo/ssl/ |
H A D | SSLSocketFactoryWrapper.java | 88 public Socket createSocket(Socket socket, String s, int i, boolean flag) argument 90 return mFactory.createSocket(socket, s, i, flag);
|
/external/apache-harmony/x-net/src/test/api/java/org/apache/harmony/xnet/tests/javax/net/ssl/ |
H A D | X509ExtendedKeyManagerTest.java | 58 Socket socket) { 67 Socket socket) { 57 chooseClientAlias(String[] keyType, Principal[] issuers, Socket socket) argument 66 chooseServerAlias(String keyType, Principal[] issuers, Socket socket) argument
|
/external/apache-http/src/org/apache/http/impl/ |
H A D | SocketHttpClientConnection.java | 66 private Socket socket = null; field in class:SocketHttpClientConnection 85 final Socket socket, 88 return new SocketInputBuffer(socket, buffersize, params); 92 final Socket socket, 95 return new SocketOutputBuffer(socket, buffersize, params); 99 final Socket socket, 101 if (socket == null) { 107 this.socket = socket; 112 createSessionInputBuffer(socket, buffersiz 84 createSessionInputBuffer( final Socket socket, int buffersize, final HttpParams params) argument 91 createSessionOutputBuffer( final Socket socket, int buffersize, final HttpParams params) argument 98 bind( final Socket socket, final HttpParams params) argument [all...] |
H A D | SocketHttpServerConnection.java | 66 private Socket socket = null; field in class:SocketHttpServerConnection 85 final Socket socket, 88 return new SocketInputBuffer(socket, buffersize, params); 92 final Socket socket, 95 return new SocketOutputBuffer(socket, buffersize, params); 98 protected void bind(final Socket socket, final HttpParams params) throws IOException { argument 99 if (socket == null) { 105 this.socket = socket; 110 createHttpDataReceiver(socket, buffersiz 84 createHttpDataReceiver( final Socket socket, int buffersize, final HttpParams params) argument 91 createHttpDataTransmitter( final Socket socket, int buffersize, final HttpParams params) argument [all...] |
/external/chromium_org/build/android/ |
H A D | lighttpd_server.py | 19 import socket namespace 137 except (httplib.HTTPException, socket.error) as client_error:
|
/external/chromium_org/content/browser/renderer_host/pepper/ |
H A D | content_browser_pepper_host_factory.cc | 241 scoped_ptr<net::TCPSocket> socket) { 246 host_, instance, version, socket.Pass())); 238 CreateAcceptedTCPSocket( PP_Instance instance, ppapi::TCPSocketVersion version, scoped_ptr<net::TCPSocket> socket) argument
|
/external/chromium_org/native_client_sdk/src/examples/api/socket/ |
H A D | echo_server.cc | 19 // socket before new ones get "Connection Refused" 59 instance_->PostMessage("Error binding listening socket."); 77 instance_->PostMessage("server: Error listening on server socket."); 97 void EchoServer::OnAcceptCompletion(int32_t result, pp::TCPSocket socket) { argument 106 pp::NetAddress addr = socket.GetLocalAddress(); 110 incoming_socket_ = socket; 124 // Remove the current incoming socket and try
|
/external/chromium_org/native_client_sdk/src/libraries/nacl_io/socket/ |
H A D | tcp_event_emitter.cc | 5 #include "nacl_io/socket/tcp_event_emitter.h" 85 void TcpEventEmitter::SetAcceptedSocket_Locked(PP_Resource socket) { argument 86 accepted_socket_ = socket;
|
/external/chromium_org/native_client_sdk/src/tests/nacl_io_socket_test/ |
H A D | echo_server.cc | 20 // socket before new ones get "Connection Refused" 60 Log("Error binding listening socket."); 78 Log("server: Error listening on server socket."); 105 void EchoServer::OnAcceptCompletion(int32_t result, pp::TCPSocket socket) { argument 114 pp::NetAddress addr = socket.GetLocalAddress(); 118 incoming_socket_ = socket; 132 // Remove the current incoming socket and try
|
/external/chromium_org/net/dns/ |
H A D | dns_session.h | 45 scoped_ptr<DatagramClientSocket> socket); 50 DatagramClientSocket* socket() { return socket_.get(); } function in class:net::DnsSession::SocketLease 99 // Allocate a socket, already connected to the server address. 100 // When the SocketLease is destroyed, the socket will be freed. 113 // Release a socket. 115 scoped_ptr<DatagramClientSocket> socket);
|
/external/chromium_org/net/quic/ |
H A D | quic_server_packet_writer.cc | 18 UDPServerSocket* socket, 20 : socket_(socket), 17 QuicServerPacketWriter( UDPServerSocket* socket, QuicBlockedWriterInterface* blocked_writer) argument
|
/external/chromium_org/net/server/ |
H A D | http_connection.h | 22 // id, underlying socket, and pending read/write data. 113 HttpConnection(int id, scoped_ptr<StreamSocket> socket); 117 StreamSocket* socket() const { return socket_.get(); } function in class:net::HttpConnection
|
/external/chromium_org/ppapi/native_client/tools/browser_tester/ |
H A D | browser_tester.py | 9 import socket namespace 153 help='Pass --allow-nacl-socket-api=<host> to Chrome, where ' 194 host = socket.gethostbyname(socket.gethostname()) 227 # socket directly. 228 host, port = server.socket.getsockname() 340 # loop to shut down before closing the socket FD it is 342 # to close the socket FD.
|
/external/chromium_org/ppapi/proxy/ |
H A D | ppapi_param_traits.cc | 264 IPC::PlatformFileForTransit socket; local 265 if (ParamTraits<IPC::PlatformFileForTransit>::Read(m, iter, &socket)) { 266 r->set_socket(socket);
|
/external/chromium_org/ppapi/tests/ |
H A D | test_tcp_socket_private.cc | 61 pp::TCPSocketPrivate socket(instance_); 64 cb.WaitForResult(socket.Connect(host_.c_str(), port_, cb.GetCallback())); 70 ASSERT_TRUE(socket.GetLocalAddress(&unused)); 71 ASSERT_TRUE(socket.GetRemoteAddress(&unused)); 73 socket.Disconnect(); 79 pp::TCPSocketPrivate socket(instance_); 82 cb.WaitForResult(socket.Connect(host_.c_str(), port_, cb.GetCallback())); 86 ASSERT_EQ(PP_OK, WriteStringToSocket(&socket, "GET / HTTP/1.0\r\n\r\n")); 90 ASSERT_EQ(PP_OK, ReadFirstLineFromSocket(&socket, &s)); 93 socket 216 ReadFirstLineFromSocket( pp::TCPSocketPrivate* socket, std::string* s) argument 243 WriteStringToSocket(pp::TCPSocketPrivate* socket, const std::string& s) argument [all...] |
/external/chromium_org/remoting/host/ |
H A D | gnubby_auth_handler_posix_unittest.cc | 8 #include "net/socket/stream_listen_socket.h" 104 net::StreamListenSocket* socket = new MockStreamListenSocket(delegate_); local 106 delegate_->DidAccept(NULL, make_scoped_ptr(socket)); 107 ASSERT_TRUE(auth_handler_posix_->HasActiveSocketForTesting(socket)); 109 delegate_->DidClose(socket); 110 ASSERT_FALSE(auth_handler_posix_->HasActiveSocketForTesting(socket)); 116 net::StreamListenSocket* socket = new MockStreamListenSocket(delegate_); local 118 delegate_->DidAccept(NULL, make_scoped_ptr(socket)); 119 delegate_->DidRead(socket, 127 net::StreamListenSocket* socket local 137 net::StreamListenSocket* socket = new MockStreamListenSocket(delegate_); local 152 net::StreamListenSocket* socket = new MockStreamListenSocket(delegate_); local [all...] |
/external/chromium_org/remoting/protocol/ |
H A D | chromium_socket_factory_unittest.cc | 31 void OnPacket(rtc::AsyncPacketSocket* socket, argument 35 EXPECT_EQ(socket, socket_.get()); 103 // Try sending a packet to an IPv6 address from a socket that's bound to an 104 // IPv4 address. This send is expected to fail, but the socket should still be 110 // Verify that socket is still usable.
|
H A D | message_reader.h | 25 // MessageReader reads data from the socket asynchronously and calls 27 // callback as soon as the socket is closed, so the socket should 31 // new data from the socket until all previously received messages are 44 // Initialize the MessageReader with a socket. If a message is received 46 void Init(net::Socket* socket, const MessageReceivedCallback& callback); 58 // Set to true, when we have a socket read pending, and expecting 94 void Init(net::Socket* socket, const MessageReceivedCallback& callback) { argument 99 socket, base::Bind(&ProtobufMessageReader<T>::OnNewData,
|
/external/chromium_org/third_party/WebKit/Tools/Scripts/webkitpy/layout_tests/servers/ |
H A D | server_base.py | 33 import socket namespace 247 s = socket.socket() 263 s = socket.socket() 265 s.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
|
/external/chromium_org/third_party/libjingle/source/talk/p2p/base/ |
H A D | asyncstuntcpsocket.cc | 52 // Binds and connects |socket| and creates AsyncTCPSocket for 53 // it. Takes ownership of |socket|. Returns NULL if bind() or 54 // connect() fail (|socket| is destroyed in that case). 56 rtc::AsyncSocket* socket, 60 socket, bind_address, remote_address), false); 64 rtc::AsyncSocket* socket, bool listen) 65 : rtc::AsyncTCPSocketBase(socket, listen, kBufSize) { 139 rtc::AsyncSocket* socket) { 140 SignalNewConnection(this, new AsyncStunTCPSocket(socket, false)); 55 Create( rtc::AsyncSocket* socket, const rtc::SocketAddress& bind_address, const rtc::SocketAddress& remote_address) argument 63 AsyncStunTCPSocket( rtc::AsyncSocket* socket, bool listen) argument
|
H A D | basicpacketsocketfactory.cc | 66 rtc::AsyncSocket* socket = local 69 if (!socket) { 72 if (BindSocket(socket, address, min_port, max_port) < 0) { 74 << socket->GetError(); 75 delete socket; 78 return new rtc::AsyncUDPSocket(socket); 90 rtc::AsyncSocket* socket = local 93 if (!socket) { 97 if (BindSocket(socket, local_address, min_port, max_port) < 0) { 99 << socket 124 rtc::AsyncSocket* socket = local 195 BindSocket( AsyncSocket* socket, const SocketAddress& local_address, int min_port, int max_port) argument [all...] |
H A D | stunserver.cc | 35 StunServer::StunServer(rtc::AsyncUDPSocket* socket) : socket_(socket) { argument 44 rtc::AsyncPacketSocket* socket, const char* buf, size_t size, 43 OnPacket( rtc::AsyncPacketSocket* socket, const char* buf, size_t size, const rtc::SocketAddress& remote_addr, const rtc::PacketTime& packet_time) argument
|
H A D | tcpport.h | 83 // Handles sending using the local TCP socket. 90 void OnNewConnection(rtc::AsyncPacketSocket* socket, 96 rtc::AsyncPacketSocket* socket; member in struct:cricket::TCPPort::Incoming 103 void OnReadPacket(rtc::AsyncPacketSocket* socket, 108 void OnReadyToSend(rtc::AsyncPacketSocket* socket); 110 void OnAddressReady(rtc::AsyncPacketSocket* socket, 125 // Connection is outgoing unless socket is specified 127 rtc::AsyncPacketSocket* socket = 0); 134 rtc::AsyncPacketSocket* socket() { return socket_; } function in class:cricket::TCPConnection 137 void OnConnect(rtc::AsyncPacketSocket* socket); [all...] |
/external/chromium_org/third_party/mesa/src/src/gallium/auxiliary/rbug/ |
H A D | rbug_connection.c | 32 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...] |