Searched refs:is_shutdown_ (Results 1 – 11 of 11) sorted by relevance
116 if (!is_shutdown_ && index_ > 0) { in Shutdown()117 is_shutdown_ = true; in Shutdown()132 this, grpc_error_string(error), is_shutdown_, index_, in CallNextHandshakerLocked()139 if (error != GRPC_ERROR_NONE || is_shutdown_ || args_.exit_early || in CallNextHandshakerLocked()141 if (error == GRPC_ERROR_NONE && is_shutdown_) { in CallNextHandshakerLocked()171 is_shutdown_ = true; in CallNextHandshakerLocked()183 return is_shutdown_; in CallNextHandshakerLocked()219 GPR_ASSERT(!is_shutdown_); in DoHandshake()
148 bool is_shutdown_ = false; variable
67 bool is_shutdown_ = false; member in grpc_core::__anon3fe17e320111::HttpConnectHandshaker117 if (!is_shutdown_) { in HandshakeFailedLocked()128 is_shutdown_ = true; in HandshakeFailedLocked()150 if (error != GRPC_ERROR_NONE || handshaker->is_shutdown_) { in OnWriteDone()184 if (error != GRPC_ERROR_NONE || handshaker->is_shutdown_) { in OnReadDone()258 handshaker->is_shutdown_ = true; in OnReadDone()270 if (!is_shutdown_) { in Shutdown()271 is_shutdown_ = true; in Shutdown()292 is_shutdown_ = true; in DoHandshake()
89 bool is_shutdown_ = false; member in grpc_core::__anonca80907c0111::SecurityHandshaker186 if (!is_shutdown_) { in HandshakeFailedLocked()198 is_shutdown_ = true; in HandshakeFailedLocked()206 if (error != GRPC_ERROR_NONE || is_shutdown_) { in OnPeerCheckedInner()264 is_shutdown_ = true; in OnPeerCheckedInner()290 if (is_shutdown_) { in OnHandshakeNextDoneLocked()395 if (error != GRPC_ERROR_NONE || h->is_shutdown_) { in OnHandshakeDataReceivedFromPeerFn()429 if (error != GRPC_ERROR_NONE || h->is_shutdown_) { in OnHandshakeDataSentToPeerFn()459 if (!is_shutdown_) { in Shutdown()460 is_shutdown_ = true; in Shutdown()
53 is_shutdown_(false), in GrpcMasterService()65 if (!is_shutdown_) { in Shutdown()67 is_shutdown_ = true; in Shutdown()94 if (!is_shutdown_) { \141 bool is_shutdown_ TF_GUARDED_BY(mu_);
77 if (!is_shutdown_) { \108 is_shutdown_(false) { in GrpcWorkerServiceThread()123 is_shutdown_ = true; in Shutdown()344 if (!is_shutdown_) { in EnqueueRecvTensorRequestRaw()363 bool is_shutdown_ TF_GUARDED_BY(shutdown_mu_);371 : is_shutdown_(false) { in GrpcWorkerService()385 if (!is_shutdown_) { in Shutdown()387 is_shutdown_ = true; in Shutdown()414 bool is_shutdown_ TF_GUARDED_BY(service_shutdown_mu_);
50 is_shutdown_(false), in TaskQueuePacedSender()61 is_shutdown_ = true; in ~TaskQueuePacedSender()199 if (is_shutdown_) { in MaybeProcessPackets()241 if (is_shutdown_) { in MaybeUpdateStats()
156 bool is_shutdown_ RTC_GUARDED_BY(task_queue_);
168 is_shutdown_ = false; in Initialize()354 is_shutdown_ = true; in ~ExceptionHandler()395 if (self->is_shutdown_) { in ExceptionHandlerThreadMain()
448 volatile bool is_shutdown_; variable
61 is_shutdown_(false) {} in Worker()78 is_shutdown_(false) {} in Worker()82 CHECK(is_shutdown_); in ~Worker()112 is_shutdown_ = true; in Shutdown()257 bool is_shutdown_; member in IPC::__anon7ae8f74a0111::Worker