| /third_party/grpc/src/cpp/server/load_reporter/ |
| D | load_reporter_async_service_impl.cc | 56 cq_->Shutdown(); in ~LoadReporterAsyncServiceImpl()
165 Shutdown(std::move(self), "OnRequestDelivered"); in OnRequestDelivered()
175 Shutdown(std::move(self), "OnRequestDelivered"); in OnRequestDelivered()
203 Shutdown(std::move(self), "OnReadDone"); in OnReadDone()
209 Shutdown(std::move(self), "OnReadDone+initial_request_not_found"); in OnReadDone()
233 Shutdown(std::move(self), "OnReadDone"); in OnReadDone()
248 Shutdown(std::move(self), "OnReadDone+second_request"); in OnReadDone()
255 Shutdown(std::move(self), "ScheduleNextReport"); in ScheduleNextReport()
265 Shutdown(std::move(self), "ScheduleNextReport"); in ScheduleNextReport()
285 Shutdown(std::move(self), "SendReport"); in SendReport()
[all …]
|
| /third_party/grpc/src/core/ext/filters/client_channel/ |
| D | client_channel_plugin.cc | 63 grpc_core::GlobalSubchannelPool::Shutdown(); in grpc_client_channel_shutdown()
65 grpc_core::ProxyMapperRegistry::Shutdown(); in grpc_client_channel_shutdown()
66 grpc_core::internal::ServerRetryThrottleMap::Shutdown(); in grpc_client_channel_shutdown()
69 grpc_core::ServiceConfigParser::Shutdown(); in grpc_client_channel_shutdown()
|
| D | connector.h | 69 virtual void Shutdown(grpc_error* error) = 0;
72 Shutdown(GRPC_ERROR_CREATE_FROM_STATIC_STRING("Subchannel disconnected")); in Orphan()
|
| /third_party/grpc/test/core/iomgr/ |
| D | buffer_list_test.cc | 53 grpc_core::TracedBuffer::Shutdown(&list, nullptr, GRPC_ERROR_NONE); in TestShutdownFlushesList()
92 grpc_core::TracedBuffer::Shutdown(&list, nullptr, GRPC_ERROR_NONE); in TestVerifierCalledOnAck()
113 grpc_core::TracedBuffer::Shutdown(&list, nullptr, GRPC_ERROR_NONE); in TestRepeatedShutdown()
114 grpc_core::TracedBuffer::Shutdown(&list, nullptr, GRPC_ERROR_NONE); in TestRepeatedShutdown()
115 grpc_core::TracedBuffer::Shutdown(&list, nullptr, GRPC_ERROR_NONE); in TestRepeatedShutdown()
|
| /third_party/grpc/test/cpp/server/ |
| D | server_builder_test.cc | 57 ServerBuilder().RegisterService(&g_service).BuildAndStart()->Shutdown(); in TEST_F()
65 ->Shutdown(); in TEST_F()
74 ->Shutdown(); in TEST_F()
|
| /third_party/grpc/test/cpp/client/ |
| D | client_channel_stress_test.cc | 92 void Shutdown() { shutdown_ = true; } in Shutdown() function in grpc::testing::__anona16c02d90111::BalancerServiceImpl
166 Shutdown(); in Run()
203 void Shutdown() { in Shutdown() function
205 server_->Shutdown(grpc_timeout_milliseconds_to_deadline(0)); in Shutdown()
313 void Shutdown() { in Shutdown() function in grpc::testing::__anona16c02d90111::ClientChannelStressTest
319 balancers_[i]->Shutdown(); in Shutdown()
320 balancer_servers_[i].Shutdown(); in Shutdown()
323 backend_servers_[i].Shutdown(); in Shutdown()
|
| /third_party/grpc/src/core/lib/transport/ |
| D | byte_stream.h | 68 virtual void Shutdown(grpc_error* error) = 0;
101 void Shutdown(grpc_error* error) override;
135 void Shutdown(grpc_error* error) override;
|
| D | byte_stream.cc | 70 void SliceBufferByteStream::Shutdown(grpc_error* error) { in Shutdown() function in grpc_core::SliceBufferByteStream
145 void ByteStreamCache::CachingByteStream::Shutdown(grpc_error* error) { in Shutdown() function in grpc_core::ByteStreamCache::CachingByteStream
149 cache_->underlying_stream_->Shutdown(error); in Shutdown()
|
| /third_party/grpc/src/core/lib/channel/ |
| D | handshaker.cc | 90 head->Shutdown(GRPC_ERROR_REF(why)); in ShutdownAllPending()
109 void HandshakeManager::Shutdown(grpc_error* why) { in Shutdown() function in grpc_core::HandshakeManager
115 handshakers_[index_ - 1]->Shutdown(GRPC_ERROR_REF(why)); in Shutdown()
201 mgr->Shutdown(GRPC_ERROR_CREATE_FROM_STATIC_STRING("Handshake timed out")); in OnTimeoutFn()
|
| D | handshaker.h | 81 virtual void Shutdown(grpc_error* why) = 0;
116 void Shutdown(grpc_error* why);
|
| /third_party/mindspore/mindspore/ccsrc/minddata/dataset/engine/cache/ |
| D | cache_grpc_server.cc | 32 void CacheServerGreeterImpl::Shutdown() { in Shutdown() function in mindspore::dataset::CacheServerGreeterImpl
35 server_->Shutdown(deadline); in Shutdown()
39 cq_->Shutdown(); in Shutdown()
48 CacheServerGreeterImpl::~CacheServerGreeterImpl() { Shutdown(); } in ~CacheServerGreeterImpl()
|
| /third_party/grpc/src/csharp/Grpc.Core.Tests/ |
| D | ChannelTest.cs | 59 …eof(ArgumentException), async () => await channel.WaitForStateChangedAsync(ChannelState.Shutdown)); in WaitForStateChangedAsync_InvalidArgument()
94 Assert.AreEqual(ChannelState.Shutdown, channel.State); in StateIsShutdownAfterShutdown()
124 Assert.AreEqual(ChannelState.Shutdown, channel.State); in ChannelBaseShutdownAsyncInvokesShutdownAsync()
|
| /third_party/grpc/test/core/transport/chttp2/ |
| D | settings_timeout_test.cc | 67 void Shutdown() { in Shutdown() function in grpc_core::test::__anon50662e6e0111::ServerThread
154 void Shutdown() { in Shutdown() function in grpc_core::test::__anon50662e6e0111::Client
239 client.Shutdown(); in TEST()
242 server_thread.Shutdown(); in TEST()
|
| /third_party/grpc/src/csharp/Grpc.Core.Tests/Internal/ |
| D | CompletionQueueSafeHandleTest.cs | 44 cq.Shutdown(); in CreateAsyncAndShutdown()
48 Assert.AreEqual(CompletionQueueEvent.CompletionType.Shutdown, ev.type); in CreateAsyncAndShutdown()
|
| /third_party/node/src/ |
| D | inspector_socket.h | 48 static void Shutdown(ProtocolHandler*);
51 DeleteFnPtr<ProtocolHandler, Shutdown> protocol_handler_;
|
| D | node_platform.h | 76 void Shutdown();
125 void Shutdown();
145 void Shutdown();
|
| /third_party/grpc/test/cpp/end2end/ |
| D | server_interceptors_end2end_test.cc | 407 server->Shutdown(); in TEST_F()
408 cq->Shutdown(); in TEST_F()
490 server->Shutdown(); in TEST_F()
491 cq->Shutdown(); in TEST_F()
575 srv_cq->Shutdown(); in TEST_F()
584 cli_cq.Shutdown(); in TEST_F()
595 server->Shutdown(); in TEST_F()
645 server->Shutdown(); in TEST_F()
646 cq->Shutdown(); in TEST_F()
694 server->Shutdown(); in TEST_F()
|
| D | health_service_end2end_test.cc | 73 void Shutdown() override { impl_->Shutdown(); } in Shutdown() function in grpc::testing::__anonb22131250111::CustomHealthCheckService
116 server_->Shutdown(); in TearDown()
118 cq_->Shutdown(); in TearDown()
250 service->Shutdown(); in VerifyHealthCheckServiceShutdown()
|
| D | port_sharing_end2end_test.cc | 139 void Shutdown() { in Shutdown() function in grpc::testing::__anon63b8e00f0111::TestTcpServer
247 tcp_server1_.Shutdown(); in TearDown()
248 tcp_server2_.Shutdown(); in TearDown()
250 server_->Shutdown(); in TearDown()
|
| /third_party/mindspore/mindspore/ccsrc/minddata/dataset/engine/gnn/ |
| D | grpc_async_server.cc | 73 server_->Shutdown(); in Stop()
77 cq_->Shutdown(); in Stop()
|
| /third_party/grpc/src/core/lib/iomgr/poller/ |
| D | eventmanager_libuv.cc | 46 Shutdown(); in ~LibuvEventManager()
65 void grpc::experimental::LibuvEventManager::Shutdown() { in Shutdown() function in grpc::experimental::LibuvEventManager
|
| /third_party/grpc/src/csharp/Grpc.Core/ |
| D | Channel.cs | 150 GrpcPreconditions.CheckArgument(lastObservedState != ChannelState.Shutdown, in TryWaitForStateChangedAsync()
204 if (currentState == ChannelState.Shutdown)
305 return ChannelState.Shutdown; in GetConnectivityState()
|
| /third_party/grpc/test/cpp/microbenchmarks/ |
| D | fullstack_fixtures.h | 88 server_->Shutdown(); in ~FullstackFixture()
89 cq_->Shutdown(); in ~FullstackFixture()
213 server_->Shutdown(); in ~EndpointPairFixture()
214 cq_->Shutdown(); in ~EndpointPairFixture()
|
| /third_party/skia/third_party/externals/swiftshader/third_party/marl/include/marl/ |
| D | trace.h | 108 Shutdown = 'S', enumerator
133 struct Shutdown : public Event { struct
134 Type type() const override { return Type::Shutdown; } in type() argument
|
| /third_party/grpc/examples/cpp/helloworld/ |
| D | greeter_async_server.cc | 46 server_->Shutdown(); in ~ServerImpl()
48 cq_->Shutdown(); in ~ServerImpl()
|