| /third_party/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 …]
|
| /third_party/mindspore/tests/ut/cpp/ps/core/ |
| D | tcp_pb_server_test.cc | 29 TestTcpServer() : client_(nullptr), server_(nullptr) {} in TestTcpServer()
34 server_ = std::make_unique<TcpServer>("127.0.0.1", 0, config.get()); in SetUp()
37 …server_->SetMessageCallback([=](std::shared_ptr<TcpConnection> conn, std::shared_ptr<MessageMeta> … in SetUp()
42 server_->SendMessage(conn, meta, protos, data, size); in SetUp()
44 server_->Init(); in SetUp()
45 server_->Start(); in SetUp()
54 server_->Stop(); in TearDown()
58 std::unique_ptr<TcpServer> server_; member in mindspore::ps::core::TestTcpServer
63 client_ = std::make_unique<TcpClient>("127.0.0.1", server_->BoundPort(), config.get()); in TEST_F()
64 std::cout << server_->BoundPort() << std::endl; in TEST_F()
|
| /third_party/nghttp2/src/ |
| D | asio_server_http2_impl.cc | 49 server_.reset( in listen_and_serve()
51 return server_->listen_and_serve(ec, tls_context, address, port, backlog_, in listen_and_serve()
72 void http2_impl::stop() { return server_->stop(); } in stop()
74 void http2_impl::join() { return server_->join(); } in join()
78 return server_->io_services(); in io_services()
81 std::vector<int> http2_impl::ports() const { return server_->ports(); } in ports()
|
| /third_party/cef/libcef/browser/ |
| D | server_impl.cc | 198 return !!server_.get(); in IsRunning()
243 server_->Send404(connection_id, MISSING_TRAFFIC_ANNOTATION); in SendHttp404Response()
244 server_->Close(connection_id); in SendHttp404Response()
268 server_->Send500(connection_id, error_message, MISSING_TRAFFIC_ANNOTATION); in SendHttp500Response()
269 server_->Close(connection_id); in SendHttp500Response()
311 server_->SendResponse(connection_id, response, MISSING_TRAFFIC_ANNOTATION); in SendHttpResponse()
313 server_->Close(connection_id); in SendHttpResponse()
333 server_->Close(connection_id); in CloseConnection()
372 server_->AcceptWebSocket(connection_id, request_info, in ContinueWebSocketRequest()
376 server_->Close(connection_id); in ContinueWebSocketRequest()
[all …]
|
| /third_party/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 …]
|
| /third_party/grpc/include/grpcpp/impl/ |
| D | server_initializer_impl.h | 36 ServerInitializer(grpc::Server* server) : server_(server) {} in ServerInitializer()
39 if (!server_->RegisterService(nullptr, service.get())) { in RegisterService()
47 return &server_->services_; in GetServiceList()
51 grpc::Server* server_;
|
| 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_;
|
| /third_party/grpc/test/cpp/microbenchmarks/ |
| D | fullstack_fixtures.h | 76 server_ = b.BuildAndStart(); in FullstackFixture()
83 channel_ = server_->InProcessChannel(args); in FullstackFixture()
88 server_->Shutdown(); in ~FullstackFixture()
107 std::unique_ptr<Server> server_;
169 server_ = b.BuildAndStart(); in EndpointPairFixture()
177 grpc_server_get_channel_args(server_->c_server()); in EndpointPairFixture()
182 grpc_server_get_pollsets(server_->c_server())) { in EndpointPairFixture()
186 grpc_server_setup_transport(server_->c_server(), server_transport_, in EndpointPairFixture()
213 server_->Shutdown(); in ~EndpointPairFixture()
237 std::unique_ptr<Server> server_;
|
| D | bm_opencensus_plugin.cc | 61 server_ = builder.BuildAndStart(); in EchoServerThread()
62 if (server_ == nullptr || port == 0) { in EchoServerThread()
70 server_->Shutdown(); in ~EchoServerThread()
77 void RunServerLoop() { server_->Wait(); } in RunServerLoop()
81 std::unique_ptr<grpc::Server> server_; member in EchoServerThread
|
| /third_party/grpc/test/cpp/end2end/ |
| D | health_service_end2end_test.cc | 111 server_ = builder.BuildAndStart(); in SetUpServer()
115 if (server_) { in TearDown()
116 server_->Shutdown(); in TearDown()
155 HealthCheckServiceInterface* service = server_->GetHealthCheckService(); in VerifyHealthCheckService()
185 HealthCheckServiceInterface* service = server_->GetHealthCheckService(); in VerifyHealthCheckServiceStreaming()
218 HealthCheckServiceInterface* service = server_->GetHealthCheckService(); in VerifyHealthCheckServiceShutdown()
282 std::unique_ptr<Server> server_; member in grpc::testing::__anonb22131250111::HealthServiceEnd2endTest
292 server_->GetHealthCheckService(); in TEST_F()
326 HealthCheckServiceInterface* service = server_->GetHealthCheckService(); in TEST_F()
342 HealthCheckServiceInterface* service = server_->GetHealthCheckService(); in TEST_F()
[all …]
|
| D | exception_test.cc | 69 server_ = builder.BuildAndStart(); in SetUp()
72 void TearDown() override { server_->Shutdown(); } in TearDown()
75 channel_ = server_->InProcessChannel(ChannelArguments()); in ResetStub()
81 std::unique_ptr<Server> server_; member in grpc::testing::ExceptionTest
|
| D | client_crash_test.cc | 57 server_.reset(new SubProcess({ in CreateServerAndStub()
61 GPR_ASSERT(server_); in CreateServerAndStub()
66 void KillServer() { server_.reset(); } in KillServer()
69 std::unique_ptr<SubProcess> server_; member in grpc::testing::__anon0907edaf0111::CrashTest
|
| D | delegating_channel_test.cc | 64 server_ = builder.BuildAndStart(); in DelegatingChannelTest()
67 ~DelegatingChannelTest() { server_->Shutdown(); } in ~DelegatingChannelTest()
71 std::unique_ptr<Server> server_; member in grpc::testing::__anon9cb25b6c0111::DelegatingChannelTest
|
| /third_party/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()
259 explicit experimental_registration_type(Server* server) : server_(server) {} in experimental_registration_type()
262 server_->RegisterCallbackGenericService(service); in RegisterCallbackGenericService()
267 server_->context_allocator_ = std::move(context_allocator); in RegisterContextAllocator()
271 Server* server_;
354 grpc_server* server_; variable
|
| D | server_impl.h | 119 explicit experimental_type(Server* server) : server_(server) {} in experimental_type()
130 Server* server_;
203 grpc_server* server() override { return server_; } in server()
259 explicit experimental_registration_type(Server* server) : server_(server) {} in experimental_registration_type()
262 server_->RegisterCallbackGenericService(service); in RegisterCallbackGenericService()
266 Server* server_;
350 grpc_server* server_; variable
|
| /third_party/mindspore/mindspore/ccsrc/minddata/dataset/engine/gnn/ |
| D | grpc_async_server.cc | 39 server_ = builder.BuildAndStart(); in Run()
40 if (server_) { in Run()
72 if (server_) { in Stop()
73 server_->Shutdown(); in Stop()
|
| /third_party/grpc/test/core/transport/chttp2/ |
| D | settings_timeout_test.cc | 59 server_ = grpc_server_create(&args, nullptr); in Start()
60 ASSERT_TRUE(grpc_server_add_insecure_http2_port(server_, address_)); in Start()
62 grpc_server_register_completion_queue(server_, cq_, nullptr); in Start()
63 grpc_server_start(server_); in Start()
70 grpc_server_shutdown_and_notify(server_, shutdown_cq, nullptr); in Shutdown()
76 grpc_server_destroy(server_); in Shutdown()
90 grpc_server* server_ = nullptr; member in grpc_core::test::__anon50662e6e0111::ServerThread
|
| /third_party/grpc/src/core/lib/surface/ |
| D | server.cc | 197 : server_(server), requests_per_cq_(server->cqs_.size()) {} in RealRequestMatcher()
219 server_->FailCall(i, rc, GRPC_ERROR_REF(error)); in KillRequests()
241 MutexLock lock(&server_->mu_call_); in RequestCallWithPossiblePublish()
289 MutexLock lock(&server_->mu_call_); in MatchOrQueue()
309 Server* server() const override { return server_; } in server()
312 Server* const server_; member in grpc_core::Server::RealRequestMatcher
325 : server_(server), cq_(cq) { in AllocatingRequestMatcherBase()
347 Server* server() const override { return server_; } in server()
356 Server* const server_; member in grpc_core::Server::AllocatingRequestMatcherBase
973 MutexLock lock(&chand_->server_->mu_global_); in OnConnectivityStateChange()
[all …]
|
| /third_party/cef/tests/cefclient/browser/ |
| D | server_test.cc | 53 DCHECK(!server_); in StartServer()
63 DCHECK(server_); in StopServer()
65 server_->Shutdown(); in StopServer()
71 DCHECK(!server_); in OnServerCreated()
72 server_ = server; in OnServerCreated()
77 DCHECK(server_); in OnServerDestroyed()
78 server_ = nullptr; in OnServerDestroyed()
200 CefRefPtr<CefServer> server_; member in client::server_test::__anone6b9c63a0111::ServerHandler
|
| /third_party/grpc/test/cpp/performance/ |
| D | writes_per_rpc_test.cc | 67 server_ = b.BuildAndStart(); in EndpointPairFixture()
74 grpc_server_get_channel_args(server_->c_server()); in EndpointPairFixture()
79 grpc_server_get_pollsets(server_->c_server())) { in EndpointPairFixture()
83 grpc_server_setup_transport(server_->c_server(), transport, nullptr, in EndpointPairFixture()
110 server_->Shutdown(); in ~EndpointPairFixture()
122 std::unique_ptr<Server> server_; member in grpc::testing::EndpointPairFixture
|
| /third_party/mindspore/tests/st/ps/cmp_sparse_embedding/ |
| D | shell_run_test.sh | 38 rm -rf ${execute_path}/server_$i/
39 mkdir ${execute_path}/server_$i/
40 cd ${execute_path}/server_$i/ || exit
|
| /third_party/grpc/test/core/tsi/alts/handshaker/ |
| D | alts_concurrent_connectivity_test.cc | 122 server_ = builder.BuildAndStart(); in FakeHandshakeServer()
128 server_->Shutdown(grpc_timeout_milliseconds_to_deadline(0)); in ~FakeHandshakeServer()
136 std::unique_ptr<grpc::Server> server_; member in __anon047530350111::FakeHandshakeServer
150 server_ = grpc_server_create(nullptr, nullptr); in TestServer()
152 grpc_server_register_completion_queue(server_, server_cq_, nullptr); in TestServer()
155 GPR_ASSERT(grpc_server_add_secure_http2_port(server_, server_addr_.c_str(), in TestServer()
158 grpc_server_start(server_); in TestServer()
167 grpc_server_shutdown_and_notify(server_, server_cq_, this); in ~TestServer()
169 grpc_server_destroy(server_); in ~TestServer()
186 grpc_server* server_; member in __anon047530350111::TestServer
|
| /third_party/mindspore/tests/st/ps/full_ps/ |
| D | shell_run_test.sh | 39 rm -rf ${execute_path}/server_$i/
40 mkdir ${execute_path}/server_$i/
41 cd ${execute_path}/server_$i/ || exit
|
| /third_party/mindspore/tests/st/ps/part_ps/ |
| D | shell_run_test.sh | 39 rm -rf ${execute_path}/server_$i/
40 mkdir ${execute_path}/server_$i/
41 cd ${execute_path}/server_$i/ || exit
|
| /third_party/grpc/include/grpcpp/impl/codegen/ |
| D | service_type.h | 58 Service() : server_(nullptr) {} in Service()
136 server_->RequestAsyncCall(methods_[idx].get(), context, stream, call_cq, in RequestAsyncUnary()
145 server_->RequestAsyncCall(methods_[idx].get(), context, stream, call_cq, in RequestAsyncClientStreaming()
155 server_->RequestAsyncCall(methods_[idx].get(), context, stream, call_cq, in RequestAsyncServerStreaming()
164 server_->RequestAsyncCall(methods_[idx].get(), context, stream, call_cq, in RequestAsyncBidiStreaming()
269 ServerInterface* server_; variable
|