void |
NativeAuthenticator.authenticate(InternalConnection connection,
ConnectionDescription connectionDescription) |
(package private) void |
X509Authenticator.authenticate(InternalConnection connection,
ConnectionDescription connectionDescription) |
(package private) void |
DefaultAuthenticator.authenticate(InternalConnection connection,
ConnectionDescription connectionDescription) |
(package private) abstract void |
Authenticator.authenticate(InternalConnection connection,
ConnectionDescription connectionDescription) |
void |
SaslAuthenticator.authenticate(InternalConnection connection,
ConnectionDescription connectionDescription) |
private void |
InternalStreamConnectionInitializer.authenticateAll(InternalConnection internalConnection,
ConnectionDescription connectionDescription) |
(package private) void |
NativeAuthenticator.authenticateAsync(InternalConnection connection,
ConnectionDescription connectionDescription,
SingleResultCallback<java.lang.Void> callback) |
(package private) void |
X509Authenticator.authenticateAsync(InternalConnection connection,
ConnectionDescription connectionDescription,
SingleResultCallback<java.lang.Void> callback) |
(package private) void |
DefaultAuthenticator.authenticateAsync(InternalConnection connection,
ConnectionDescription connectionDescription,
SingleResultCallback<java.lang.Void> callback) |
(package private) abstract void |
Authenticator.authenticateAsync(InternalConnection connection,
ConnectionDescription connectionDescription,
SingleResultCallback<java.lang.Void> callback) |
(package private) void |
SaslAuthenticator.authenticateAsync(InternalConnection connection,
ConnectionDescription connectionDescription,
SingleResultCallback<java.lang.Void> callback) |
private ConnectionDescription |
InternalStreamConnectionInitializer.completeConnectionDescriptionInitialization(InternalConnection internalConnection,
ConnectionDescription connectionDescription) |
private void |
InternalStreamConnectionInitializer.completeConnectionDescriptionInitializationAsync(InternalConnection internalConnection,
ConnectionDescription connectionDescription,
SingleResultCallback<ConnectionDescription> callback) |
Connection |
DefaultConnectionFactory.create(InternalConnection internalConnection,
ProtocolExecutor executor,
ClusterConnectionMode clusterConnectionMode) |
Connection |
ConnectionFactory.create(InternalConnection internalConnection,
ProtocolExecutor executor,
ClusterConnectionMode clusterConnectionMode) |
AsyncConnection |
DefaultConnectionFactory.createAsync(InternalConnection internalConnection,
ProtocolExecutor executor,
ClusterConnectionMode clusterConnectionMode) |
AsyncConnection |
ConnectionFactory.createAsync(InternalConnection internalConnection,
ProtocolExecutor executor,
ClusterConnectionMode clusterConnectionMode) |
private SingleResultCallback<ConnectionDescription> |
InternalStreamConnectionInitializer.createConnectionDescriptionCallback(InternalConnection internalConnection,
SingleResultCallback<ConnectionDescription> callback) |
<T> T |
DefaultServer.DefaultServerProtocolExecutor.execute(CommandProtocol<T> protocol,
InternalConnection connection,
SessionContext sessionContext) |
<T> T |
ProtocolExecutor.execute(CommandProtocol<T> protocol,
InternalConnection connection,
SessionContext sessionContext) |
java.lang.Void |
KillCursorProtocol.execute(InternalConnection connection) |
T |
CommandProtocol.execute(InternalConnection connection) |
QueryResult<T> |
GetMoreProtocol.execute(InternalConnection connection) |
T |
LegacyProtocol.execute(InternalConnection connection) |
QueryResult<T> |
QueryProtocol.execute(InternalConnection connection) |
WriteConcernResult |
InsertProtocol.execute(InternalConnection connection) |
WriteConcernResult |
WriteProtocol.execute(InternalConnection connection) |
WriteConcernResult |
UpdateProtocol.execute(InternalConnection connection) |
WriteConcernResult |
DeleteProtocol.execute(InternalConnection connection) |
T |
CommandProtocolImpl.execute(InternalConnection connection) |
<T> T |
DefaultServer.DefaultServerProtocolExecutor.execute(LegacyProtocol<T> protocol,
InternalConnection connection) |
<T> T |
ProtocolExecutor.execute(LegacyProtocol<T> protocol,
InternalConnection connection) |
<T> void |
DefaultServer.DefaultServerProtocolExecutor.executeAsync(CommandProtocol<T> protocol,
InternalConnection connection,
SessionContext sessionContext,
SingleResultCallback<T> callback) |
<T> void |
ProtocolExecutor.executeAsync(CommandProtocol<T> protocol,
InternalConnection connection,
SessionContext sessionContext,
SingleResultCallback<T> callback) |
void |
GetMoreProtocol.executeAsync(InternalConnection connection,
SingleResultCallback<QueryResult<T>> callback) |
void |
QueryProtocol.executeAsync(InternalConnection connection,
SingleResultCallback<QueryResult<T>> callback) |
void |
CommandProtocol.executeAsync(InternalConnection connection,
SingleResultCallback<T> callback) |
void |
LegacyProtocol.executeAsync(InternalConnection connection,
SingleResultCallback<T> callback) |
void |
CommandProtocolImpl.executeAsync(InternalConnection connection,
SingleResultCallback<T> callback) |
void |
KillCursorProtocol.executeAsync(InternalConnection connection,
SingleResultCallback<java.lang.Void> callback) |
void |
InsertProtocol.executeAsync(InternalConnection connection,
SingleResultCallback<WriteConcernResult> callback) |
void |
WriteProtocol.executeAsync(InternalConnection connection,
SingleResultCallback<WriteConcernResult> callback) |
void |
UpdateProtocol.executeAsync(InternalConnection connection,
SingleResultCallback<WriteConcernResult> callback) |
void |
DeleteProtocol.executeAsync(InternalConnection connection,
SingleResultCallback<WriteConcernResult> callback) |
<T> void |
DefaultServer.DefaultServerProtocolExecutor.executeAsync(LegacyProtocol<T> protocol,
InternalConnection connection,
SingleResultCallback<T> callback) |
<T> void |
ProtocolExecutor.executeAsync(LegacyProtocol<T> protocol,
InternalConnection connection,
SingleResultCallback<T> callback) |
private void |
WriteProtocol.executeAsync(RequestMessage requestMessage,
InternalConnection connection,
SingleResultCallback<WriteConcernResult> callback) |
(package private) static BsonDocument |
CommandHelper.executeCommand(java.lang.String database,
BsonDocument command,
ClusterClock clusterClock,
InternalConnection internalConnection) |
(package private) static BsonDocument |
CommandHelper.executeCommand(java.lang.String database,
BsonDocument command,
InternalConnection internalConnection) |
(package private) static void |
CommandHelper.executeCommandAsync(java.lang.String database,
BsonDocument command,
InternalConnection internalConnection,
SingleResultCallback<BsonDocument> callback) |
(package private) static BsonDocument |
CommandHelper.executeCommandWithoutCheckingForFailure(java.lang.String database,
BsonDocument command,
InternalConnection internalConnection) |
private CommandMessage |
CommandProtocolImpl.getCommandMessage(InternalConnection connection) |
private static CommandMessage |
CommandHelper.getCommandMessage(java.lang.String database,
BsonDocument command,
InternalConnection internalConnection) |
private ConnectionId |
DefaultConnectionPool.getId(InternalConnection internalConnection) |
private void |
DefaultConnectionPool.incrementGenerationOnSocketException(InternalConnection connection,
java.lang.Throwable t)
If there was a socket exception that wasn't some form of interrupted read, increment the generation count so that any connections
created prior will be discarded.
|
ConnectionDescription |
InternalConnectionInitializer.initialize(InternalConnection internalConnection) |
ConnectionDescription |
InternalStreamConnectionInitializer.initialize(InternalConnection internalConnection) |
void |
InternalConnectionInitializer.initializeAsync(InternalConnection internalConnection,
SingleResultCallback<ConnectionDescription> callback) |
void |
InternalStreamConnectionInitializer.initializeAsync(InternalConnection internalConnection,
SingleResultCallback<ConnectionDescription> callback) |
private ConnectionDescription |
InternalStreamConnectionInitializer.initializeConnectionDescription(InternalConnection internalConnection) |
private void |
InternalStreamConnectionInitializer.initializeConnectionDescriptionAsync(InternalConnection internalConnection,
SingleResultCallback<ConnectionDescription> callback) |
private ServerDescription |
DefaultServerMonitor.ServerMonitorRunnable.lookupServerDescription(InternalConnection connection) |
private static BsonDocument |
CommandHelper.sendAndReceive(java.lang.String database,
BsonDocument command,
ClusterClock clusterClock,
InternalConnection internalConnection) |
private void |
WriteProtocol.sendFailedEvent(InternalConnection connection,
RequestMessage message,
boolean sentCommandStartedEvent,
java.lang.Throwable t,
long startTimeNanos) |
private void |
GetMoreProtocol.sendMessage(GetMoreMessage message,
InternalConnection connection) |
private boolean |
QueryProtocol.sendQueryStartedEvent(InternalConnection connection,
QueryMessage message,
ByteBufferBsonOutput bsonOutput,
RequestMessage.EncodingMetadata metadata) |
private BsonDocument |
SaslAuthenticator.sendSaslContinue(BsonInt32 conversationId,
byte[] outToken,
InternalConnection connection) |
private void |
SaslAuthenticator.sendSaslContinueAsync(BsonInt32 conversationId,
byte[] outToken,
InternalConnection connection,
SingleResultCallback<BsonDocument> callback) |
private BsonDocument |
SaslAuthenticator.sendSaslStart(byte[] outToken,
InternalConnection connection) |
private void |
SaslAuthenticator.sendSaslStartAsync(byte[] outToken,
InternalConnection connection,
SingleResultCallback<BsonDocument> callback) |
private void |
WriteProtocol.sendStartedEvent(InternalConnection connection,
RequestMessage message,
RequestMessage.EncodingMetadata encodingMetadata,
ByteBufferBsonOutput bsonOutput) |
private void |
WriteProtocol.sendSucceededEvent(InternalConnection connection,
RequestMessage message,
BsonDocument responseDocument,
long startTimeNanos) |
private void |
WriteProtocol.sendSucceededEvent(InternalConnection connection,
RequestMessage message,
long startTimeNanos) |