| /external/chromium_org/tools/android/forwarder2/ |
| 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) {
98 client_socket->WriteString(
106 client_socket->WriteString("OK");
107 client_socket->Close();
|
| daemon.cc | 57 scoped_ptr<Socket> client_socket(new Socket());
58 if (!server_socket->Accept(client_socket.get())) {
65 if (!client_socket->Write(welcome_message.c_str(),
71 server_delegate->OnClientConnected(client_socket.Pass());
176 scoped_ptr<Socket> client_socket = ConnectToUnixDomainSocket( local
178 if (!client_socket) {
199 scoped_ptr<Socket> client_socket = ConnectToUnixDomainSocket( local
201 if (client_socket.get()) {
236 if (!client_socket) {
237 client_socket = ConnectToUnixDomainSocket
[all...] |
| daemon.h | 40 virtual void OnClientConnected(scoped_ptr<Socket> client_socket) = 0;
|
| 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) {
[all...] |
| /external/chromium_org/ipc/ |
| unix_domain_socket_util.h | 32 // successful, |client_socket| will be set to the new file descriptor, and the
35 int* client_socket);
|
| unix_domain_socket_util.cc | 117 int* client_socket) {
118 DCHECK(client_socket);
136 *client_socket = fd.release();
|
| /external/chromium_org/remoting/protocol/ |
| connection_tester.h | 32 StreamConnectionTester(net::StreamSocket* client_socket,
69 DatagramConnectionTester(net::Socket* client_socket,
|
| channel_multiplexer_unittest.cc | 85 FakeSocket* client_socket = local
87 host_socket->PairWith(client_socket);
95 scoped_ptr<net::StreamSocket>* client_socket) {
102 client_socket, &counter));
107 EXPECT_TRUE(client_socket->get());
147 scoped_ptr<net::StreamSocket> client_socket; local
149 CreateChannel(kTestChannelName, &host_socket, &client_socket));
153 StreamConnectionTester tester(host_socket.get(), client_socket.get(),
|
| connection_tester.cc | 17 StreamConnectionTester::StreamConnectionTester(net::StreamSocket* client_socket,
23 client_socket_(client_socket),
130 DatagramConnectionTester::DatagramConnectionTester(net::Socket* client_socket,
137 client_socket_(client_socket),
|
| /device/moto/shamu/camera/QCamera2/stack/mm-camera-test/src/ |
| mm_qcamera_socket.c | 614 int server_socket = -1, client_socket = -1; local
647 if (client_socket > 0) {
648 FD_SET(client_socket, &tsfds);
667 client_socket = accept(server_socket,
669 if (client_socket == -1) {
674 ALOGE("accept a new connect on 55555, sd(%d)\n", client_socket);
675 num_fds = TUNESERVER_MAX(num_fds, client_socket);
694 lib_handle->tsctrl.clientsocket_id = client_socket;
697 close(client_socket);
700 tuneserver_initialize_tuningp(lib_handle, client_socket,
[all...] |
| /external/bluetooth/bluedroid/hci/src/ |
| btsnoop_net.c | 107 int client_socket = accept(listen_socket_, NULL, NULL); local
108 if (client_socket == -1) {
121 client_socket_ = client_socket;
|
| /external/chromium_org/extensions/browser/api/sockets_tcp_server/ |
| tcp_server_socket_event_dispatcher.cc | 125 ResumableTCPSocket* client_socket = local
127 client_socket->set_paused(true);
128 int client_socket_id = params.client_sockets->Add(client_socket);
|
| /external/chromium_org/ppapi/tests/ |
| 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();
|
| 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();
|
| 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();
|
| 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/device/bluetooth/ |
| bluetooth_socket_chromeos_unittest.cc | 342 scoped_refptr<BluetoothSocket> client_socket = last_socket_; local
348 client_socket->Disconnect(
355 client_socket = NULL;
380 client_socket = last_socket_;
386 client_socket->Disconnect(
393 client_socket = NULL;
|
| bluetooth_socket_chromeos.cc | 439 scoped_refptr<BluetoothSocketChromeOS> client_socket = local
446 client_socket->device_address_ = device->GetAddress();
447 client_socket->device_path_ = request->device_path;
448 client_socket->uuid_ = uuid_;
454 client_socket,
460 client_socket,
|
| /external/chromium_org/content/browser/devtools/ |
| tethering_handler.cc | 45 net::StreamSocket* client_socket)
46 : client_socket_(client_socket),
|
| /external/chromium_org/jingle/glue/ |
| pseudotcp_adapter_unittest.cc | 169 net::Socket* client_socket,
173 client_socket_(client_socket),
|
| /external/chromium_org/extensions/browser/api/socket/ |
| socket_api.cc | 355 Socket* client_socket = new TCPSocket(socket, extension_id(), true); local
356 result->SetInteger(kSocketIdKey, AddSocket(client_socket));
|
| /external/compiler-rt/lib/msan/tests/ |
| msan_test.cc | 964 int client_socket = socket(AF_INET, SOCK_DGRAM, 0); local
965 ASSERT_LT(0, client_socket);
972 res = bind(client_socket, (struct sockaddr *)&client_sai, sizeof(client_sai));
976 res = getsockname(client_socket, (struct sockaddr *)&client_sai, &sz);
991 res = sendmsg(client_socket, &msg, 0);
1014 close(client_socket);
[all...] |
