com.mongodb

Class DBTCPConnector

java.lang.Object

com.mongodb.DBTCPConnector

All Implemented Interfaces:

DBConnector

Deprecated.

This class is NOT part of the public API. It will be dropped in 3.x releases.

@Deprecated
public class DBTCPConnector
extends java.lang.Object
implements DBConnector

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
(package private) class	DBTCPConnector.MyPort Deprecated.
(package private) static class	DBTCPConnector.PinnedRequestStatus Deprecated.

Field Summary

Fields

Modifier and Type	Field and Description
private boolean	_closed Deprecated.
private Mongo	_mongo Deprecated.
private DBTCPConnector.MyPort	_myPort Deprecated.
private Cluster	cluster Deprecated.
private ClusterConnectionMode	connectionMode Deprecated.
private MongosHAServerSelector	mongosHAServerSelector Deprecated.
private static java.util.concurrent.atomic.AtomicInteger	NEXT_CLUSTER_ID Deprecated.
private ClusterType	type Deprecated.

Constructor Summary

Constructors

Constructor and Description
DBTCPConnector(Mongo mongo) Deprecated.

Method Summary

Modifier and Type	Method and Description
private WriteResult	_checkWriteError(DB db, DBPort port, WriteConcern concern) Deprecated.
CommandResult	authenticate(MongoCredential credentials) Deprecated. Authenticate using the given credentials.
Response	call(DB db, DBCollection coll, OutMessage m, ServerAddress hostNeeded, DBDecoder decoder) Deprecated. does a read operation on the database
Response	call(DB db, DBCollection coll, OutMessage m, ServerAddress hostNeeded, int retries) Deprecated. does a read operation on the database
Response	call(DB db, DBCollection coll, OutMessage m, ServerAddress hostNeeded, int retries, ReadPreference readPref, DBDecoder decoder) Deprecated. does a read operation on the database
void	close() Deprecated.
private ServerSelector	createServerSelector(ReadPreference readPreference) Deprecated.
java.lang.String	debugString() Deprecated.
(package private) <T> T	doOperation(DB db, DBPort port, DBPort.Operation<T> operation) Deprecated.
ServerAddress	getAddress() Deprecated.
java.util.List<ServerAddress>	getAllAddress() Deprecated. Gets the list of seed server addresses
private ClusterDescription	getClusterDescription() Deprecated.
private int	getClusterWaitTimeMS() Deprecated.
private int	getConnectionWaitTimeMS() Deprecated.
java.lang.String	getConnectPoint() Deprecated.
DBPortPool	getDBPortPool(ServerAddress addr) Deprecated. Gets the DBPortPool associated with a ServerAddress.
int	getMaxBsonObjectSize() Deprecated. Gets the maximum size for a BSON object supported by the current master server.
private MongosHAServerSelector	getMongosHAServerSelector() Deprecated.
(package private) DBTCPConnector.MyPort	getMyPort() Deprecated.
(package private) DBPort	getPort(ReadPreference readPreference) Deprecated.
(package private) DBPort	getPrimaryPort() Deprecated.
ReplicaSetStatus	getReplicaSetStatus() Deprecated.
private Server	getServer(ServerSelector serverSelector) Deprecated.
java.util.List<ServerAddress>	getServerAddressList() Deprecated. Gets the list of server addresses currently seen by the connector.
(package private) ServerDescription	getServerDescription(ServerAddress address) Deprecated.
private ClusterType	getType() Deprecated.
private Response	innerCall(DB db, DBCollection coll, OutMessage m, ServerAddress hostNeeded, int remainingRetries, ReadPreference readPref, DBDecoder decoder) Deprecated.
(package private) boolean	isMongosConnection() Deprecated.
boolean	isOpen() Deprecated. returns true if the connector is in a usable state
(package private) void	releasePort(DBPort port) Deprecated.
void	requestDone() Deprecated. End the current "request", if this thread is in one.
void	requestEnsureConnection() Deprecated. Ensures that a connection exists for the "consistent request"
void	requestStart() Deprecated. Start a "request".
WriteResult	say(DB db, OutMessage m, WriteConcern concern) Deprecated. does a write operation
(package private) WriteResult	say(DB db, OutMessage m, WriteConcern concern, DBPort port) Deprecated.
WriteResult	say(DB db, OutMessage m, WriteConcern concern, ServerAddress hostNeeded) Deprecated. does a write operation
private boolean	shouldRetryQuery(ReadPreference readPreference, DBCollection coll, java.io.IOException ioe, int remainingRetries) Deprecated.
void	start() Deprecated.
void	updatePortPool(ServerAddress addr) Deprecated. Assigns a new DBPortPool for a given ServerAddress.

