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.Runnableprivate 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