com.mongodb

Class ServerMonitor

java.lang.Object

com.mongodb.ServerMonitor

@ThreadSafe
class ServerMonitor
extends java.lang.Object

Nested Class Summary

Nested Classes

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

Field Summary

Fields

Modifier and Type	Field and Description
private java.util.concurrent.locks.Condition	condition
private PooledConnectionProvider	connectionProvider
private int	count
private long	elapsedNanosSum
private boolean	isClosed
private java.util.concurrent.locks.Lock	lock
private static java.util.logging.Logger	LOGGER
private Mongo	mongo
private java.lang.Thread	monitorThread
private ServerAddress	serverAddress
private ChangeListener<ServerDescription>	serverStateListener
private ServerSettings	settings
private SocketSettings	socketSettings

Constructor Summary

Constructors

Constructor and Description
ServerMonitor(ServerAddress serverAddress, ChangeListener<ServerDescription> serverStateListener, SocketSettings socketSettings, ServerSettings settings, java.lang.String clusterId, Mongo mongo, PooledConnectionProvider connectionProvider)

Method Summary

Modifier and Type	Method and Description
void	close()
void	connect()
(package private) static ServerDescription	createDescription(CommandResult commandResult, ServerVersion serverVersion, long averageLatencyNanos)
(package private) static boolean	descriptionHasChanged(ServerDescription previousServerDescription, ServerDescription currentServerDescription)
(package private) static boolean	exceptionHasChanged(java.lang.Throwable previousException, java.lang.Throwable currentException)
private ServerDescription	getConnectingServerDescription(java.lang.Throwable throwable)
private MongoOptions	getOptions()
(package private) static ServerType	getServerType(CommandResult isMasterResult)
private static TagSet	getTagSetFromDocument(DBObject tagsDocument)
private static boolean	isReplicaSetMember(BasicDBObject isMasterResult)
private static java.util.Set<java.lang.String>	listToSet(java.util.List<java.lang.String> list)
private ServerDescription	lookupServerDescription(DBPort connection)
(package private) void	start()
(package private) static boolean	stateHasChanged(ServerDescription previousServerDescription, ServerDescription currentServerDescription)

Methods inherited from class java.lang.Object

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

Field Detail

LOGGER

private static final java.util.logging.Logger LOGGER

serverAddress

private final ServerAddress serverAddress

serverStateListener

private final ChangeListener<ServerDescription> serverStateListener

socketSettings

private final SocketSettings socketSettings

settings

private final ServerSettings settings

mongo

private final Mongo mongo

connectionProvider

private final PooledConnectionProvider connectionProvider

count

private int count

elapsedNanosSum

private long elapsedNanosSum

isClosed

private volatile boolean isClosed

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

Constructor Detail

ServerMonitor

ServerMonitor(ServerAddress serverAddress,
              ChangeListener<ServerDescription> serverStateListener,
              SocketSettings socketSettings,
              ServerSettings settings,
              java.lang.String clusterId,
              Mongo mongo,
              PooledConnectionProvider connectionProvider)

Method Detail

start

void start()

connect

public void connect()

close

public void close()

getOptions

private MongoOptions getOptions()

descriptionHasChanged

static boolean descriptionHasChanged(ServerDescription previousServerDescription,
                                     ServerDescription currentServerDescription)

stateHasChanged

static boolean stateHasChanged(ServerDescription previousServerDescription,
                               ServerDescription currentServerDescription)

exceptionHasChanged

static boolean exceptionHasChanged(java.lang.Throwable previousException,
                                   java.lang.Throwable currentException)

lookupServerDescription

private ServerDescription lookupServerDescription(DBPort connection)
                                           throws java.io.IOException

Throws:

java.io.IOException

createDescription

static ServerDescription createDescription(CommandResult commandResult,
                                           ServerVersion serverVersion,
                                           long averageLatencyNanos)

listToSet

private static java.util.Set<java.lang.String> listToSet(java.util.List<java.lang.String> list)

getServerType

static ServerType getServerType(CommandResult isMasterResult)

isReplicaSetMember

private static boolean isReplicaSetMember(BasicDBObject isMasterResult)

getTagSetFromDocument

private static TagSet getTagSetFromDocument(DBObject tagsDocument)

getConnectingServerDescription

private ServerDescription getConnectingServerDescription(java.lang.Throwable throwable)