private final class ConnectivityCheckClient.PaceMaker extends Object
Modifier and Type | Field and Description |
---|---|
private AtomicBoolean |
cancelled
Indicates whether this Runnable should continue running.
|
private CheckList |
checkList
The
CheckList that this PaceMaker will be running
checks for. |
private Runnable |
connectivityChecker
Sends connectivity checks at the pace determined by the
Agent.calculateTa() method and using either the trigger check queue
or the regular check lists. |
private ScheduledFuture<?> |
scheduledCheck
Scheduled instance of
connectivityChecker runnable |
Constructor and Description |
---|
PaceMaker(CheckList checkList)
Creates a new
ConnectivityCheckClient.PaceMaker for this
ConnectivityCheckClient. |
Modifier and Type | Method and Description |
---|---|
(package private) void |
cancel()
Cancel execution of current and further connectivity checks
|
private long |
getNextWaitInterval()
Returns the number milliseconds to wait before we send the next
check.
|
(package private) void |
schedule()
Schedules execution of checks for check list
|
private final AtomicBoolean cancelled
private final Runnable connectivityChecker
Agent.calculateTa()
method and using either the trigger check queue
or the regular check lists.private final CheckList checkList
CheckList
that this PaceMaker will be running
checks for.private ScheduledFuture<?> scheduledCheck
connectivityChecker
runnablepublic PaceMaker(CheckList checkList)
ConnectivityCheckClient.PaceMaker
for this
ConnectivityCheckClient.checkList
- the CheckList
that we'll be sending checks
forvoid cancel()
void schedule()
private long getNextWaitInterval()
Copyright © 2018. All rights reserved.