class DefaultServerMonitor.ServerMonitorRunnable
extends java.lang.Object
implements java.lang.Runnable
Modifier and Type | Field and Description |
---|---|
private ExponentiallyWeightedMovingAverage |
averageRoundTripTime |
Constructor and Description |
---|
ServerMonitorRunnable() |
Modifier and Type | Method and Description |
---|---|
private ServerDescription |
getConnectingServerDescription(java.lang.Throwable exception) |
private void |
logStateChange(ServerDescription previousServerDescription,
ServerDescription currentServerDescription) |
private ServerDescription |
lookupServerDescription(InternalConnection connection) |
void |
run() |
private void |
waitForNext() |
private long |
waitForSignalOrTimeout() |
private final ExponentiallyWeightedMovingAverage averageRoundTripTime
public void run()
run
in interface java.lang.Runnable
private ServerDescription getConnectingServerDescription(java.lang.Throwable exception)
private ServerDescription lookupServerDescription(InternalConnection connection)
private void logStateChange(ServerDescription previousServerDescription, ServerDescription currentServerDescription)
private void waitForNext()
private long waitForSignalOrTimeout() throws java.lang.InterruptedException
java.lang.InterruptedException