com.mongodb.connection

Class DefaultServerMonitor

java.lang.Object

com.mongodb.connection.DefaultServerMonitor

All Implemented Interfaces:

ServerMonitor

@ThreadSafe
class DefaultServerMonitor
extends java.lang.Object
implements ServerMonitor

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
(package private) class	DefaultServerMonitor.ServerMonitorRunnable

Field Summary

Fields

Modifier and Type	Field and Description
private java.util.concurrent.locks.Condition	condition
private ConnectionPool	connectionPool
private InternalConnectionFactory	internalConnectionFactory
private boolean	isClosed
private java.util.concurrent.locks.Lock	lock
private static Logger	LOGGER
private DefaultServerMonitor.ServerMonitorRunnable	monitor
private java.lang.Thread	monitorThread
private ServerId	serverId
private ServerMonitorListener	serverMonitorListener
private ChangeListener<ServerDescription>	serverStateListener
private ServerSettings	settings

Constructor Summary

Constructors

Constructor and Description
DefaultServerMonitor(ServerId serverId, ServerSettings settings, ChangeListener<ServerDescription> serverStateListener, InternalConnectionFactory internalConnectionFactory, ConnectionPool connectionPool)

Method Summary

Modifier and Type	Method and Description
void	close()
void	connect()
(package private) static boolean	shouldLogStageChange(ServerDescription previous, ServerDescription current)
void	start()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

LOGGER

private static final Logger LOGGER

serverId

private final ServerId serverId

serverMonitorListener

private final ServerMonitorListener serverMonitorListener

serverStateListener

private final ChangeListener<ServerDescription> serverStateListener

internalConnectionFactory

private final InternalConnectionFactory internalConnectionFactory

connectionPool

private final ConnectionPool connectionPool

settings

private final ServerSettings settings

monitor

private final DefaultServerMonitor.ServerMonitorRunnable monitor

monitorThread

private final java.lang.Thread monitorThread

lock

private final java.util.concurrent.locks.Lock lock

condition

private final java.util.concurrent.locks.Condition condition

isClosed

private volatile boolean isClosed

Constructor Detail

DefaultServerMonitor

DefaultServerMonitor(ServerId serverId,
                     ServerSettings settings,
                     ChangeListener<ServerDescription> serverStateListener,
                     InternalConnectionFactory internalConnectionFactory,
                     ConnectionPool connectionPool)

Method Detail

start

public void start()

Specified by:

start in interface ServerMonitor

connect

public void connect()

Specified by:

connect in interface ServerMonitor

close

public void close()

Specified by:

close in interface ServerMonitor

shouldLogStageChange

static boolean shouldLogStageChange(ServerDescription previous,
                                    ServerDescription current)