| /external/rust/crates/grpcio-sys/grpc/third_party/cares/cares/test/ |
| D | ares-test-mock.cc | 41 ON_CALL(server_, OnRequest("www.google.com", ns_t_a)) in TEST_P()
42 .WillByDefault(SetReplyData(&server_, reply)); in TEST_P()
59 ON_CALL(server_, OnRequest("www.google.com", ns_t_a)) in TEST_P()
60 .WillByDefault(SetReply(&server_, &rsp1)); in TEST_P()
65 ON_CALL(server_, OnRequest("www.example.com", ns_t_a)) in TEST_P()
66 .WillByDefault(SetReply(&server_, &rsp2)); in TEST_P()
98 EXPECT_CALL(server_, OnRequest("www.google.com", ns_t_a)) in TEST_P()
99 .WillOnce(SetReply(&server_, &rsptruncated)) in TEST_P()
100 .WillOnce(SetReply(&server_, &rspok)); in TEST_P()
123 EXPECT_CALL(server_, OnRequest("www.google.com", ns_t_a)) in TEST_P()
[all …]
|
| /external/openscreen/osp/impl/quic/ |
| D | quic_server_unittest.cc | 76 server_ = quic_bridge_->quic_server.get(); in SetUp()
128 QuicServer* server_; member in openscreen::osp::__anon2ca997370111::QuicServerTest
139 server_->Stop(); in TEST_F()
143 EXPECT_FALSE(server_->CreateProtocolConnection(1)); in TEST_F()
149 server_->CreateProtocolConnection(connection1->endpoint_id()); in TEST_F()
153 server_->Stop(); in TEST_F()
157 server_->Stop(); in TEST_F()
159 EXPECT_TRUE(server_->Start()); in TEST_F()
160 EXPECT_FALSE(server_->Start()); in TEST_F()
169 EXPECT_TRUE(server_->Stop()); in TEST_F()
[all …]
|
| /external/pigweed/pw_rpc/ |
| D | server_test.cc | 72 server_(channels_),
74 server_.RegisterService(service_);
91 Server server_; member in pw::rpc::__anon14aa8bb00111::BasicServer
100 server_.ProcessPacket( in TEST_F()
114 server_.ProcessPacket( in TEST_F()
117 server_.ProcessPacket(EncodeRequest(PacketType::REQUEST, 1, 0, 101), in TEST_F()
120 server_.ProcessPacket(EncodeRequest(PacketType::REQUEST, 1, 42, 0), in TEST_F()
129 server_.ProcessPacket( in TEST_F()
137 server_.ProcessPacket(EncodeRequest(PacketType::REQUEST, 1, 0, 101), in TEST_F()
146 server_.ProcessPacket(EncodeRequest(PacketType::REQUEST, 1, 42, 0), in TEST_F()
[all …]
|
| /external/grpc-grpc-java/services/src/generated/main/java/io/grpc/channelz/v1/ |
| D | GetServersResponse.java | 19 server_ = java.util.Collections.emptyList(); in GetServersResponse()
56 server_ = new java.util.ArrayList<io.grpc.channelz.v1.Server>(); in GetServersResponse()
59 server_.add( in GetServersResponse()
77 server_ = java.util.Collections.unmodifiableList(server_); in GetServersResponse()
97 private java.util.List<io.grpc.channelz.v1.Server> server_; field in GetServersResponse
107 return server_; in getServerList()
119 return server_; in getServerOrBuilderList()
130 return server_.size(); in getServerCount()
141 return server_.get(index); in getServer()
153 return server_.get(index); in getServerOrBuilder()
[all …]
|
| /external/webrtc/p2p/base/ |
| D | test_turn_server.h | 59 : server_(thread), thread_(thread) { in server_() function
61 server_.SetExternalSocketFactory(new rtc::BasicPacketSocketFactory(thread), in server_()
63 server_.set_realm(kTestRealm); in server_()
64 server_.set_software(kTestSoftware); in server_()
65 server_.set_auth_hook(this); in server_()
72 server_.set_enable_otu_nonce(enable); in set_enable_otu_nonce()
77 return &server_; in server()
82 server_.set_redirect_hook(redirect_hook); in set_redirect_hook()
87 server_.set_enable_permission_checks(enable); in set_enable_permission_checks()
96 server_.AddInternalSocket(
[all …]
|
| /external/webrtc/rtc_base/ |
| D | firewall_socket_server.cc | 29 : AsyncSocketAdapter(socket), server_(server), type_(type) {} in FirewallSocket()
32 if (!server_->IsBindableIp(addr.ipaddr())) { in Bind()
41 if (!server_->Check(FP_TCP, GetLocalAddress(), addr)) { in Connect()
58 if (!server_->Check(protocol, GetLocalAddress(), addr)) { in SendTo()
80 if (server_->Check(FP_UDP, *paddr, GetLocalAddress())) in RecvFrom()
92 if (!server_->tcp_listen_enabled()) { in Listen()
102 if (server_->Check(FP_TCP, addr, GetLocalAddress())) { in Accept()
117 FirewallSocketServer* server_; member in rtc::FirewallSocket
124 : server_(server), in FirewallSocketServer()
138 if (server_ && should_delete_server_) { in ~FirewallSocketServer()
[all …]
|
| D | virtual_socket_server.cc | 101 : server_(server), in VirtualSocket()
145 int result = server_->Bind(this, &local_addr_); in Bind()
154 server_->msg_queue_->Post(RTC_FROM_HERE, this, MSG_ID_ADDRESS_BOUND); in Bind()
166 server_->Unbind(local_addr_, this); in Close()
177 server_->Disconnect(server_->LookupBinding(addr)); in Close()
187 server_->LookupConnection(local_addr_, remote_addr_); in Close()
193 socket = server_->LookupBinding(remote_addr_); in Close()
195 server_->Disconnect(socket); in Close()
198 server_->RemoveConnection(remote_addr_, local_addr_); in Close()
199 server_->RemoveConnection(local_addr_, remote_addr_); in Close()
[all …]
|
| D | physical_socket_server_unittest.cc | 118 : server_(new FakePhysicalSocketServer(this)), in PhysicalSocketTest()
119 thread_(server_.get()), in PhysicalSocketTest()
126 std::unique_ptr<FakePhysicalSocketServer> server_; member in rtc::PhysicalSocketTest
202 server_->CreateAsyncSocket(loopback.family(), SOCK_STREAM)); in ConnectInternalAcceptError()
208 server_->CreateAsyncSocket(loopback.family(), SOCK_STREAM)); in ConnectInternalAcceptError()
215 server_->CreateAsyncSocket(loopback.family(), SOCK_STREAM)); in ConnectInternalAcceptError()
470 server_->set_network_binder(&fake_network_binder); in TEST_F()
472 server_->CreateAsyncSocket(AF_INET, SOCK_DGRAM)); in TEST_F()
475 server_->set_network_binder(nullptr); in TEST_F()
482 server_->set_network_binder(&fake_network_binder); in TEST_F()
[all …]
|
| D | firewall_socket_server.h | 39 SocketServer* socketserver() const { return server_; } in socketserver()
41 if (server_ && should_delete_server_) { in set_socketserver()
42 delete server_; in set_socketserver() local
43 server_ = nullptr; in set_socketserver()
46 server_ = server; in set_socketserver()
91 SocketServer* server_;
|
| /external/rust/crates/grpcio-sys/grpc/src/cpp/server/ |
| D | server_cc.cc | 121 : server_(server), in BaseAsyncRequest()
156 call_, server_, call_cq_, server_->max_receive_message_size(), nullptr); in FinalizeResult()
216 server_->server(), registered_method, &call_, in IssueRequest()
256 call_, server_, call_cq_, server_->max_receive_message_size(), in FinalizeResult()
260 *server_->interceptor_creators())); in FinalizeResult()
432 server_(server), in CallData()
464 : server_->resource_exhausted_handler_.get(); in Run()
488 : server_->resource_exhausted_handler_.get(); in ContinueRunAfterInterception()
515 Server* server_; member in grpc::Server::SyncRequest::CallData
548 : server_(server), in CallbackRequest()
[all …]
|
| /external/grpc-grpc/src/cpp/server/ |
| D | server_cc.cc | 107 server_(server), in UnimplementedAsyncRequest()
116 Server* const server_; member in grpc::Server::UnimplementedAsyncRequest
217 server_(server) { in CallData()
236 : server_->resource_exhausted_handler_.get(); in Run()
259 Server* server_; member in grpc::Server::SyncRequest::CallData
285 server_(server), in SyncRequestThreadManager()
322 SyncRequest::CallData cd(server_, sync_req); in DoWork()
326 sync_req->Request(server_->c_server(), server_cq_->cq()); in DoWork()
370 (*m)->Request(server_->c_server(), server_cq_->cq()); in Start()
378 Server* server_; member in grpc::Server::SyncRequestThreadManager
[all …]
|
| /external/pigweed/pw_rpc/public/pw_rpc/internal/ |
| D | call.h | 41 : server_(nullptr), in ServerCall()
50 : server_(&server), in ServerCall()
62 PW_DCHECK_NOTNULL(server_); in server()
63 return *server_; in server()
82 Server* server_;
|
| /external/grpc-grpc/src/core/lib/iomgr/ |
| D | udp_server.cc | 118 grpc_udp_server* server_; member in GrpcUdpListener
147 server_(server), in GrpcUdpListener()
299 GRPC_CLOSURE_INIT(&destroyed_closure_, destroyed_port, server_, in OrphanFd()
332 GRPC_CLOSURE_INIT(&destroyed_closure_, destroyed_port, server_, in OnFdAboutToOrphan()
340 udp_handler_->OnFdAboutToOrphan(&orphan_fd_closure_, server_->user_data); in OnFdAboutToOrphan()
469 gpr_mu_lock(&server_->mu); in OnRead()
470 if (0 == --server_->active_ports && server_->shutdown) { in OnRead()
471 gpr_mu_unlock(&server_->mu); in OnRead()
472 deactivated_all_ports(server_); in OnRead()
474 gpr_mu_unlock(&server_->mu); in OnRead()
[all …]
|
| /external/rust/crates/grpcio-sys/grpc/src/core/lib/iomgr/ |
| D | udp_server.cc | 123 grpc_udp_server* server_; member in GrpcUdpListener
152 server_(server), in GrpcUdpListener()
300 GRPC_CLOSURE_INIT(&destroyed_closure_, destroyed_port, server_, in OrphanFd()
333 GRPC_CLOSURE_INIT(&destroyed_closure_, destroyed_port, server_, in OnFdAboutToOrphan()
341 udp_handler_->OnFdAboutToOrphan(&orphan_fd_closure_, server_->user_data); in OnFdAboutToOrphan()
470 gpr_mu_lock(&server_->mu); in OnRead()
471 if (0 == --server_->active_ports && server_->shutdown) { in OnRead()
472 gpr_mu_unlock(&server_->mu); in OnRead()
473 deactivated_all_ports(server_); in OnRead()
475 gpr_mu_unlock(&server_->mu); in OnRead()
[all …]
|
| /external/grpc-grpc/include/grpcpp/impl/ |
| D | server_initializer.h | 34 ServerInitializer(Server* server) : server_(server) {} in ServerInitializer()
37 if (!server_->RegisterService(nullptr, service.get())) { in RegisterService()
45 return &server_->services_; in GetServiceList()
49 Server* server_;
|
| /external/rust/crates/grpcio-sys/grpc/spm-cpp-include/grpcpp/impl/ |
| D | server_initializer.h | 33 explicit ServerInitializer(grpc::Server* server) : server_(server) {} in ServerInitializer()
36 if (!server_->RegisterService(nullptr, service.get())) { in RegisterService()
44 return &server_->services_; in GetServiceList()
48 grpc::Server* server_;
|
| /external/tensorflow/tensorflow/core/profiler/rpc/ |
| D | profiler_server.cc | 41 server_ = builder.BuildAndStart(); in StartProfilerServer()
52 if (server_) { in ~ProfilerServer()
53 server_->Shutdown(); in ~ProfilerServer()
54 server_->Wait(); in ~ProfilerServer()
|
| /external/rust/crates/grpcio-sys/grpc/include/grpcpp/impl/ |
| D | server_initializer.h | 33 explicit ServerInitializer(grpc::Server* server) : server_(server) {} in ServerInitializer()
36 if (!server_->RegisterService(nullptr, service.get())) { in RegisterService()
44 return &server_->services_; in GetServiceList()
48 grpc::Server* server_;
|
| /external/grpc-grpc/test/cpp/microbenchmarks/ |
| D | fullstack_fixtures.h | 85 server_ = b.BuildAndStart(); in FullstackFixture()
92 channel_ = server_->InProcessChannel(args); in FullstackFixture()
100 grpc_server_shutdown_and_notify(server_->c_server(), cq_->cq(), in ~FullstackFixture()
120 std::unique_ptr<Server> server_;
182 server_ = b.BuildAndStart(); in EndpointPairFixture()
190 grpc_server_get_channel_args(server_->c_server()); in EndpointPairFixture()
196 grpc_server_get_pollsets(server_->c_server(), &pollsets, &num_pollsets); in EndpointPairFixture()
202 grpc_server_setup_transport(server_->c_server(), server_transport_, in EndpointPairFixture()
229 grpc_server_shutdown_and_notify(server_->c_server(), cq_->cq(), in ~EndpointPairFixture()
254 std::unique_ptr<Server> server_;
|
| D | bm_opencensus_plugin.cc | 59 server_ = builder.BuildAndStart(); in EchoServerThread()
60 if (server_ == nullptr || port == 0) { in EchoServerThread()
68 server_->Shutdown(); in ~EchoServerThread()
75 void RunServerLoop() { server_->Wait(); } in RunServerLoop()
79 std::unique_ptr<grpc::Server> server_; member in EchoServerThread
|
| /external/grpc-grpc/test/cpp/end2end/ |
| D | health_service_end2end_test.cc | 149 server_ = builder.BuildAndStart(); in SetUpServer()
153 if (server_) { in TearDown()
154 server_->Shutdown(); in TearDown()
193 HealthCheckServiceInterface* service = server_->GetHealthCheckService(); in VerifyHealthCheckService()
225 std::unique_ptr<Server> server_; member in grpc::testing::__anon93a36ff40111::HealthServiceEnd2endTest
235 server_->GetHealthCheckService(); in TEST_F()
263 server_->GetHealthCheckService(); in TEST_F()
277 HealthCheckServiceInterface* service = server_->GetHealthCheckService(); in TEST_F()
293 HealthCheckServiceInterface* service = server_->GetHealthCheckService(); in TEST_F()
|
| /external/rust/crates/grpcio-sys/grpc/include/grpcpp/ |
| D | server.h | 114 explicit experimental_type(Server* server) : server_(server) {} in experimental_type()
125 Server* server_;
197 grpc_server* server() override { return server_; } in server()
251 explicit experimental_registration_type(Server* server) : server_(server) {} in experimental_registration_type()
254 server_->RegisterCallbackGenericService(service); in RegisterCallbackGenericService()
258 Server* server_;
341 grpc_server* server_; variable
|
| /external/rust/crates/grpcio-sys/grpc/spm-cpp-include/grpcpp/ |
| D | server.h | 114 explicit experimental_type(Server* server) : server_(server) {} in experimental_type()
125 Server* server_;
197 grpc_server* server() override { return server_; } in server()
251 explicit experimental_registration_type(Server* server) : server_(server) {} in experimental_registration_type()
254 server_->RegisterCallbackGenericService(service); in RegisterCallbackGenericService()
258 Server* server_;
341 grpc_server* server_; variable
|
| /external/grpc-grpc/test/core/transport/chttp2/ |
| D | settings_timeout_test.cc | 57 server_ = grpc_server_create(&args, nullptr); in Start()
58 ASSERT_TRUE(grpc_server_add_insecure_http2_port(server_, address_)); in Start()
60 grpc_server_register_completion_queue(server_, cq_, nullptr); in Start()
61 grpc_server_start(server_); in Start()
68 grpc_server_shutdown_and_notify(server_, shutdown_cq, nullptr); in Shutdown()
74 grpc_server_destroy(server_); in Shutdown()
88 grpc_server* server_ = nullptr; member in grpc_core::test::__anon93793cbd0111::ServerThread
|
| /external/grpc-grpc/include/grpcpp/impl/codegen/ |
| D | service_type.h | 60 Service() : server_(nullptr) {} in Service()
100 server_->RequestAsyncCall(methods_[idx].get(), context, stream, call_cq, in RequestAsyncUnary()
108 server_->RequestAsyncCall(methods_[idx].get(), context, stream, call_cq, in RequestAsyncClientStreaming()
117 server_->RequestAsyncCall(methods_[idx].get(), context, stream, call_cq, in RequestAsyncServerStreaming()
125 server_->RequestAsyncCall(methods_[idx].get(), context, stream, call_cq, in RequestAsyncBidiStreaming()
185 ServerInterface* server_; variable
|