/external/chromium_org/net/socket/ |
unix_domain_client_socket_posix_unittest.cc | 140 UnixDomainClientSocket client_socket(socket_path_, kUseAbstractNamespace); 141 EXPECT_FALSE(client_socket.IsConnected()); 143 EXPECT_EQ(OK, ConnectSynchronously(&client_socket)); 144 EXPECT_TRUE(client_socket.IsConnected()); 167 UnixDomainClientSocket client_socket(socket_path_, kUseAbstractNamespace); 168 EXPECT_FALSE(client_socket.IsConnected()); 170 EXPECT_EQ(OK, ConnectSynchronously(&client_socket)); 171 EXPECT_TRUE(client_socket.IsConnected()); 178 SocketDescriptor client_socket_fd = client_socket.ReleaseConnectedSocket(); 204 UnixDomainClientSocket client_socket(socket_path_, kUseAbstractNamespace) [all...] |
unix_domain_server_socket_posix_unittest.cc | 96 UnixDomainClientSocket client_socket(socket_path_, kUseAbstractNamespace); 97 EXPECT_FALSE(client_socket.IsConnected()); 102 client_socket.Connect(connect_callback.callback())); 109 rv = read_callback.GetResult(client_socket.Read( 114 EXPECT_FALSE(client_socket.IsConnected());
|
/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 | 87 FakeStreamSocket* client_socket = local 90 host_socket->PairWith(client_socket); 98 scoped_ptr<net::StreamSocket>* client_socket) { 105 client_socket, &counter)); 110 EXPECT_TRUE(client_socket->get()); 150 scoped_ptr<net::StreamSocket> client_socket; local 152 CreateChannel(kTestChannelName, &host_socket, &client_socket)); 156 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 | 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/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 | 341 scoped_refptr<BluetoothSocket> client_socket = last_socket_; local 347 client_socket->Disconnect( 354 client_socket = NULL; 379 client_socket = last_socket_; 385 client_socket->Disconnect( 392 client_socket = NULL;
|
bluetooth_socket_chromeos.cc | 446 scoped_refptr<BluetoothSocketChromeOS> client_socket = local 450 client_socket->device_address_ = device->GetAddress(); 451 client_socket->device_path_ = request->device_path; 452 client_socket->uuid_ = uuid_; 458 client_socket, 464 client_socket,
|
/external/chromium_org/content/browser/devtools/ |
tethering_handler.cc | 37 net::StreamSocket* client_socket) 38 : 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 | 366 Socket* client_socket = new TCPSocket(socket, extension_id(), true); local 367 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...] |