Searched defs:socket (Results 151 - 175 of 430) sorted by relevance

1234567891011>>

/external/chromium_org/ppapi/tests/
H A Dtest_host_resolver.cc48 pp::TCPSocket* socket,
51 callback.WaitForResult(socket->Connect(address, callback.GetCallback()));
57 std::string TestHostResolver::SyncRead(pp::TCPSocket* socket, argument
63 socket->Read(buffer, num_bytes, callback.GetCallback()));
70 std::string TestHostResolver::SyncWrite(pp::TCPSocket* socket, argument
76 socket->Write(buffer, num_bytes, callback.GetCallback()));
83 std::string TestHostResolver::CheckHTTPResponse(pp::TCPSocket* socket, argument
88 SyncWrite(socket, request.c_str(), request.size(), &rv));
91 SyncRead(socket, &response_buffer[0], response.size(), &rv));
127 pp::TCPSocket socket(instance
47 SyncConnect( pp::TCPSocket* socket, const pp::NetAddress& address) argument
[all...]
H A Dtest_host_resolver_private.cc49 std::string TestHostResolverPrivate::SyncConnect(pp::TCPSocketPrivate* socket, argument
54 socket->Connect(host.c_str(), port, callback.GetCallback()));
61 pp::TCPSocketPrivate* socket,
65 socket->ConnectWithNetAddress(&address, callback.GetCallback()));
71 std::string TestHostResolverPrivate::SyncRead(pp::TCPSocketPrivate* socket, argument
77 socket->Read(buffer, num_bytes, callback.GetCallback()));
84 std::string TestHostResolverPrivate::SyncWrite(pp::TCPSocketPrivate* socket, argument
90 socket->Write(buffer, num_bytes, callback.GetCallback()));
98 pp::TCPSocketPrivate* socket,
103 SyncWrite(socket, reques
60 SyncConnect( pp::TCPSocketPrivate* socket, const PP_NetAddress_Private& address) argument
97 CheckHTTPResponse( pp::TCPSocketPrivate* socket, const std::string& request, const std::string& response) argument
[all...]
H A Dtest_net_address_private_untrusted.cc55 int32_t TestNetAddressPrivateUntrusted::Connect(TCPSocketPrivate* socket, argument
61 socket->Connect(host.c_str(), port, callback.GetCallback()));
66 pp::TCPSocketPrivate socket(instance_);
67 int32_t rv = Connect(&socket, host_, port_);
72 ASSERT_TRUE(socket.GetLocalAddress(&local_address));
73 ASSERT_TRUE(socket.GetRemoteAddress(&remote_address));
78 socket.Disconnect();
83 pp::TCPSocketPrivate socket(instance_);
84 int32_t rv = Connect(&socket, host_, port_);
89 ASSERT_TRUE(socket
[all...]
H A Dtest_tcp_server_socket_private.cc63 TCPSocketPrivate socket(instance_);
66 socket.Connect(host_.c_str(), port_, callback.GetCallback()));
69 ASSERT_TRUE(socket.GetLocalAddress(address));
70 socket.Disconnect();
74 std::string TestTCPServerSocketPrivate::SyncRead(TCPSocketPrivate* socket, argument
80 socket->Read(buffer, num_bytes, callback.GetCallback()));
89 std::string TestTCPServerSocketPrivate::SyncWrite(TCPSocketPrivate* socket, argument
95 socket->Write(buffer, num_bytes, callback.GetCallback()));
105 TCPSocketPrivate* socket,
109 socket
104 SyncConnect( TCPSocketPrivate* socket, PP_NetAddress_Private* address) argument
115 ForceConnect(TCPSocketPrivate* socket, PP_NetAddress_Private* address) argument
123 SyncListen( TCPServerSocketPrivate* socket, PP_NetAddress_Private* address, int32_t backlog) argument
[all...]
/external/chromium_org/remoting/host/
H A Dgnubby_socket.cc9 #include "net/socket/stream_listen_socket.h"
24 GnubbySocket::GnubbySocket(scoped_ptr<net::StreamListenSocket> socket, argument
26 : socket_(socket.Pass()) {
82 bool GnubbySocket::IsSocket(net::StreamListenSocket* socket) const {
83 return socket == socket_.get();
/external/chromium_org/remoting/protocol/
H A Dauthenticator_test_base.cc162 scoped_ptr<net::StreamSocket> socket) {
164 host_socket_ = socket.Pass();
169 scoped_ptr<net::StreamSocket> socket) {
171 client_socket_ = socket.Pass();
160 OnHostConnected( int error, scoped_ptr<net::StreamSocket> socket) argument
167 OnClientConnected( int error, scoped_ptr<net::StreamSocket> socket) argument
H A Dbuffered_socket_writer.cc36 void BufferedSocketWriterBase::Init(net::Socket* socket, argument
39 DCHECK(socket);
40 socket_ = socket;
H A Dssl_hmac_channel_authenticator.cc15 #include "net/socket/client_socket_factory.h"
16 #include "net/socket/client_socket_handle.h"
17 #include "net/socket/ssl_client_socket.h"
18 #include "net/socket/ssl_client_socket_openssl.h"
19 #include "net/socket/ssl_server_socket.h"
59 scoped_ptr<net::StreamSocket> socket, const DoneCallback& done_callback) {
61 DCHECK(socket->IsConnected());
86 net::CreateSSLServerSocket(socket.Pass(),
117 socket_handle->SetSocket(socket.Pass());
151 // Generate authentication digest to write to the socket
58 SecureAndAuthenticate( scoped_ptr<net::StreamSocket> socket, const DoneCallback& done_callback) argument
291 CallDoneCallback( int error, scoped_ptr<net::StreamSocket> socket) argument
[all...]
H A Dssl_hmac_channel_authenticator_unittest.cc39 MOCK_METHOD2(OnDone, void(int error, net::StreamSocket* socket));
114 scoped_ptr<net::StreamSocket> socket) {
120 host_callback_.OnDone(error, socket.get());
121 host_socket_ = socket.Pass();
124 void OnClientConnected(int error, scoped_ptr<net::StreamSocket> socket) { argument
126 client_callback_.OnDone(error, socket.get());
127 client_socket_ = socket.Pass();
112 OnHostConnected(const std::string& ref_argument, int error, scoped_ptr<net::StreamSocket> socket) argument
/external/chromium_org/third_party/libjingle/source/talk/examples/peerconnection/server/
H A Ddata_socket.h38 #include <sys/socket.h>
55 explicit SocketBase(int socket) : socket_(socket) { } argument
58 int socket() const { return socket_; } function in class:SocketBase
68 // Represents an HTTP server socket.
78 explicit DataSocket(int socket) argument
79 : SocketBase(socket),
133 // Clears all held state and prepares the socket for receiving a new request.
158 // The server socket. Accepts connections and generates DataSocket instances
/external/chromium_org/third_party/libjingle/source/talk/p2p/base/
H A Dasyncstuntcpsocket_unittest.cc111 void OnReadPacket(rtc::AsyncPacketSocket* socket, const char* data, argument
244 // We have problem in getting the SignalWriteEvent from the virtual socket
258 // We have problem in getting the SignalWriteEvent from the virtual socket
H A Dstunport_unittest.cc116 void OnReadPacket(rtc::AsyncPacketSocket* socket, const char* data, argument
120 socket, data, size, remote_addr, rtc::PacketTime());
230 // Test that a local candidate can be generated using a shared socket.
H A Dtestrelayserver.h74 rtc::AsyncSocket* socket = local
76 socket->Bind(addr);
77 socket->Listen(5);
78 socket->SignalReadEvent.connect(this, &TestRelayServer::OnAccept);
79 return socket;
81 void OnAccept(rtc::AsyncSocket* socket) { argument
82 bool external = (socket == tcp_ext_socket_.get() ||
83 socket == ssl_ext_socket_.get());
84 bool ssl = (socket == ssl_int_socket_.get() ||
85 socket
102 OnInternalClose(rtc::AsyncPacketSocket* socket, int error) argument
105 OnExternalClose(rtc::AsyncPacketSocket* socket, int error) argument
[all...]
H A Dtestturnserver.h97 // For TCP we need to create a server socket which can listen for incoming
99 rtc::AsyncSocket* socket = local
101 socket->Bind(int_addr);
102 socket->Listen(5);
103 server_.AddInternalServerSocket(socket, proto);
/external/chromium_org/third_party/libjingle/source/talk/xmpp/
H A Dxmppsocket.cc61 rtc::AsyncSocket* socket = local
66 socket = rtc::SSLAdapter::Create(socket);
69 cricket_socket_ = socket;
76 cricket_socket_ = socket;
96 void XmppSocket::OnReadEvent(rtc::AsyncSocket * socket) { argument
100 void XmppSocket::OnWriteEvent(rtc::AsyncSocket * socket) { argument
114 void XmppSocket::OnConnectEvent(rtc::AsyncSocket * socket) { argument
127 void XmppSocket::OnCloseEvent(rtc::AsyncSocket * socket, int error) { argument
/external/chromium_org/third_party/webrtc/base/
H A Dasynchttprequest_unittest.cc41 void OnAccept(AsyncSocket* socket) { argument
H A Dasyncudpsocket.cc19 AsyncSocket* socket,
21 scoped_ptr<AsyncSocket> owned_socket(socket);
22 if (socket->Bind(bind_address) < 0) {
23 LOG(LS_ERROR) << "Bind() failed with error " << socket->GetError();
31 AsyncSocket* socket = local
33 if (!socket)
35 return Create(socket, bind_address);
38 AsyncUDPSocket::AsyncUDPSocket(AsyncSocket* socket) argument
39 : socket_(socket) {
44 // The socket shoul
18 Create( AsyncSocket* socket, const SocketAddress& bind_address) argument
96 OnReadEvent(AsyncSocket* socket) argument
118 OnWriteEvent(AsyncSocket* socket) argument
[all...]
H A Dautodetectproxy.cc59 // Clean up the autodetect socket, from the thread that created it
189 LOG(LS_VERBOSE) << "Unable to create socket for " << proxy_.address;
215 void AutoDetectProxy::OnConnectEvent(AsyncSocket * socket) { argument
242 void AutoDetectProxy::OnReadEvent(AsyncSocket * socket) { argument
276 void AutoDetectProxy::OnCloseEvent(AsyncSocket * socket, int error) { argument
H A Dproxyserver.cc39 void ProxyServer::OnAcceptEvent(AsyncSocket* socket) { argument
40 ASSERT(socket != NULL && socket == server_socket_.get());
41 AsyncSocket* int_socket = socket->Accept(NULL);
49 LOG(LS_ERROR) << "Unable to create external socket on proxy accept event";
77 void ProxyBinding::OnConnectRequest(AsyncProxyServerSocket* socket, argument
84 void ProxyBinding::OnInternalRead(AsyncSocket* socket) { argument
89 void ProxyBinding::OnInternalWrite(AsyncSocket* socket) { argument
93 void ProxyBinding::OnInternalClose(AsyncSocket* socket, int err) { argument
97 void ProxyBinding::OnExternalConnect(AsyncSocket* socket) { argument
103 OnExternalRead(AsyncSocket* socket) argument
108 OnExternalWrite(AsyncSocket* socket) argument
112 OnExternalClose(AsyncSocket* socket, int err) argument
119 Read(AsyncSocket* socket, FifoBuffer* buffer) argument
131 Write(AsyncSocket* socket, FifoBuffer* buffer) argument
[all...]
H A Dsocketpool.cc121 AsyncSocket* socket = local
123 if (!socket) {
128 if ((socket->Connect(remote) != 0) && !socket->IsBlocking()) {
130 *err = socket->GetError();
131 delete socket;
136 return new SocketStream(socket);
159 // Only one socket can be used from this "pool" at a time
162 LOG_F(LS_VERBOSE) << "Creating new socket";
168 AsyncSocket* socket local
[all...]
H A Dtestclient.cc21 TestClient::TestClient(AsyncPacketSocket* socket) argument
22 : socket_(socket), ready_to_send_(false) {
36 // Wait for our timeout value until the socket reaches the desired state.
121 void TestClient::OnPacket(AsyncPacketSocket* socket, const char* buf, argument
128 void TestClient::OnReadyToSend(AsyncPacketSocket* socket) { argument
/external/chromium_org/third_party/webrtc/test/channel_transport/
H A Dudp_transport_unittest.cc19 // We must mock the socket manager, for which we need its definition.
73 MockUdpSocketWrapper* socket = new MockUdpSocketWrapper(); local
74 // We instrument the socket with calls that are expected, but do
76 EXPECT_CALL(*socket, ValidHandle()).WillRepeatedly(Return(true));
77 EXPECT_CALL(*socket, Bind(_)).WillOnce(Return(true));
78 socket_counter_->push_back(socket);
79 return socket;
/external/chromium_org/tools/telemetry/telemetry/core/
H A Dmemory_cache_http_server.py11 import socket namespace
32 except socket.error, e:
/external/chromium_org/tools/telemetry/third_party/pyserial/serial/urlhandler/
H A Dprotocol_socket.py6 # This module implements a simple socket based client.
16 # URL format: socket://<host>:<port>[/option[/option...]]
22 import socket namespace
51 self._socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
70 """Set communication parameters on opened port. for the socket://
82 self._socket.shutdown(socket.SHUT_RDWR)
97 if url.lower().startswith("socket
[all...]
/external/deqp/framework/delibs/decpp/
H A DdeSocket.hpp102 Socket (deSocket* socket) : m_socket(socket) {} argument

Completed in 409 milliseconds

1234567891011>>