| /external/grpc-grpc/src/core/lib/iomgr/ |
| D | endpoint_pair_windows.cc | 39 SOCKET cli_sock = INVALID_SOCKET; in create_sockets() local
56 cli_sock = WSASocket(AF_INET, SOCK_STREAM, IPPROTO_TCP, NULL, 0, in create_sockets()
58 GPR_ASSERT(cli_sock != INVALID_SOCKET); in create_sockets()
60 GPR_ASSERT(WSAConnect(cli_sock, (grpc_sockaddr*)&addr, addr_len, NULL, NULL, in create_sockets()
66 grpc_tcp_prepare_socket(cli_sock); in create_sockets()
69 sv[1] = cli_sock; in create_sockets()
|
| /external/rust/crates/grpcio-sys/grpc/src/core/lib/iomgr/ |
| D | endpoint_pair_windows.cc | 39 SOCKET cli_sock = INVALID_SOCKET; in create_sockets() local
56 cli_sock = WSASocket(AF_INET, SOCK_STREAM, IPPROTO_TCP, NULL, 0, in create_sockets()
58 GPR_ASSERT(cli_sock != INVALID_SOCKET); in create_sockets()
60 GPR_ASSERT(WSAConnect(cli_sock, (grpc_sockaddr*)&addr, addr_len, NULL, NULL, in create_sockets()
66 grpc_tcp_prepare_socket(cli_sock); in create_sockets()
69 sv[1] = cli_sock; in create_sockets()
|
| /external/perfetto/src/profiling/memory/ |
| D | client_api_factory_standalone.cc | 81 base::UnixSocketRaw cli_sock; in StartHeapprofdIfStatic() local
83 std::tie(cli_sock, srv_sock) = base::UnixSocketRaw::CreatePairPosix( in StartHeapprofdIfStatic()
86 if (!cli_sock || !srv_sock) { in StartHeapprofdIfStatic()
102 *g_client_sock = std::move(cli_sock); in StartHeapprofdIfStatic()
110 cli_sock.ReleaseFd(); in StartHeapprofdIfStatic()
|
| D | client_api_unittest.cc | 58 base::UnixSocketRaw cli_sock; in ConstructClient() local
60 std::tie(cli_sock, srv_sock) = base::UnixSocketRaw::CreatePairPosix( in ConstructClient()
64 PERFETTO_CHECK(cli_sock); in ConstructClient()
67 return std::allocate_shared<Client>(unhooked_allocator, std::move(cli_sock), in ConstructClient()
|
| D | client_api_benchmark.cc | 56 base::UnixSocketRaw cli_sock; in ConstructClient() local
58 std::tie(cli_sock, srv_sock) = base::UnixSocketRaw::CreatePairPosix( in ConstructClient()
63 PERFETTO_CHECK(cli_sock); in ConstructClient()
66 return std::allocate_shared<Client>(unhooked_allocator, std::move(cli_sock), in ConstructClient()
|
| /external/perfetto/src/trace_processor/rpc/ |
| D | httpd.cc | 329 base::UnixSocket* cli_sock = client->sock.get(); in HandleRequest() local
330 HttpReply(cli_sock, "200 OK", headers, nullptr, kOmitContentLength); in HandleRequest()
338 cli_sock->Send(chunk_hdr, hdr_len); in HandleRequest()
339 cli_sock->Send(buf, len); in HandleRequest()
340 cli_sock->Send("\r\n", 2); in HandleRequest()
343 cli_sock->Send(chunk_hdr, hdr_len); in HandleRequest()
|
| /external/python/cpython3/Lib/test/test_asyncio/ |
| D | test_sendfile.py | 265 cli_sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
266 cli_sock.connect((socket_helper.HOST, port))
270 lambda: cli_proto, sock=cli_sock,
272 self.reduce_send_buffer_size(cli_sock, transport=tr)
|
| /external/perfetto/src/base/ |
| D | unix_socket_unittest.cc | 445 .WillRepeatedly(Invoke([](UnixSocket* cli_sock) { in TEST_F() argument
446 cli_sock->ReceiveString(); // Read connection EOF; in TEST_F()
|
| /external/python/cpython3/Lib/test/ |
| D | test_socket.py | 2645 return self.cli_sock.send(msg)
2656 return self.cli_sock.sendmsg(
2789 def cli_sock(self): member in SendrecvmsgConnectionlessBase
2797 return self.cli_sock.sendto(msg, self.serv_addr)
2811 def cli_sock(self): member in SendrecvmsgConnectedBase
2875 self.assertRaises(TypeError, self.cli_sock.sendmsg)
2943 self.cli_sock.close()
2965 self.cli_sock.settimeout(0.03)
3019 self.assertRaises(OSError, self.cli_sock.sendmsg,
3021 self.assertRaises(OSError, self.cli_sock.sendmsg,
[all …]
|