Searched refs:CallState (Results 1 – 8 of 8) sorted by relevance
130 call_state_ = MakeOrphanable<CallState>(Ref(), interested_parties_); in StartCallLocked()250 HealthCheckClient::CallState::CallState( in CallState() function in grpc_core::HealthCheckClient::CallState259 HealthCheckClient::CallState::~CallState() { in ~CallState()280 void HealthCheckClient::CallState::Orphan() { in Orphan()285 void HealthCheckClient::CallState::StartCall() { in StartCall()383 void HealthCheckClient::CallState::StartBatchInCallCombiner( in StartBatchInCallCombiner()392 void HealthCheckClient::CallState::StartBatch( in StartBatch()401 void HealthCheckClient::CallState::AfterCallStackDestruction( in AfterCallStackDestruction()403 HealthCheckClient::CallState* self = in AfterCallStackDestruction()404 static_cast<HealthCheckClient::CallState*>(arg); in AfterCallStackDestruction()[all …]
59 class CallState : public Orphanable {61 CallState(RefCountedPtr<HealthCheckClient> health_check_client,63 ~CallState() override;164 OrphanablePtr<CallState> call_state_;
106 class CallState {108 CallState() = default;109 virtual ~CallState() = default;202 CallState* call_state;246 std::function<void(grpc_error*, MetadataInterface*, CallState*)>
1025 LoadBalancingPolicy::CallState*)>4855 class LoadBalancedCall::LbCallState : public LoadBalancingPolicy::CallState {
208 calld->SetState(CallData::CallState::ZOMBIED); in ZombifyPending()274 calld->SetState(CallData::CallState::ACTIVATED); in MatchOrQueue()299 calld->SetState(CallData::CallState::PENDING); in MatchOrQueue()305 calld->SetState(CallData::CallState::ACTIVATED); in MatchOrQueue()380 calld->SetState(CallData::CallState::ACTIVATED); in MatchOrQueue()410 calld->SetState(CallData::CallState::ACTIVATED); in MatchOrQueue()1198 GPR_ASSERT(state_.Load(MemoryOrder::RELAXED) != CallState::PENDING); in ~CallData()1210 void Server::CallData::SetState(CallState state) { in SetState()1215 CallState expected = CallState::PENDING; in MaybeActivate()1216 return state_.CompareExchangeStrong(&expected, CallState::ACTIVATED, in MaybeActivate()[all …]
232 enum class CallState { enum247 void SetState(CallState state);286 Atomic<CallState> state_{CallState::NOT_STARTED};
350 CallState* call_state) { in Pick()
2272 d = CallState()11074 class CallState(Packet): class