| /external/chromium_org/tools/android/forwarder2/ |
| H A D | device_forwarder_main.cc | 80 virtual void OnClientConnected(scoped_ptr<Socket> client_socket) OVERRIDE {
82 client_socket->WriteString("OK");
88 GetExitNotifierFD(), base::Passed(&client_socket)));
93 void StartController(int exit_notifier_fd, scoped_ptr<Socket> client_socket) { argument
98 client_socket->WriteString(
106 client_socket->WriteString("OK");
107 client_socket->Close();
|
| H A D | daemon.cc | 59 scoped_ptr<Socket> client_socket(new Socket());
60 if (!server_socket->Accept(client_socket.get())) {
67 if (!client_socket->Write(welcome_message.c_str(),
73 server_delegate->OnClientConnected(client_socket.Pass());
178 scoped_ptr<Socket> client_socket = ConnectToUnixDomainSocket( local
180 if (!client_socket) {
201 scoped_ptr<Socket> client_socket = ConnectToUnixDomainSocket( local
203 if (client_socket.get()) {
238 if (!client_socket) {
239 client_socket
[all...] |
| H A D | host_forwarder_main.cc | 107 scoped_ptr<Socket> client_socket) {
115 base::Passed(&client_socket)));
161 scoped_ptr<Socket> client_socket) {
167 client_socket.get());
178 client_socket.get());
184 SendMessage("ERROR: missing host port", client_socket.get());
195 client_socket.get());
207 SendMessage("ERROR: Connection to device failed.", client_socket.get());
215 if (!SendMessage(msg, client_socket.get()))
289 bool SendMessage(const std::string& msg, Socket* client_socket) { argument
104 HandleRequest(const std::string& device_serial, int device_port, int host_port, scoped_ptr<Socket> client_socket) argument
158 HandleRequestOnInternalThread(const std::string& device_serial, int device_port, int host_port, scoped_ptr<Socket> client_socket) argument
[all...] |
| H A D | daemon.h | 40 virtual void OnClientConnected(scoped_ptr<Socket> client_socket) = 0;
|
| /external/chromium_org/ipc/ |
| H A D | unix_domain_socket_util.h | 32 // successful, |client_socket| will be set to the new file descriptor, and the
35 int* client_socket);
|
| H A D | unix_domain_socket_util.cc | 117 int* client_socket) {
118 DCHECK(client_socket);
136 *client_socket = *scoped_fd.release();
116 CreateClientUnixDomainSocket(const base::FilePath& socket_path, int* client_socket) argument
|
| /external/chromium_org/remoting/protocol/ |
| H A D | connection_tester.h | 32 StreamConnectionTester(net::StreamSocket* client_socket,
69 DatagramConnectionTester(net::Socket* client_socket,
|
| H A D | channel_multiplexer_unittest.cc | 84 FakeSocket* client_socket = local
86 host_socket->PairWith(client_socket);
94 scoped_ptr<net::StreamSocket>* client_socket) {
101 client_socket, &counter));
106 EXPECT_TRUE(client_socket->get());
146 scoped_ptr<net::StreamSocket> client_socket; local
148 CreateChannel(kTestChannelName, &host_socket, &client_socket));
152 StreamConnectionTester tester(host_socket.get(), client_socket.get(),
92 CreateChannel(const std::string& name, scoped_ptr<net::StreamSocket>* host_socket, scoped_ptr<net::StreamSocket>* client_socket) argument
|
| H A D | connection_tester.cc | 17 StreamConnectionTester::StreamConnectionTester(net::StreamSocket* client_socket, argument
23 client_socket_(client_socket),
130 DatagramConnectionTester::DatagramConnectionTester(net::Socket* client_socket, argument
137 client_socket_(client_socket),
|
| /external/chromium_org/ppapi/tests/ |
| H A D | test_tcp_server_socket_private.cc | 163 TCPSocketPrivate client_socket(instance_);
164 ForceConnect(&client_socket, &address);
167 ASSERT_TRUE(client_socket.GetLocalAddress(&client_local_addr));
168 ASSERT_TRUE(client_socket.GetRemoteAddress(&client_remote_addr));
183 ASSERT_SUBTEST_SUCCESS(SyncWrite(&client_socket,
194 client_socket.Disconnect();
|
| H A D | test_udp_socket_private.cc | 168 pp::UDPSocketPrivate server_socket(instance_), client_socket(instance_);
173 ASSERT_SUBTEST_SUCCESS(LookupPortAndBindUDPSocket(&client_socket,
176 ASSERT_SUBTEST_SUCCESS(PassMessage(&server_socket, &client_socket,
185 client_socket.Close();
|
| H A D | test_tcp_socket.cc | 208 pp::TCPSocket client_socket; local
211 client_socket = pp::TCPSocket(instance_);
213 callback.WaitForResult(client_socket.Connect(
217 pp::NetAddress client_local_addr = client_socket.GetLocalAddress();
218 pp::NetAddress client_remote_addr = client_socket.GetRemoteAddress();
235 ASSERT_SUBTEST_SUCCESS(WriteToSocket(&client_socket,
245 client_socket.Close();
|
| H A D | test_udp_socket.cc | 189 pp::UDPSocket server_socket(instance_), client_socket(instance_);
194 ASSERT_SUBTEST_SUCCESS(LookupPortAndBindUDPSocket(&client_socket,
198 ASSERT_SUBTEST_SUCCESS(PassMessage(&server_socket, &client_socket,
204 client_socket.Close();
|
| /external/chromium_org/chrome/browser/extensions/api/sockets_tcp_server/ |
| H A D | tcp_server_socket_event_dispatcher.cc | 126 ResumableTCPSocket *client_socket = local
128 client_socket->set_paused(true);
129 int client_socket_id = params.client_sockets->Add(client_socket);
|
| /external/chromium_org/content/browser/devtools/ |
| H A D | tethering_handler.cc | 45 net::StreamSocket* client_socket)
46 : client_socket_(client_socket),
44 SocketPump(DevToolsHttpHandlerDelegate* delegate, net::StreamSocket* client_socket) argument
|
| /external/chromium_org/jingle/glue/ |
| H A D | pseudotcp_adapter_unittest.cc | 169 net::Socket* client_socket,
173 client_socket_(client_socket),
168 TCPChannelTester(base::MessageLoop* message_loop, net::Socket* client_socket, net::Socket* host_socket) argument
|
| /external/chromium_org/chrome/browser/extensions/api/socket/ |
| H A D | socket_api.cc | 366 Socket *client_socket = new TCPSocket(socket, extension_id(), true); local
367 result->SetInteger(kSocketIdKey, AddSocket(client_socket));
|
| /external/chromium/ |
| H A D | Android.mk | 295 net/socket/client_socket.cc \
|