Searched refs:Rescheduler (Results 1 – 5 of 5) sorted by relevance
29 final class Rescheduler { class42 Rescheduler( in Rescheduler() method in Rescheduler80 Rescheduler.this.serializingExecutor.execute(new ChannelFutureRunnable()); in run()84 return Rescheduler.this.enabled; in isEnabled()
541 private final Rescheduler idleTimer;597 idleTimer = new Rescheduler( in ManagedChannelImpl()
356 class Rescheduler { class358 Rescheduler(benchmark::State& state, grpc_closure_scheduler* scheduler) in Rescheduler() function in Rescheduler376 Rescheduler* self = static_cast<Rescheduler*>(arg); in Step()386 Rescheduler r(state, grpc_schedule_on_exec_ctx); in BM_ClosureReschedOnExecCtx()397 Rescheduler r(state, grpc_combiner_scheduler(combiner)); in BM_ClosureReschedOnCombiner()410 Rescheduler r(state, grpc_combiner_finally_scheduler(combiner)); in BM_ClosureReschedOnCombinerFinally()
37 private final Rescheduler rescheduler = new Rescheduler(
171 assertFalse(Rescheduler.isEnabled(a.command)); in allPendingTasksAreRun()