@Deprecated public class DBPort extends java.lang.Object implements Connection
| Modifier and Type | Class and Description |
|---|---|
(package private) class |
DBPort.ActiveState
Deprecated.
|
(package private) class |
DBPort.Authenticator
Deprecated.
|
(package private) class |
DBPort.GSSAPIAuthenticator
Deprecated.
|
(package private) class |
DBPort.NativeAuthenticator
Deprecated.
|
(package private) static interface |
DBPort.Operation<T>
Deprecated.
|
(package private) class |
DBPort.PlainAuthenticator
Deprecated.
|
(package private) class |
DBPort.SaslAuthenticator
Deprecated.
|
(package private) class |
DBPort.ScramSha1Authenticator
Deprecated.
|
(package private) class |
DBPort.X509Authenticator
Deprecated.
|
| Modifier and Type | Field and Description |
|---|---|
private DBPort.ActiveState |
_activeState
Deprecated.
|
private ServerAddress |
_addr
Deprecated.
|
private DBDecoder |
_decoder
Deprecated.
|
private java.io.InputStream |
_in
Deprecated.
|
private java.util.logging.Logger |
_logger
Deprecated.
|
private MongoOptions |
_options
Deprecated.
|
private java.io.OutputStream |
_out
Deprecated.
|
private static java.util.logging.Logger |
_rootLogger
Deprecated.
|
private ServerAddress |
_sa
Deprecated.
|
private ServerVersion |
_serverVersion
Deprecated.
|
private java.net.Socket |
_socket
Deprecated.
|
private java.util.Set<java.lang.String> |
authenticatedDatabases
Deprecated.
|
private boolean |
closed
Deprecated.
|
(package private) static long |
CONN_RETRY_TIME_MS
Deprecated.
|
private int |
generation
Deprecated.
|
private long |
lastUsedAt
Deprecated.
|
private long |
openedAt
Deprecated.
|
static int |
PORT
Deprecated.
the default port
|
private PooledConnectionProvider |
provider
Deprecated.
|
private long |
usageCount
Deprecated.
|
(package private) static boolean |
USE_NAGLE
Deprecated.
|
| Modifier | Constructor and Description |
|---|---|
|
DBPort(ServerAddress addr)
Deprecated.
creates a new DBPort
|
(package private) |
DBPort(ServerAddress addr,
Mongo mongo,
MongoOptions options)
Deprecated.
|
(package private) |
DBPort(ServerAddress addr,
PooledConnectionProvider pool,
Mongo mongo,
int generation)
Deprecated.
|
private |
DBPort(ServerAddress addr,
PooledConnectionProvider pool,
Mongo mongo,
MongoOptions options,
int generation)
Deprecated.
|
| Modifier and Type | Method and Description |
|---|---|
(package private) CommandResult |
authenticate(Mongo mongo,
MongoCredential credentials)
Deprecated.
|
(package private) Response |
call(OutMessage msg,
DBCollection coll)
Deprecated.
|
(package private) Response |
call(OutMessage msg,
DBCollection coll,
DBDecoder decoder)
Deprecated.
|
(package private) void |
checkAuth(Mongo mongo)
Deprecated.
|
void |
close()
Deprecated.
closes the underlying connection and streams
|
private CommandResult |
convertToCommandResult(DBObject cmd,
Response res)
Deprecated.
|
(package private) <T> T |
doOperation(DBPort.Operation<T> operation)
Deprecated.
|
void |
ensureOpen()
Deprecated.
makes sure that a connection to the server has been opened
|
private void |
ensureOpen(Mongo mongo)
Deprecated.
makes sure that a connection to the server has been opened
|
(package private) DBPort.ActiveState |
getActiveState()
Deprecated.
|
(package private) ServerAddress |
getAddress()
Deprecated.
|
(package private) java.util.Set<java.lang.String> |
getAuthenticatedDatabases()
Deprecated.
|
(package private) DBDecoder |
getDecoder()
Deprecated.
|
int |
getGeneration()
Deprecated.
Gets the generation of this connection.
|
(package private) java.io.InputStream |
getInputStream()
Deprecated.
|
(package private) CommandResult |
getLastError(DB db,
WriteConcern concern)
Deprecated.
|
long |
getLastUsedAt()
Deprecated.
Returns the time at which this connection was last used, or
Long.MAX_VALUE if it has not yet been used. |
(package private) int |
getLocalPort()
Deprecated.
|
long |
getOpenedAt()
Deprecated.
Returns the time at which this connection was opened, or
Long.MAX_VALUE if it has not yet been opened. |
(package private) java.io.OutputStream |
getOutputStream()
Deprecated.
|
DBPortPool |
getPool()
Deprecated.
Gets the pool that this port belongs to.
|
(package private) PooledConnectionProvider |
getProvider()
Deprecated.
|
(package private) ServerVersion |
getServerVersion()
Deprecated.
|
long |
getUsageCount()
Deprecated.
|
(package private) static ServerVersion |
getVersion(CommandResult buildInfoResult)
Deprecated.
|
int |
hashCode()
Deprecated.
|
java.lang.String |
host()
Deprecated.
returns a String representation of the target host
|
boolean |
isClosed()
Deprecated.
|
private void |
reset()
Deprecated.
|
(package private) CommandResult |
runCommand(DB db,
DBObject cmd)
Deprecated.
|
(package private) CommandResult |
runCommand(DB db,
DBObject cmd,
int maxBsonObjectSize)
Deprecated.
|
(package private) CommandResult |
runCommand(DB db,
DBObject cmd,
ReadPreference readPreference,
int maxBsonObjectSize)
Deprecated.
|
(package private) void |
say(OutMessage msg)
Deprecated.
|
ServerAddress |
serverAddress()
Deprecated.
|
(package private) void |
setActiveState(DBPort.ActiveState activeState)
Deprecated.
|
java.lang.String |
toString()
Deprecated.
|
(package private) CommandResult |
tryGetLastError(DB db,
long last,
WriteConcern concern)
Deprecated.
|
public static final int PORT
static final boolean USE_NAGLE
static final long CONN_RETRY_TIME_MS
private static java.util.logging.Logger _rootLogger
private volatile boolean closed
private final long openedAt
private volatile long lastUsedAt
private final int generation
private final PooledConnectionProvider provider
private final ServerAddress _sa
private final ServerAddress _addr
private final MongoOptions _options
private final java.util.logging.Logger _logger
private final DBDecoder _decoder
private volatile java.net.Socket _socket
private volatile java.io.InputStream _in
private volatile java.io.OutputStream _out
private volatile ServerVersion _serverVersion
private final java.util.Set<java.lang.String> authenticatedDatabases
private volatile long usageCount
private volatile DBPort.ActiveState _activeState
public DBPort(ServerAddress addr)
addr - the server addressDBPort(ServerAddress addr, PooledConnectionProvider pool, Mongo mongo, int generation)
DBPort(ServerAddress addr, Mongo mongo, MongoOptions options)
private DBPort(ServerAddress addr, PooledConnectionProvider pool, Mongo mongo, MongoOptions options, int generation)
public int getGeneration()
getGeneration in interface Connectionpublic long getOpenedAt()
Long.MAX_VALUE if it has not yet been opened.getOpenedAt in interface Connectionpublic long getLastUsedAt()
Long.MAX_VALUE if it has not yet been used.getLastUsedAt in interface ConnectionResponse call(OutMessage msg, DBCollection coll) throws java.io.IOException
java.io.IOExceptionResponse call(OutMessage msg, DBCollection coll, DBDecoder decoder) throws java.io.IOException
java.io.IOExceptionvoid say(OutMessage msg) throws java.io.IOException
java.io.IOException<T> T doOperation(DBPort.Operation<T> operation) throws java.io.IOException
java.io.IOExceptionvoid setActiveState(DBPort.ActiveState activeState)
CommandResult getLastError(DB db, WriteConcern concern) throws java.io.IOException
java.io.IOExceptionCommandResult runCommand(DB db, DBObject cmd) throws java.io.IOException
java.io.IOExceptionCommandResult runCommand(DB db, DBObject cmd, int maxBsonObjectSize) throws java.io.IOException
java.io.IOExceptionCommandResult runCommand(DB db, DBObject cmd, ReadPreference readPreference, int maxBsonObjectSize) throws java.io.IOException
java.io.IOExceptionprivate CommandResult convertToCommandResult(DBObject cmd, Response res)
CommandResult tryGetLastError(DB db, long last, WriteConcern concern) throws java.io.IOException
java.io.IOExceptionjava.io.OutputStream getOutputStream()
throws java.io.IOException
java.io.IOExceptionjava.io.InputStream getInputStream()
throws java.io.IOException
java.io.IOExceptionpublic void ensureOpen()
throws java.io.IOException
java.io.IOExceptionprivate void ensureOpen(Mongo mongo) throws java.io.IOException
mongo - java.io.IOExceptionstatic ServerVersion getVersion(CommandResult buildInfoResult)
public int hashCode()
hashCode in class java.lang.Objectpublic java.lang.String host()
public ServerAddress serverAddress()
DBDecoder getDecoder()
public java.lang.String toString()
toString in class java.lang.ObjectDBPort.ActiveState getActiveState()
int getLocalPort()
ServerAddress getAddress()
public boolean isClosed()
isClosed in interface Connectionpublic void close()
close in interface Connectionprivate void reset()
CommandResult authenticate(Mongo mongo, MongoCredential credentials)
void checkAuth(Mongo mongo) throws java.io.IOException
java.io.IOExceptionpublic DBPortPool getPool()
public long getUsageCount()
ServerVersion getServerVersion()
PooledConnectionProvider getProvider()
java.util.Set<java.lang.String> getAuthenticatedDatabases()