| /external/pigweed/pw_stream/ |
| D | socket_stream_test.cc | 29 EXPECT_EQ(server.Listen(), OkStatus()); in RunConnectTest()
60 EXPECT_EQ(initial_server.Listen(), OkStatus()); in TEST()
65 EXPECT_EQ(server.Listen(port), OkStatus()); in TEST()
124 EXPECT_EQ(server.Listen(), OkStatus()); in TEST()
141 EXPECT_EQ(server.Listen(), OkStatus()); in TEST()
175 EXPECT_EQ(server.Listen(0), OkStatus()); in TEST()
190 EXPECT_EQ(server2.Listen(server_port), OkStatus()); in TEST()
|
| /external/tensorflow/tensorflow/compiler/jit/ |
| D | xla_activity_listener.h | 49 virtual Status Listen(
53 virtual Status Listen(
57 virtual Status Listen(const XlaOptimizationRemark& optimization_remark) = 0;
|
| D | xla_activity_logging_listener.cc | 27 Status Listen( in Listen() function in tensorflow::__anon21f0856a0111::XlaActivityLoggingListener
45 Status Listen( in Listen() function in tensorflow::__anon21f0856a0111::XlaActivityLoggingListener
63 Status Listen(const XlaOptimizationRemark& optimization_remark) override { in Listen() function in tensorflow::__anon21f0856a0111::XlaActivityLoggingListener
|
| D | xla_activity_listener.cc | 66 return listener->Listen(auto_clustering_activity); in BroadcastXlaActivity()
73 return listener->Listen(jit_compilation_activity); in BroadcastXlaActivity()
80 return listener->Listen(optimization_remark); in BroadcastOptimizationRemark()
|
| D | xla_activity_listener_test.cc | 34 Status Listen( in Listen() function in tensorflow::__anon0de518e30111::TestListener
40 Status Listen( in Listen() function in tensorflow::__anon0de518e30111::TestListener
46 Status Listen(const XlaOptimizationRemark& optimization_remark) override { in Listen() function in tensorflow::__anon0de518e30111::TestListener
|
| /external/tensorflow/tensorflow/compiler/jit/tests/ |
| D | xla_compilation_cache_test_helper.h | 32 Status Listen( in Listen() function
37 Status Listen( in Listen() function
44 Status Listen(const XlaOptimizationRemark& optimization_remark) override { in Listen() function
|
| /external/pigweed/pw_log_rpc/ |
| D | rpc_log_drain_test.cc | 136 rpc::RawServerWriter::Open<log::pw_rpc::raw::Logs::Listen>( in TEST()
169 rpc::RawServerWriter::Open<log::pw_rpc::raw::Logs::Listen>( in TEST()
175 rpc::RawServerWriter::Open<log::pw_rpc::raw::Logs::Listen>( in TEST()
215 writer_ = rpc::RawServerWriter::Open<log::pw_rpc::raw::Logs::Listen>( in OpenWriter()
301 output_.payloads<log::pw_rpc::raw::Logs::Listen>(kDrainChannelId); in TEST_F()
339 output_.payloads<log::pw_rpc::raw::Logs::Listen>(kDrainChannelId); in TEST_F()
389 output_.payloads<log::pw_rpc::raw::Logs::Listen>(kDrainChannelId); in TEST_F()
406 output_.payloads<log::pw_rpc::raw::Logs::Listen>(kDrainChannelId); in TEST_F()
437 rpc::RawServerWriter::Open<log::pw_rpc::raw::Logs::Listen>( in TEST()
453 writer = rpc::RawServerWriter::Open<log::pw_rpc::raw::Logs::Listen>( in TEST()
|
| D | log_service_test.cc | 47 PW_RAW_TEST_METHOD_CONTEXT(LogService, Listen, 10)
551 rpc::RawServerWriter writer = rpc::RawServerWriter::Open<Logs::Listen>( in TEST_F()
559 ASSERT_EQ(output.payloads<Logs::Listen>().size(), successful_packets_sent); in TEST_F()
572 for (auto& response : output.payloads<Logs::Listen>()) { in TEST_F()
589 writer = rpc::RawServerWriter::Open<Logs::Listen>( in TEST_F()
614 for (auto& response : output.payloads<Logs::Listen>()) { in TEST_F()
663 rpc::RawServerWriter writer = rpc::RawServerWriter::Open<Logs::Listen>( in TEST_F()
671 ASSERT_GT(output.payloads<Logs::Listen>().size(), 0u); in TEST_F()
675 for (auto& response : output.payloads<Logs::Listen>()) { in TEST_F()
696 protobuf::Decoder entry_decoder(output.payloads<Logs::Listen>()[i]); in TEST_F()
[all …]
|
| /external/openscreen/platform/impl/ |
| D | stream_socket.h | 51 virtual Error Listen() = 0;
52 virtual Error Listen(int max_backlog_size) = 0;
|
| D | stream_socket_posix.h | 45 Error Listen() override;
46 Error Listen(int max_backlog_size) override;
|
| D | stream_socket_posix.cc | 172 Error StreamSocketPosix::Listen() { in Listen() function in openscreen::StreamSocketPosix
173 return Listen(kDefaultMaxBacklogSize); in Listen()
176 Error StreamSocketPosix::Listen(int max_backlog_size) { in Listen() function in openscreen::StreamSocketPosix
|
| /external/perfetto/src/base/ |
| D | unix_socket_unittest.cc | 105 UnixSocket::Listen(kTestSocket.name(), &event_listener_, &task_runner_, in TEST_F()
143 UnixSocket::Listen(kTestSocket.name(), &event_listener_, &task_runner_, in TEST_F()
209 auto srv = UnixSocket::Listen(std::move(fd), &event_listener_, &task_runner_, in TEST_F()
243 UnixSocket::Listen(kTestSocket.name(), &event_listener_, &task_runner_, in TEST_F()
285 UnixSocket::Listen(kTestSocket.name(), &event_listener_, &task_runner_, in TEST_F()
341 UnixSocket::Listen(kTestSocket.name(), &event_listener_, &task_runner_, in TEST_F()
388 UnixSocket::Listen(kTestSocket.name(), &event_listener_, &task_runner_, in TEST_F()
435 srv = UnixSocket::Listen(host_and_port, &event_listener_, &task_runner_, in TEST_F()
485 UnixSocket::Listen(kTestSocket.name(), &event_listener_, &task_runner_, in TEST_F()
519 UnixSocket::Listen(kTestSocket.name(), &event_listener_, &task_runner_, in TEST_F()
[all …]
|
| /external/libcap/goapps/web/ |
| D | web.go | 62 return net.Listen(network, address)
84 return net.Listen(network, address)
|
| /external/oss-fuzz/projects/grpc-go/ |
| D | fuzz_hello.go | 27 lis, err := net.Listen("tcp", ":50051")
65 lis, err := net.Listen("tcp", ":50051")
|
| /external/webrtc/rtc_base/ |
| D | async_socket.cc | 65 int AsyncSocketAdapter::Listen(int backlog) { in Listen() function in rtc::AsyncSocketAdapter
66 return socket_->Listen(backlog); in Listen()
|
| D | socket_unittest.cc | 261 EXPECT_EQ(0, server->Listen(5)); in ConnectInternal()
314 EXPECT_EQ(0, server->Listen(5)); in ConnectWithDnsLookupInternal()
426 EXPECT_EQ(0, server->Listen(5)); in ConnectWithClosedSocketInternal()
446 EXPECT_EQ(0, server->Listen(5)); in ConnectWhileNotClosedInternal()
494 EXPECT_EQ(0, server->Listen(5)); in ServerCloseDuringConnectInternal()
523 EXPECT_EQ(0, server->Listen(5)); in ClientCloseDuringConnectInternal()
561 EXPECT_EQ(0, server->Listen(5)); in ServerCloseInternal()
636 EXPECT_EQ(0, server->Listen(5)); in CloseInClosedCallbackInternal()
715 EXPECT_EQ(0, server->Listen(5)); in SocketServerWaitInternal()
767 EXPECT_EQ(0, server->Listen(5)); in TcpInternal()
[all …]
|
| /external/cronet/net/third_party/quiche/src/quiche/quic/core/io/ |
| D | socket_test.cc | 123 TEST(SocketTest, Listen) { in TEST() argument
129 EXPECT_TRUE(socket_api::Listen(socket, /*backlog=*/5).ok()); in TEST()
141 ASSERT_TRUE(socket_api::Listen(socket, /*backlog=*/5).ok()); in TEST()
|
| /external/perfetto/include/perfetto/ext/base/ |
| D | unix_socket.h | 113 bool Listen();
270 static std::unique_ptr<UnixSocket> Listen(const std::string& socket_name,
278 static std::unique_ptr<UnixSocket> Listen(ScopedSocketHandle,
|
| /external/cronet/net/socket/ |
| D | tcp_server_socket.cc | 35 int TCPServerSocket::Listen(const IPEndPoint& address, in Listen() function in net::TCPServerSocket
63 result = socket_->Listen(backlog); in Listen()
|
| D | udp_socket_unittest.cc | 188 ASSERT_THAT(server->Listen(server_address), IsOk()); in ConnectTest()
311 ASSERT_THAT(server_socket.Listen(IPEndPoint(IPAddress::IPv4Localhost(), 0)), in TEST_F()
372 EXPECT_THAT(server1->Listen(listen_address), IsOk()); in TEST_F()
375 EXPECT_THAT(server2->Listen(listen_address), IsOk()); in TEST_F()
525 ASSERT_THAT(server1.Listen(server1_address), IsOk()); in TEST_F()
532 ASSERT_THAT(server2.Listen(server2_address), IsOk()); in TEST_F()
622 int rv = server.Listen(bind_address); in TEST_F()
637 int rv = server.Listen(bind_address); in TEST_F()
679 int rv = server.Listen(bind_address); in TEST_F()
706 int rv = server.Listen(bind_address); in TEST_F()
[all …]
|
| D | unix_domain_server_socket_posix.cc | 53 int UnixDomainServerSocket::Listen(const IPEndPoint& address, in Listen() function in net::UnixDomainServerSocket
92 rv = socket->Listen(backlog); in BindAndListen()
|
| D | tcp_client_socket_unittest.cc | 76 ASSERT_THAT(server_socket->Listen(IPEndPoint(local_address, 0), 1, in CreateConnectedSockets()
120 ASSERT_THAT(server.Listen(IPEndPoint(lo_address, 0), 1, in TEST_F()
175 server.Listen(IPEndPoint(IPAddress::IPv6Localhost(), 0), 1, in TEST_F()
200 server.Listen(IPEndPoint(lo_address, 0), 1, /*ipv6_only=*/absl::nullopt), in TEST_F()
250 server.Listen(IPEndPoint(lo_address, 0), 1, /*ipv6_only=*/absl::nullopt), in TEST_F()
512 server.Listen(IPEndPoint(lo_address, 0), 1, /*ipv6_only=*/absl::nullopt), in TEST_F()
552 server.Listen(IPEndPoint(lo_address, 0), 1, /*ipv6_only=*/absl::nullopt), in TEST_F()
578 ASSERT_THAT(server.Listen(IPEndPoint(IPAddress(0, 0, 0, 0), 0), 1, in TEST_F()
|
| /external/cronet/net/tools/quic/ |
| D | quic_simple_server.cc | 99 return Listen(ToIPEndPoint(address)); in CreateUDPSocketAndListen()
106 bool QuicSimpleServer::Listen(const IPEndPoint& address) { in Listen() function in net::QuicSimpleServer
|
| /external/pigweed/pw_web/webconsole/common/ |
| D | logService.ts | 20 const call = device.rpcs.pw.log.Logs.Listen((msg: any) => {
|
| /external/pigweed/pw_log_rpc/public/pw_log_rpc/ |
| D | log_service.h | 35 void Listen(ConstByteSpan, rpc::RawServerWriter& writer);
|