Home
last modified time | relevance | path

Searched refs:client_socket (Results 1 – 19 of 19) sorted by relevance

/external/chromium_org/tools/android/forwarder2/
Ddaemon.cc59 scoped_ptr<Socket> client_socket(new Socket()); in RunServerAcceptLoop() local
60 if (!server_socket->Accept(client_socket.get())) { in RunServerAcceptLoop()
67 if (!client_socket->Write(welcome_message.c_str(), in RunServerAcceptLoop()
73 server_delegate->OnClientConnected(client_socket.Pass()); in RunServerAcceptLoop()
178 scoped_ptr<Socket> client_socket = ConnectToUnixDomainSocket( in SpawnIfNeeded() local
180 if (!client_socket) { in SpawnIfNeeded()
201 scoped_ptr<Socket> client_socket = ConnectToUnixDomainSocket( in SpawnIfNeeded() local
203 if (client_socket.get()) { in SpawnIfNeeded()
238 if (!client_socket) { in SpawnIfNeeded()
239 client_socket = ConnectToUnixDomainSocket( in SpawnIfNeeded()
[all …]
Dhost_forwarder_main.cc107 scoped_ptr<Socket> client_socket) { in HandleRequest() argument
115 base::Passed(&client_socket))); in HandleRequest()
161 scoped_ptr<Socket> client_socket) { in HandleRequestOnInternalThread() argument
167 client_socket.get()); in HandleRequestOnInternalThread()
178 client_socket.get()); in HandleRequestOnInternalThread()
184 SendMessage("ERROR: missing host port", client_socket.get()); in HandleRequestOnInternalThread()
195 client_socket.get()); in HandleRequestOnInternalThread()
207 SendMessage("ERROR: Connection to device failed.", client_socket.get()); in HandleRequestOnInternalThread()
215 if (!SendMessage(msg, client_socket.get())) in HandleRequestOnInternalThread()
289 bool SendMessage(const std::string& msg, Socket* client_socket) { in SendMessage() argument
[all …]
Ddevice_forwarder_main.cc80 virtual void OnClientConnected(scoped_ptr<Socket> client_socket) OVERRIDE { in OnClientConnected() argument
82 client_socket->WriteString("OK"); in OnClientConnected()
88 GetExitNotifierFD(), base::Passed(&client_socket))); in OnClientConnected()
93 void StartController(int exit_notifier_fd, scoped_ptr<Socket> client_socket) { in StartController() argument
98 client_socket->WriteString( in StartController()
106 client_socket->WriteString("OK"); in StartController()
107 client_socket->Close(); in StartController()
Ddaemon.h40 virtual void OnClientConnected(scoped_ptr<Socket> client_socket) = 0;
/external/chromium_org/remoting/protocol/
Dchannel_multiplexer_unittest.cc84 FakeSocket* client_socket = in ConnectSockets() local
86 host_socket->PairWith(client_socket); in ConnectSockets()
94 scoped_ptr<net::StreamSocket>* client_socket) { in CreateChannel() argument
101 client_socket, &counter)); in CreateChannel()
106 EXPECT_TRUE(client_socket->get()); in CreateChannel()
146 scoped_ptr<net::StreamSocket> client_socket; in TEST_F() local
148 CreateChannel(kTestChannelName, &host_socket, &client_socket)); in TEST_F()
152 StreamConnectionTester tester(host_socket.get(), client_socket.get(), in TEST_F()
Dconnection_tester.cc17 StreamConnectionTester::StreamConnectionTester(net::StreamSocket* client_socket, in StreamConnectionTester() argument
23 client_socket_(client_socket), in StreamConnectionTester()
130 DatagramConnectionTester::DatagramConnectionTester(net::Socket* client_socket, in DatagramConnectionTester() argument
137 client_socket_(client_socket), in DatagramConnectionTester()
Dconnection_tester.h32 StreamConnectionTester(net::StreamSocket* client_socket,
69 DatagramConnectionTester(net::Socket* client_socket,
/external/chromium_org/ppapi/tests/
Dtest_tcp_server_socket_private.cc163 TCPSocketPrivate client_socket(instance_); in TestListen() local
164 ForceConnect(&client_socket, &address); in TestListen()
167 ASSERT_TRUE(client_socket.GetLocalAddress(&client_local_addr)); in TestListen()
168 ASSERT_TRUE(client_socket.GetRemoteAddress(&client_remote_addr)); in TestListen()
183 ASSERT_SUBTEST_SUCCESS(SyncWrite(&client_socket, in TestListen()
194 client_socket.Disconnect(); in TestListen()
Dtest_tcp_socket.cc208 pp::TCPSocket client_socket; in TestListen() local
211 client_socket = pp::TCPSocket(instance_); in TestListen()
213 callback.WaitForResult(client_socket.Connect( in TestListen()
217 pp::NetAddress client_local_addr = client_socket.GetLocalAddress(); in TestListen()
218 pp::NetAddress client_remote_addr = client_socket.GetRemoteAddress(); in TestListen()
235 ASSERT_SUBTEST_SUCCESS(WriteToSocket(&client_socket, in TestListen()
245 client_socket.Close(); in TestListen()
Dtest_udp_socket_private.cc168 pp::UDPSocketPrivate server_socket(instance_), client_socket(instance_); in TestConnect() local
173 ASSERT_SUBTEST_SUCCESS(LookupPortAndBindUDPSocket(&client_socket, in TestConnect()
176 ASSERT_SUBTEST_SUCCESS(PassMessage(&server_socket, &client_socket, in TestConnect()
185 client_socket.Close(); in TestConnect()
Dtest_udp_socket.cc189 pp::UDPSocket server_socket(instance_), client_socket(instance_); in TestReadWrite() local
194 ASSERT_SUBTEST_SUCCESS(LookupPortAndBindUDPSocket(&client_socket, in TestReadWrite()
198 ASSERT_SUBTEST_SUCCESS(PassMessage(&server_socket, &client_socket, in TestReadWrite()
204 client_socket.Close(); in TestReadWrite()
/external/chromium_org/ipc/
Dunix_domain_socket_util.cc117 int* client_socket) { in CreateClientUnixDomainSocket() argument
118 DCHECK(client_socket); in CreateClientUnixDomainSocket()
136 *client_socket = *scoped_fd.release(); in CreateClientUnixDomainSocket()
Dunix_domain_socket_util.h35 int* client_socket);
/external/chromium_org/chrome/browser/extensions/api/sockets_tcp_server/
Dtcp_server_socket_event_dispatcher.cc126 ResumableTCPSocket *client_socket = in AcceptCallback() local
128 client_socket->set_paused(true); in AcceptCallback()
129 int client_socket_id = params.client_sockets->Add(client_socket); in AcceptCallback()
/external/chromium_org/content/browser/devtools/
Dtethering_handler.cc45 net::StreamSocket* client_socket) in SocketPump() argument
46 : client_socket_(client_socket), in SocketPump()
/external/chromium_org/jingle/glue/
Dpseudotcp_adapter_unittest.cc169 net::Socket* client_socket, in TCPChannelTester() argument
173 client_socket_(client_socket), in TCPChannelTester()
/external/chromium_org/chrome/browser/extensions/api/socket/
Dsocket_api.cc366 Socket *client_socket = new TCPSocket(socket, extension_id(), true); in OnAccept() local
367 result->SetInteger(kSocketIdKey, AddSocket(client_socket)); in OnAccept()
/external/chromium/
DAndroid.mk295 net/socket/client_socket.cc \
/external/chromium/net/
Dnet.gyp606 'socket/client_socket.cc',
607 'socket/client_socket.h',