private static final class BaseCluster.ServerSelectionRequest
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
private SingleResultCallback<Server> |
callback |
private ServerSelector |
compositeSelector |
private long |
maxWaitTimeNanos |
private ServerSelector |
originalSelector |
private java.util.concurrent.CountDownLatch |
phase |
private long |
startTimeNanos |
Constructor and Description |
---|
ServerSelectionRequest(ServerSelector serverSelector,
ServerSelector compositeSelector,
long maxWaitTimeNanos,
SingleResultCallback<Server> callback) |
Modifier and Type | Method and Description |
---|---|
(package private) long |
getRemainingTime() |
(package private) void |
onResult(Server server,
java.lang.Throwable t) |
(package private) boolean |
timedOut() |
private final ServerSelector originalSelector
private final ServerSelector compositeSelector
private final long maxWaitTimeNanos
private final SingleResultCallback<Server> callback
private final long startTimeNanos
private java.util.concurrent.CountDownLatch phase
ServerSelectionRequest(ServerSelector serverSelector, ServerSelector compositeSelector, long maxWaitTimeNanos, SingleResultCallback<Server> callback)
void onResult(Server server, java.lang.Throwable t)
boolean timedOut()
long getRemainingTime()