private final class AsyncRequestFutureImpl.ReplicaCallIssuingRunnable extends Object implements Runnable
Modifier and Type | Field and Description |
---|---|
private List<Action> |
initialActions |
private long |
startTime |
Constructor and Description |
---|
ReplicaCallIssuingRunnable(List<Action> initialActions,
long startTime) |
Modifier and Type | Method and Description |
---|---|
private void |
addReplicaActions(int index,
Map<ServerName,MultiAction> actionsByServer,
List<Action> unknownReplicaActions)
Add replica actions to action map by server.
|
private void |
addReplicaActionsAgain(Action action,
Map<ServerName,MultiAction> actionsByServer) |
void |
run() |
private final long startTime
private final List<Action> initialActions
public ReplicaCallIssuingRunnable(List<Action> initialActions, long startTime)
private void addReplicaActions(int index, Map<ServerName,MultiAction> actionsByServer, List<Action> unknownReplicaActions)
index
- Index of the original action.actionsByServer
- The map by server to add it to.private void addReplicaActionsAgain(Action action, Map<ServerName,MultiAction> actionsByServer)
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.