Methods inherited from class java.lang.Object

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

Field Detail

NEXT_CLUSTER_ID

private static final java.util.concurrent.atomic.AtomicInteger NEXT_CLUSTER_ID

Deprecated.

_closed

private volatile boolean _closed

Deprecated.

_mongo

private final Mongo _mongo

Deprecated.

cluster

private Cluster cluster

Deprecated.

_myPort

private final DBTCPConnector.MyPort _myPort

Deprecated.

connectionMode

private final ClusterConnectionMode connectionMode

Deprecated.

type

private ClusterType type

Deprecated.

mongosHAServerSelector

private MongosHAServerSelector mongosHAServerSelector

Deprecated.

Constructor Detail

DBTCPConnector

public DBTCPConnector(Mongo mongo)

Deprecated.

Parameters:

mongo - the Mongo instance

Throws:

MongoException

Method Detail

start

public void start()

Deprecated.

requestStart

public void requestStart()

Deprecated.

Start a "request". A "request" is a group of operations in which order matters. Examples include inserting a document and then performing a query which expects that document to have been inserted, or performing an operation and then using com.mongodb.Mongo.getLastError to perform error-checking on that operation. When a thread performs operations in a "request", all operations will be performed on the same socket, so they will be correctly ordered.

Specified by:

requestStart in interface DBConnector

requestDone

public void requestDone()

Deprecated.

End the current "request", if this thread is in one. By ending a request when it is safe to do so the built-in connection- pool is allowed to reassign requests to different sockets in order to more effectively balance load. See requestStart for more information.

Specified by:

requestDone in interface DBConnector

requestEnsureConnection

public void requestEnsureConnection()

Deprecated.

Description copied from interface: DBConnector

Ensures that a connection exists for the "consistent request"

Specified by:

requestEnsureConnection in interface DBConnector

Throws:

MongoException

_checkWriteError

private WriteResult _checkWriteError(DB db,
                                     DBPort port,
                                     WriteConcern concern)
                              throws java.io.IOException

Deprecated.

Throws:

java.io.IOException

say

public WriteResult say(DB db,
                       OutMessage m,
                       WriteConcern concern)

Deprecated.

Description copied from interface: DBConnector

does a write operation

Specified by:

say in interface DBConnector

Parameters:

db -

m -

concern -

Returns:

Throws:

MongoException

say

public WriteResult say(DB db,
                       OutMessage m,
                       WriteConcern concern,
                       ServerAddress hostNeeded)

Deprecated.

Description copied from interface: DBConnector

does a write operation

Specified by:

say in interface DBConnector

Parameters:

db -

m -

concern -

hostNeeded -

Returns:

Throws:

MongoException

say

WriteResult say(DB db,
                OutMessage m,
                WriteConcern concern,
                DBPort port)

Deprecated.

doOperation

<T> T doOperation(DB db,
                  DBPort port,
                  DBPort.Operation<T> operation)

Deprecated.

call

public Response call(DB db,
                     DBCollection coll,
                     OutMessage m,
                     ServerAddress hostNeeded,
                     DBDecoder decoder)

Deprecated.

Description copied from interface: DBConnector

does a read operation on the database

Specified by:

call in interface DBConnector

Parameters:

db -

coll -

m -

hostNeeded -

decoder -

Returns:

Throws:

MongoException

call

public Response call(DB db,
                     DBCollection coll,
                     OutMessage m,
                     ServerAddress hostNeeded,
                     int retries)

Deprecated.

