| /external/grpc-grpc/src/cpp/server/load_reporter/ |
| D | load_reporter_async_service_impl.cc | 52 cq_->Shutdown(); in ~LoadReporterAsyncServiceImpl()
160 Shutdown(std::move(self), "OnRequestDelivered"); in OnRequestDelivered()
170 Shutdown(std::move(self), "OnRequestDelivered"); in OnRequestDelivered()
198 Shutdown(std::move(self), "OnReadDone"); in OnReadDone()
204 Shutdown(std::move(self), "OnReadDone+initial_request_not_found"); in OnReadDone()
228 Shutdown(std::move(self), "OnReadDone"); in OnReadDone()
243 Shutdown(std::move(self), "OnReadDone+second_request"); in OnReadDone()
250 Shutdown(std::move(self), "ScheduleNextReport"); in ScheduleNextReport()
260 Shutdown(std::move(self), "ScheduleNextReport"); in ScheduleNextReport()
280 Shutdown(std::move(self), "SendReport"); in SendReport()
[all …]
|
| /external/grpc-grpc/test/cpp/client/ |
| D | client_channel_stress_test.cc | 86 void Shutdown() { shutdown_ = true; } in Shutdown() function in grpc::testing::__anone8ea55010111::BalancerServiceImpl
160 Shutdown(); in Run()
197 void Shutdown() { in Shutdown() function
199 server_->Shutdown(grpc_timeout_milliseconds_to_deadline(0)); in Shutdown()
290 void Shutdown() { in Shutdown() function in grpc::testing::__anone8ea55010111::ClientChannelStressTest
296 balancers_[i]->Shutdown(); in Shutdown()
297 balancer_servers_[i].Shutdown(); in Shutdown()
300 backend_servers_[i].Shutdown(); in Shutdown()
|
| /external/grpc-grpc/test/cpp/server/ |
| D | server_builder_test.cc | 50 ServerBuilder().RegisterService(&g_service).BuildAndStart()->Shutdown(); in TEST()
58 ->Shutdown(); in TEST()
67 ->Shutdown(); in TEST()
|
| /external/libchrome/base/ |
| D | sync_socket_unittest.cc | 154 EXPECT_TRUE(socket_b_.Shutdown()); in TEST_F()
167 EXPECT_TRUE(socket_b_.Shutdown()); in TEST_F()
174 socket_a_.Shutdown(); in TEST_F()
180 socket_a_.Shutdown(); in TEST_F()
|
| /external/grpc-grpc/src/core/lib/transport/ |
| D | byte_stream.h | 64 virtual void Shutdown(grpc_error* error) GRPC_ABSTRACT;
99 void Shutdown(grpc_error* error) override;
134 void Shutdown(grpc_error* error) override;
|
| D | byte_stream.cc | 72 void SliceBufferByteStream::Shutdown(grpc_error* error) { in Shutdown() function in grpc_core::SliceBufferByteStream
147 void ByteStreamCache::CachingByteStream::Shutdown(grpc_error* error) { in Shutdown() function in grpc_core::ByteStreamCache::CachingByteStream
151 cache_->underlying_stream_->Shutdown(error); in Shutdown()
|
| /external/syzkaller/vendor/google.golang.org/grpc/connectivity/ |
| D | connectivity.go | 43 case Shutdown:
61 Shutdown const
|
| /external/tensorflow/tensorflow/python/grappler/ |
| D | cluster.py | 61 def Shutdown(self): member in Cluster
67 self.Shutdown()
130 cluster.Shutdown()
|
| /external/grpc-grpc/test/core/transport/chttp2/ |
| D | settings_timeout_test.cc | 65 void Shutdown() { in Shutdown() function in grpc_core::test::__anonecf37e960111::ServerThread
151 void Shutdown() { in Shutdown() function in grpc_core::test::__anonecf37e960111::Client
235 client.Shutdown(); in TEST()
238 server_thread.Shutdown(); in TEST()
|
| /external/tensorflow/tensorflow/core/grappler/clusters/ |
| D | single_machine_test.cc | 54 TF_CHECK_OK(cluster_->Shutdown()); in TearDown()
190 TF_CHECK_OK(cluster_->Shutdown()); in TEST_F()
330 Status s2 = cluster.Shutdown(); in RunInfiniteTFLoop()
344 TF_CHECK_OK(cluster_->Shutdown()); in TEST_F()
561 TF_CHECK_OK(cluster_->Shutdown()); in TEST_F()
565 TF_CHECK_OK(cluster_->Shutdown()); in TEST_F()
590 TF_CHECK_OK(cluster_->Shutdown()); in TEST_F()
594 TF_CHECK_OK(cluster_->Shutdown()); in TEST_F()
606 TF_CHECK_OK(cluster_->Shutdown()); in TEST_F()
616 TF_CHECK_OK(cluster.Shutdown()); in TEST_F()
|
| /external/grpc-grpc/test/cpp/end2end/ |
| D | grpclb_end2end_test.cc | 150 bool Shutdown() { in Shutdown() function in grpc::testing::__anon5deae6e10111::BackendServiceImpl
280 bool Shutdown() { in Shutdown() function in grpc::testing::__anon5deae6e10111::BalancerServiceImpl
380 if (backends_[i]->Shutdown()) backend_servers_[i].Shutdown(); in TearDown()
383 if (balancers_[i]->Shutdown()) balancer_servers_[i].Shutdown(); in TearDown()
603 void Shutdown() { in Shutdown() function
605 server_->Shutdown(grpc_timeout_milliseconds_to_deadline(0)); in Shutdown()
947 if (backends_[i]->Shutdown()) backend_servers_[i].Shutdown(); in TEST_F()
1126 if (balancers_[0]->Shutdown()) balancer_servers_[0].Shutdown(); in TEST_F()
1210 if (backends_[0]->Shutdown()) backend_servers_[0].Shutdown(); in TEST_F()
1268 if (backends_[0]->Shutdown()) backend_servers_[0].Shutdown(); in TEST_F()
[all …]
|
| D | client_lb_end2end_test.cc | 129 servers_[i]->Shutdown(); in TearDown()
286 void Shutdown(bool join = true) { in Shutdown() function
287 server_->Shutdown(grpc_timeout_milliseconds_to_deadline(0)); in Shutdown()
646 servers_[0]->Shutdown(); in TEST_F()
665 servers_[1]->Shutdown(); in TEST_F()
681 servers_[0]->Shutdown(); in TEST_F()
696 servers_[0]->Shutdown(); in TEST_F()
867 servers_[1]->Shutdown(false); in TEST_F()
929 servers_[i]->Shutdown(true); in TEST_F()
977 servers_[0]->Shutdown(true); in TEST_F()
|
| /external/webrtc/webrtc/test/ |
| D | test_suite.cc | 48 Shutdown(); in Run()
58 void TestSuite::Shutdown() { in Shutdown() function in webrtc::test::TestSuite
|
| /external/grpc-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()
|
| /external/perfetto/src/base/ |
| D | unix_socket.cc | 215 void UnixSocketRaw::Shutdown() { in Shutdown() function in perfetto::base::UnixSocketRaw
479 Shutdown(true); in ~UnixSocket()
565 Shutdown(false); in OnEvent()
630 Shutdown(true); in Send()
634 void UnixSocket::Shutdown(bool notify) { in Shutdown() function in perfetto::base::UnixSocket
652 sock_raw_.Shutdown(); in Shutdown()
673 Shutdown(true); in Receive()
690 Shutdown(false); in NotifyConnectionState()
|
| /external/grpc-grpc/src/cpp/server/ |
| D | server_cc.cc | 242 cq_.Shutdown(); in Run()
351 void Shutdown() override { in Shutdown() function in grpc::Server::SyncRequestThreadManager
352 ThreadManager::Shutdown(); in Shutdown()
353 server_cq_->Shutdown(); in Shutdown()
452 Shutdown(); in ~Server()
456 (*it)->Shutdown(); in ~Server()
610 shutdown_cq.Shutdown(); in ShutdownInternal()
628 (*it)->Shutdown(); // ThreadManager's Shutdown() in ShutdownInternal()
|
| /external/tensorflow/tensorflow/core/distributed_runtime/rpc/eager/ |
| D | grpc_eager_service_impl.cc | 68 cq_->Shutdown(); in HandleRPCsLoop()
74 void GrpcEagerServiceImpl::Shutdown() { in Shutdown() function in tensorflow::eager::GrpcEagerServiceImpl
|
| /external/grpc-grpc/src/csharp/Grpc.Core/ |
| D | Channel.cs | 152 GrpcPreconditions.CheckArgument(lastObservedState != ChannelState.Shutdown, in TryWaitForStateChangedAsync()
215 if (currentState == ChannelState.Shutdown)
317 return ChannelState.Shutdown; in GetConnectivityState()
|
| /external/syzkaller/vendor/google.golang.org/grpc/ |
| D | clientconn.go | 648 if csm.state == connectivity.Shutdown {
938 if ac.state == connectivity.Shutdown {
975 if ac.state == connectivity.Shutdown {
1086 cc.csMgr.updateState(connectivity.Shutdown)
1196 if ac.state == connectivity.Shutdown {
1237 if ac.state == connectivity.Shutdown {
1298 if ac.state == connectivity.Shutdown {
1319 if ac.state == connectivity.Shutdown {
1348 if ac.state == connectivity.Shutdown {
1425 if ac.state == connectivity.Shutdown {
[all …]
|
| /external/perfetto/src/tracing/ipc/service/ |
| D | service_ipc_host_impl.cc | 74 Shutdown(); in DoStart()
95 void ServiceIPCHostImpl::Shutdown() { in Shutdown() function in perfetto::ServiceIPCHostImpl
|
| /external/grpc-grpc/test/core/iomgr/ |
| D | buffer_list_test.cc | 53 grpc_core::TracedBuffer::Shutdown(&list, GRPC_ERROR_NONE); in TestShutdownFlushesList()
91 grpc_core::TracedBuffer::Shutdown(&list, GRPC_ERROR_NONE); in TestVerifierCalledOnAck()
|
| /external/libbrillo/brillo/daemons/ |
| D | daemon.cc | 66 signal, base::Bind(&Daemon::Shutdown, base::Unretained(this))); in OnInit()
87 bool Daemon::Shutdown(const signalfd_siginfo& /* info */) { in Shutdown() function in brillo::Daemon
|
| /external/grpc-grpc/examples/cpp/helloworld/ |
| D | greeter_async_server.cc | 42 server_->Shutdown(); in ~ServerImpl()
44 cq_->Shutdown(); in ~ServerImpl()
|
| /external/swiftshader/third_party/llvm-7.0/llvm/unittests/Support/DynamicLibrary/ |
| D | DynamicLibraryTest.cpp | 64 llvm_shutdown_obj Shutdown; in TEST() local
112 TEST(DynamicLibrary, Shutdown) { in TEST() argument
117 llvm_shutdown_obj Shutdown; in TEST() local
|
| /external/syzkaller/vm/ |
| D | vm.go | 44 Shutdown = vmimpl.Shutdown var
194 case <-Shutdown:
|