com.mongodb

Class MultiServerCluster

java.lang.Object

com.mongodb.BaseCluster

com.mongodb.MultiServerCluster

All Implemented Interfaces:

Cluster

final class MultiServerCluster
extends BaseCluster

This class needs to be final because we are leaking a reference to "this" from the constructor

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
private class	MultiServerCluster.DefaultServerStateListener
private static class	MultiServerCluster.ServerTuple

Field Summary

Fields

Modifier and Type	Field and Description
private java.util.concurrent.ConcurrentMap<ServerAddress,MultiServerCluster.ServerTuple>	addressToServerTupleMap
private ClusterType	clusterType
private static java.util.logging.Logger	LOGGER
private ObjectId	maxElectionId
private java.lang.Integer	maxSetVersion
private java.lang.String	replicaSetName

Constructor Summary

Constructors

Constructor and Description
MultiServerCluster(java.lang.String clusterId, ClusterSettings settings, ClusterableServerFactory serverFactory, ClusterListener clusterListener)

Method Summary

Modifier and Type	Method and Description
private void	addHostsToSet(java.util.Set<java.lang.String> hosts, java.util.Set<ServerAddress> retVal)
private void	addNewHosts(java.util.Set<java.lang.String> hosts)
private void	addServer(ServerAddress serverAddress)
void	close() Closes connections to the servers in the cluster.
protected void	connect() Try to connect to all servers
private void	ensureServers(ServerDescription description)
private java.util.Set<ServerAddress>	getAllServerAddresses(ServerDescription serverDescription)
private ServerDescription	getConnectingServerDescription(ServerAddress serverAddress)
private java.util.List<ServerDescription>	getNewServerDescriptionList()
protected ClusterableServer	getServer(ServerAddress serverAddress) Return the server at the given address.
private boolean	handleReplicaSetMemberChanged(ServerDescription newDescription)
private boolean	handleShardRouterChanged(ServerDescription newDescription)
private boolean	handleStandAloneChanged(ServerDescription newDescription)
private boolean	hasPrimary()
private void	invalidateOldPrimaries(ServerAddress newPrimary)
private boolean	isNotAlreadyPrimary(ServerAddress address)
private boolean	isStalePrimary(ServerDescription newDescription)
private void	onChange(ChangeEvent<ServerDescription> event)
private void	removeExtraHosts(ServerDescription serverDescription)
private void	removeServer(ServerAddress serverAddress)
private void	updateDescription()

Methods inherited from class com.mongodb.BaseCluster

createServer, fireChangeEvent, getCurrentDescription, getDescription, getServer, getSettings, isClosed, updateDescription

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

clusterType

private ClusterType clusterType

replicaSetName

private java.lang.String replicaSetName

maxElectionId

private ObjectId maxElectionId

maxSetVersion

private java.lang.Integer maxSetVersion

addressToServerTupleMap

private final java.util.concurrent.ConcurrentMap<ServerAddress,MultiServerCluster.ServerTuple> addressToServerTupleMap

Constructor Detail

MultiServerCluster

public MultiServerCluster(java.lang.String clusterId,
                          ClusterSettings settings,
                          ClusterableServerFactory serverFactory,
                          ClusterListener clusterListener)

Method Detail

connect

protected void connect()

Description copied from class: BaseCluster

Try to connect to all servers

Specified by:

connect in class BaseCluster

close

public void close()

Description copied from interface: Cluster

Closes connections to the servers in the cluster. After this is called, this cluster instance can no longer be used.

Specified by:

close in interface Cluster

Overrides:

close in class BaseCluster

getServer

protected ClusterableServer getServer(ServerAddress serverAddress)

Description copied from class: BaseCluster

Return the server at the given address.

Specified by:

getServer in class BaseCluster

Parameters:

serverAddress - the address

Returns:

the server, or null if the cluster no longer contains a server at this address.

onChange

private void onChange(ChangeEvent<ServerDescription> event)

handleReplicaSetMemberChanged

private boolean handleReplicaSetMemberChanged(ServerDescription newDescription)

isStalePrimary

private boolean isStalePrimary(ServerDescription newDescription)

isNotAlreadyPrimary

private boolean isNotAlreadyPrimary(ServerAddress address)

handleShardRouterChanged

private boolean handleShardRouterChanged(ServerDescription newDescription)

handleStandAloneChanged

private boolean handleStandAloneChanged(ServerDescription newDescription)

addServer

private void addServer(ServerAddress serverAddress)

removeServer

private void removeServer(ServerAddress serverAddress)

invalidateOldPrimaries

private void invalidateOldPrimaries(ServerAddress newPrimary)

getConnectingServerDescription

private ServerDescription getConnectingServerDescription(ServerAddress serverAddress)

updateDescription

private void updateDescription()

getNewServerDescriptionList

private java.util.List<ServerDescription> getNewServerDescriptionList()

ensureServers

private void ensureServers(ServerDescription description)

hasPrimary

private boolean hasPrimary()

addNewHosts

private void addNewHosts(java.util.Set<java.lang.String> hosts)

removeExtraHosts

private void removeExtraHosts(ServerDescription serverDescription)

getAllServerAddresses

private java.util.Set<ServerAddress> getAllServerAddresses(ServerDescription serverDescription)

addHostsToSet

private void addHostsToSet(java.util.Set<java.lang.String> hosts,
                           java.util.Set<ServerAddress> retVal)