Description copied from interface: DBConnector

does a read operation on the database

Specified by:

call in interface DBConnector

Parameters:

db -

coll -

m -

hostNeeded -

retries -

Returns:

Throws:

MongoException

call

public Response call(DB db,
                     DBCollection coll,
                     OutMessage m,
                     ServerAddress hostNeeded,
                     int retries,
                     ReadPreference readPref,
                     DBDecoder decoder)

Deprecated.

Description copied from interface: DBConnector

does a read operation on the database

Specified by:

call in interface DBConnector

Parameters:

db -

coll -

m -

hostNeeded -

readPref -

decoder -

retries - number of retries in case of error

Returns:

Throws:

MongoException

innerCall

private Response innerCall(DB db,
                           DBCollection coll,
                           OutMessage m,
                           ServerAddress hostNeeded,
                           int remainingRetries,
                           ReadPreference readPref,
                           DBDecoder decoder)

Deprecated.

getAddress

public ServerAddress getAddress()

Deprecated.

getAllAddress

public java.util.List<ServerAddress> getAllAddress()

Deprecated.

Gets the list of seed server addresses

Returns:

getServerAddressList

public java.util.List<ServerAddress> getServerAddressList()

Deprecated.

Gets the list of server addresses currently seen by the connector. This includes addresses auto-discovered from a replica set.

Returns:

Throws:

MongoException

getReplicaSetStatus

public ReplicaSetStatus getReplicaSetStatus()

Deprecated.

isMongosConnection

boolean isMongosConnection()

Deprecated.

getConnectPoint

public java.lang.String getConnectPoint()

Deprecated.

shouldRetryQuery

private boolean shouldRetryQuery(ReadPreference readPreference,
                                 DBCollection coll,
                                 java.io.IOException ioe,
                                 int remainingRetries)

Deprecated.

getClusterDescription

private ClusterDescription getClusterDescription()

Deprecated.

getClusterWaitTimeMS

private int getClusterWaitTimeMS()

Deprecated.

getConnectionWaitTimeMS

private int getConnectionWaitTimeMS()

Deprecated.

getPrimaryPort

DBPort getPrimaryPort()

Deprecated.

getPort

DBPort getPort(ReadPreference readPreference)

Deprecated.

releasePort

void releasePort(DBPort port)

Deprecated.

getServerDescription

ServerDescription getServerDescription(ServerAddress address)

Deprecated.

createServerSelector

private ServerSelector createServerSelector(ReadPreference readPreference)

Deprecated.

getType

private ClusterType getType()

Deprecated.

getMongosHAServerSelector

private MongosHAServerSelector getMongosHAServerSelector()

Deprecated.

debugString

public java.lang.String debugString()

Deprecated.

close

public void close()

Deprecated.

updatePortPool

public void updatePortPool(ServerAddress addr)

Deprecated.

Assigns a new DBPortPool for a given ServerAddress. This is used to obtain a new pool when the resolved IP of a host changes, for example. User application should not have to call this method directly.

Parameters:

addr -

getDBPortPool

public DBPortPool getDBPortPool(ServerAddress addr)

Deprecated.

Gets the DBPortPool associated with a ServerAddress.

Parameters:

addr -

Returns:

isOpen

public boolean isOpen()

Deprecated.

Description copied from interface: DBConnector

returns true if the connector is in a usable state

Specified by:

isOpen in interface DBConnector

Returns:

authenticate

public CommandResult authenticate(MongoCredential credentials)

Deprecated.

Description copied from interface: DBConnector

Authenticate using the given credentials.

Specified by:

authenticate in interface DBConnector

Parameters:

credentials - the credentials.

Returns:

the result of the authentication command, if successful

getMaxBsonObjectSize

public int getMaxBsonObjectSize()

Deprecated.

Gets the maximum size for a BSON object supported by the current master server. Note that this value may change over time depending on which server is master.

Returns:

the maximum size, or 0 if not obtained from servers yet.

getMyPort

DBTCPConnector.MyPort getMyPort()

Deprecated.

getServer

private Server getServer(ServerSelector serverSelector)

Deprecated.