Home
last modified time | relevance | path

Searched refs:GetEventEngine (Results 1 – 25 of 28) sorted by relevance

12

/external/grpc-grpc/src/core/load_balancing/
Ddelegating_helper.h78 grpc_event_engine::experimental::EventEngine* GetEventEngine() override { in GetEventEngine() function
79 return parent_helper()->GetEventEngine(); in GetEventEngine()
Dlb_policy.h325 virtual grpc_event_engine::experimental::EventEngine* GetEventEngine() = 0;
/external/rust/android-crates-io/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/lb_policy/grpclb/
Dgrpclb.cc468 grpc_event_engine::experimental::EventEngine* GetEventEngine() override;
496 parent_->channel_control_helper()->GetEventEngine()->Cancel( in OnConnectivityStateChange()
864 grpc_event_engine::experimental::EventEngine* GrpcLb::Helper::GetEventEngine() { in GetEventEngine() function in grpc_core::__anon095b06330111::GrpcLb::Helper
865 return parent_->channel_control_helper()->GetEventEngine(); in GetEventEngine()
941 grpclb_policy()->channel_control_helper()->GetEventEngine()->Cancel( in Orphan()
1028 grpclb_policy()->channel_control_helper()->GetEventEngine()->RunAfter( in ScheduleNextClientLoadReportLocked()
1258 grpclb_policy()->channel_control_helper()->GetEventEngine()->Cancel( in OnBalancerMessageReceivedLocked()
1277 grpclb_policy()->channel_control_helper()->GetEventEngine()->Cancel( in OnBalancerMessageReceivedLocked()
1345 grpclb_policy()->channel_control_helper()->GetEventEngine()->Cancel( in OnBalancerStatusReceivedLocked()
1504 channel_control_helper()->GetEventEngine()->Cancel( in ShutdownLocked()
[all …]
/external/rust/android-crates-io/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/lb_policy/xds/
Dxds_cluster_manager.cc180 EventEngine* GetEventEngine() override;
449 ->GetEventEngine() in Orphan()
494 ->GetEventEngine() in UpdateLocked()
533 ->GetEventEngine() in DeactivateLocked()
614 EventEngine* XdsClusterManagerLb::ClusterChild::Helper::GetEventEngine() { in GetEventEngine() function in grpc_core::__anon3b8a06980111::XdsClusterManagerLb::ClusterChild::Helper
617 ->GetEventEngine(); in GetEventEngine()
Dxds_wrr_locality.cc135 grpc_event_engine::experimental::EventEngine* GetEventEngine() override;
326 XdsWrrLocalityLb::Helper::GetEventEngine() { in GetEventEngine() function in grpc_core::__anon24e5ce970111::XdsWrrLocalityLb::Helper
327 return xds_wrr_locality_->channel_control_helper()->GetEventEngine(); in GetEventEngine()
Dxds_cluster_impl.cc247 grpc_event_engine::experimental::EventEngine* GetEventEngine() override;
680 XdsClusterImplLb::Helper::GetEventEngine() { in GetEventEngine() function in grpc_core::__anone049a72f0111::XdsClusterImplLb::Helper
681 return xds_cluster_impl_policy_->channel_control_helper()->GetEventEngine(); in GetEventEngine()
Dcds.cc179 grpc_event_engine::experimental::EventEngine* GetEventEngine() override;
267 grpc_event_engine::experimental::EventEngine* CdsLb::Helper::GetEventEngine() { in GetEventEngine() function in grpc_core::__anon29260e480111::CdsLb::Helper
268 return parent_->channel_control_helper()->GetEventEngine(); in GetEventEngine()
Dxds_override_host.cc233 grpc_event_engine::experimental::EventEngine* GetEventEngine() override;
649 XdsOverrideHostLb::Helper::GetEventEngine() { in GetEventEngine() function in grpc_core::__anon52204dd90111::XdsOverrideHostLb::Helper
650 return xds_override_host_policy_->channel_control_helper()->GetEventEngine(); in GetEventEngine()
Dxds_cluster_resolver.cc382 grpc_event_engine::experimental::EventEngine* GetEventEngine() override;
460 XdsClusterResolverLb::Helper::GetEventEngine() { in GetEventEngine() function in grpc_core::__anon31908e4f0111::XdsClusterResolverLb::Helper
462 ->GetEventEngine(); in GetEventEngine()
/external/grpc-grpc/src/core/load_balancing/grpclb/
Dgrpclb.cc499 parent_->channel_control_helper()->GetEventEngine()->Cancel( in OnConnectivityStateChange()
943 grpclb_policy()->channel_control_helper()->GetEventEngine()->Cancel( in Orphan()
1030 grpclb_policy()->channel_control_helper()->GetEventEngine()->RunAfter( in ScheduleNextClientLoadReportLocked()
1260 grpclb_policy()->channel_control_helper()->GetEventEngine()->Cancel( in OnBalancerMessageReceivedLocked()
1279 grpclb_policy()->channel_control_helper()->GetEventEngine()->Cancel( in OnBalancerMessageReceivedLocked()
1347 grpclb_policy()->channel_control_helper()->GetEventEngine()->Cancel( in OnBalancerStatusReceivedLocked()
1485 channel_control_helper()->GetEventEngine()->Cancel( in ShutdownLocked()
1491 channel_control_helper()->GetEventEngine()->Cancel( in ShutdownLocked()
1496 channel_control_helper()->GetEventEngine()->Cancel( in ShutdownLocked()
1584 channel_control_helper()->GetEventEngine()->RunAfter( in UpdateLocked()
[all …]
/external/rust/android-crates-io/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/lb_policy/priority/
Dpriority.cc179 EventEngine* GetEventEngine() override;
522 ->GetEventEngine() in DeactivationTimer()
542 ->GetEventEngine() in Orphan()
581 ->GetEventEngine() in FailoverTimer()
603 ->GetEventEngine() in Orphan()
824 EventEngine* PriorityLb::ChildPriority::Helper::GetEventEngine() { in GetEventEngine() function in grpc_core::__anon19f3b8830111::PriorityLb::ChildPriority::Helper
826 ->GetEventEngine(); in GetEventEngine()
/external/rust/android-crates-io/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/lb_policy/weighted_target/
Dweighted_target.cc187 grpc_event_engine::experimental::EventEngine* GetEventEngine() override;
480 ->GetEventEngine() in DelayedRemovalTimer()
502 ->GetEventEngine() in Orphan()
705 WeightedTargetLb::WeightedChild::Helper::GetEventEngine() { in GetEventEngine() function in grpc_core::__anon61e0630d0111::WeightedTargetLb::WeightedChild::Helper
707 ->GetEventEngine(); in GetEventEngine()
/external/rust/android-crates-io/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/lb_policy/
Dchild_policy_handler.cc111 grpc_event_engine::experimental::EventEngine* GetEventEngine() override { in GetEventEngine() function in grpc_core::ChildPolicyHandler::Helper
112 return parent_->channel_control_helper()->GetEventEngine(); in GetEventEngine()
/external/grpc-grpc/src/core/load_balancing/xds/
Dxds_cluster_manager.cc449 ->GetEventEngine() in Orphan()
494 ->GetEventEngine() in UpdateLocked()
533 ->GetEventEngine() in DeactivateLocked()
Dxds_override_host.cc619 timer_handle_ = policy_->channel_control_helper()->GetEventEngine()->RunAfter( in IdleTimer()
636 policy_->channel_control_helper()->GetEventEngine()->Cancel(*timer_handle_); in Orphan()
/external/grpc-grpc/src/core/load_balancing/priority/
Dpriority.cc523 ->GetEventEngine() in DeactivationTimer()
543 ->GetEventEngine() in Orphan()
582 ->GetEventEngine() in FailoverTimer()
604 ->GetEventEngine() in Orphan()
/external/rust/android-crates-io/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/lb_policy/outlier_detection/
Doutlier_detection.cc346 grpc_event_engine::experimental::EventEngine* GetEventEngine() override;
796 OutlierDetectionLb::Helper::GetEventEngine() { in GetEventEngine() function in grpc_core::__anonc587e8230111::OutlierDetectionLb::Helper
797 return outlier_detection_policy_->channel_control_helper()->GetEventEngine(); in GetEventEngine()
819 timer_handle_ = parent_->channel_control_helper()->GetEventEngine()->RunAfter( in EjectionTimer()
832 parent_->channel_control_helper()->GetEventEngine()->Cancel(*timer_handle_); in Orphan()
/external/grpc-grpc/src/core/load_balancing/pick_first/
Dpick_first.cc813 p->channel_control_helper()->GetEventEngine()->Cancel( in OnConnectivityStateChange()
890 p->channel_control_helper()->GetEventEngine()->RunAfter( in RequestConnectionWithTimer()
923 p->channel_control_helper()->GetEventEngine()->Cancel( in ProcessUnselectedReadyLocked()
1045 policy_->channel_control_helper()->GetEventEngine()->Cancel(*timer_handle_); in Orphan()
/external/rust/android-crates-io/crates/grpcio-sys/grpc/src/core/lib/load_balancing/
Dlb_policy.h301 virtual grpc_event_engine::experimental::EventEngine* GetEventEngine() = 0;
/external/grpc-grpc/src/core/load_balancing/weighted_target/
Dweighted_target.cc488 ->GetEventEngine() in DelayedRemovalTimer()
510 ->GetEventEngine() in Orphan()
/external/rust/android-crates-io/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/lb_policy/rls/
Drls.cc343 grpc_event_engine::experimental::EventEngine* GetEventEngine() override;
930 RlsLb::ChildPolicyWrapper::ChildPolicyHelper::GetEventEngine() { in GetEventEngine() function in grpc_core::__anond85855010111::RlsLb::ChildPolicyWrapper::ChildPolicyHelper
931 return wrapper_->lb_policy_->channel_control_helper()->GetEventEngine(); in GetEventEngine()
1116 entry_->lb_policy_->channel_control_helper()->GetEventEngine()->RunAfter( in BackoffTimer()
1130 entry_->lb_policy_->channel_control_helper()->GetEventEngine()->Cancel( in Orphan()
1419 lb_policy_->channel_control_helper()->GetEventEngine()->Cancel( in Shutdown()
1430 lb_policy_->channel_control_helper()->GetEventEngine()->RunAfter( in StartCleanupTimer()
/external/rust/android-crates-io/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/lb_policy/weighted_round_robin/
Dweighted_round_robin.cc534 wrr_->channel_control_helper()->GetEventEngine()->Cancel(*timer_handle_); in Orphan()
605 timer_handle_ = wrr_->channel_control_helper()->GetEventEngine()->RunAfter( in BuildSchedulerAndStartTimerLocked()
/external/grpc-grpc/src/core/load_balancing/weighted_round_robin/
Dweighted_round_robin.cc563 wrr_->channel_control_helper()->GetEventEngine()->Cancel(*timer_handle_); in Orphaned()
660 timer_handle_ = wrr_->channel_control_helper()->GetEventEngine()->RunAfter( in BuildSchedulerAndStartTimerLocked()
/external/grpc-grpc/src/core/load_balancing/outlier_detection/
Doutlier_detection.cc866 timer_handle_ = parent_->channel_control_helper()->GetEventEngine()->RunAfter( in EjectionTimer()
879 parent_->channel_control_helper()->GetEventEngine()->Cancel(*timer_handle_); in Orphan()
/external/grpc-grpc/src/core/load_balancing/rls/
Drls.cc1138 entry_->lb_policy_->channel_control_helper()->GetEventEngine()->RunAfter( in BackoffTimer()
1152 entry_->lb_policy_->channel_control_helper()->GetEventEngine()->Cancel( in Orphan()
1444 lb_policy_->channel_control_helper()->GetEventEngine()->Cancel( in Shutdown()
1468 lb_policy_->channel_control_helper()->GetEventEngine()->RunAfter( in StartCleanupTimer()

12