Searched refs:state_tracker_ (Results 1 – 4 of 4) sorted by relevance
| /external/grpc-grpc/src/core/ext/filters/client_channel/lb_policy/pick_first/ |
| D | pick_first.cc | 145 grpc_connectivity_state_tracker state_tracker_; member in grpc_core::__anondbaa39340111::PickFirst
157 grpc_connectivity_state_init(&state_tracker_, GRPC_CHANNEL_IDLE, in PickFirst()
174 grpc_connectivity_state_destroy(&state_tracker_); in ~PickFirst()
203 grpc_connectivity_state_set(&state_tracker_, GRPC_CHANNEL_SHUTDOWN, in ShutdownLocked()
293 return grpc_connectivity_state_get(&state_tracker_, error); in CheckConnectivityLocked()
298 grpc_connectivity_state_notify_on_state_change(&state_tracker_, current, in NotifyOnStateChangeLocked()
342 &state_tracker_, GRPC_CHANNEL_TRANSIENT_FAILURE, in UpdateLocked()
368 &state_tracker_, GRPC_CHANNEL_TRANSIENT_FAILURE, in UpdateLocked()
471 &p->state_tracker_, GRPC_CHANNEL_TRANSIENT_FAILURE, in ProcessConnectivityChangeLocked()
485 grpc_connectivity_state_set(&p->state_tracker_, GRPC_CHANNEL_IDLE, in ProcessConnectivityChangeLocked()
[all …]
|
| /external/grpc-grpc/src/core/ext/filters/client_channel/lb_policy/round_robin/ |
| D | round_robin.cc | 222 grpc_connectivity_state_tracker state_tracker_; member in grpc_core::__anone1f0a73a0111::RoundRobin
233 grpc_connectivity_state_init(&state_tracker_, GRPC_CHANNEL_IDLE, in RoundRobin()
251 grpc_connectivity_state_destroy(&state_tracker_); in ~RoundRobin()
280 grpc_connectivity_state_set(&state_tracker_, GRPC_CHANNEL_SHUTDOWN, in ShutdownLocked()
509 grpc_connectivity_state_set(&p->state_tracker_, GRPC_CHANNEL_READY, in MaybeUpdateRoundRobinConnectivityStateLocked()
513 grpc_connectivity_state_set(&p->state_tracker_, GRPC_CHANNEL_CONNECTING, in MaybeUpdateRoundRobinConnectivityStateLocked()
517 grpc_connectivity_state_set(&p->state_tracker_, in MaybeUpdateRoundRobinConnectivityStateLocked()
657 return grpc_connectivity_state_get(&state_tracker_, error); in CheckConnectivityLocked()
662 grpc_connectivity_state_notify_on_state_change(&state_tracker_, current, in NotifyOnStateChangeLocked()
675 &state_tracker_, GRPC_CHANNEL_TRANSIENT_FAILURE, in UpdateLocked()
[all …]
|
| /external/grpc-grpc/src/core/ext/filters/client_channel/lb_policy/grpclb/ |
| D | grpclb.cc | 291 grpc_connectivity_state_tracker state_tracker_; member in grpc_core::__anon9fb3300c0111::GrpcLb
1047 grpc_connectivity_state_init(&state_tracker_, GRPC_CHANNEL_IDLE, "grpclb"); in GrpcLb()
1077 grpc_connectivity_state_destroy(&state_tracker_); in ~GrpcLb()
1109 grpc_connectivity_state_set(&state_tracker_, GRPC_CHANNEL_SHUTDOWN, in ShutdownLocked()
1275 return grpc_connectivity_state_get(&state_tracker_, connectivity_error); in CheckConnectivityLocked()
1280 grpc_connectivity_state_notify_on_state_change(&state_tracker_, current, in NotifyOnStateChangeLocked()
1767 grpc_connectivity_state_check(&state_tracker_); in UpdateConnectivityStateFromRoundRobinPolicyLocked()
1814 grpc_connectivity_state_set(&state_tracker_, rr_connectivity_state_, in UpdateConnectivityStateFromRoundRobinPolicyLocked()
|
| /external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/ |
| D | client_channel.cc | 361 ConnectivityStateTracker state_tracker_; member in grpc_core::__anon5e2240680111::ChannelData
1651 chand_->state_tracker_.AddWatcher( in AddWatcherLocked()
1656 chand_->state_tracker_.RemoveWatcher(this); in RemoveWatcherLocked()
1678 chand_->state_tracker_.AddWatcher(initial_state_, std::move(watcher_)); in AddWatcherLocked()
1704 chand_->state_tracker_.RemoveWatcher(watcher_); in RemoveWatcherLocked()
1881 state_tracker_("client_channel", GRPC_CHANNEL_IDLE), in ChannelData()
2400 state_tracker_.SetState(state, status, reason); in UpdateStateAndPickerLocked()
2465 if (state_tracker_.state() != GRPC_CHANNEL_READY) { in DoPingLocked()
2490 state_tracker_.AddWatcher(op->start_connectivity_watch_state, in StartTransportOpLocked()
2494 state_tracker_.RemoveWatcher(op->stop_connectivity_watch); in StartTransportOpLocked()
[all …]
|