Package io.grpc.internal

Class BackoffPolicyRetryScheduler

java.lang.Object

io.grpc.internal.BackoffPolicyRetryScheduler

All Implemented Interfaces:

RetryScheduler

final class BackoffPolicyRetryScheduler
extends Object
implements RetryScheduler

Schedules a retry operation according to a BackoffPolicy. The retry is run within a SynchronizationContext. At most one retry is scheduled at a time.

Field Summary

Fields

Modifier and Type	Field	Description
private static final Logger	logger
private BackoffPolicy	policy
private final BackoffPolicy.Provider	policyProvider
private final ScheduledExecutorService	scheduledExecutorService
private SynchronizationContext.ScheduledHandle	scheduledHandle
private final SynchronizationContext	syncContext

Constructor Summary

Constructors

Constructor	Description
BackoffPolicyRetryScheduler(BackoffPolicy.Provider policyProvider, ScheduledExecutorService scheduledExecutorService, SynchronizationContext syncContext)

Method Summary

Modifier and Type	Method	Description
void	reset()	Resets the BackoffPolicyRetryScheduler and cancels any pending retry task.
void	schedule(Runnable retryOperation)	Schedules a future retry operation.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

scheduledExecutorService

private final ScheduledExecutorService scheduledExecutorService

syncContext

private final SynchronizationContext syncContext

policyProvider

private final BackoffPolicy.Provider policyProvider

policy

private BackoffPolicy policy

scheduledHandle

private SynchronizationContext.ScheduledHandle scheduledHandle

logger

private static final Logger logger

Constructor Details

BackoffPolicyRetryScheduler

BackoffPolicyRetryScheduler(BackoffPolicy.Provider policyProvider,
 ScheduledExecutorService scheduledExecutorService,
 SynchronizationContext syncContext)

Method Details

schedule

public void schedule(Runnable retryOperation)

Schedules a future retry operation. Only allows one retry to be scheduled at any given time.

Specified by:

schedule in interface RetryScheduler

reset

public void reset()

Resets the BackoffPolicyRetryScheduler and cancels any pending retry task. The policy will be cleared thus also resetting any state associated with it (e.g. a backoff multiplier).

Specified by:

reset in interface RetryScheduler