(package private) void |
X509Authenticator.authenticate(InternalConnection connection,
ConnectionDescription connectionDescription) |
void |
SaslAuthenticator.authenticate(InternalConnection connection,
ConnectionDescription connectionDescription) |
void |
NativeAuthenticator.authenticate(InternalConnection connection,
ConnectionDescription connectionDescription) |
(package private) void |
DefaultAuthenticator.authenticate(InternalConnection connection,
ConnectionDescription connectionDescription) |
(package private) abstract void |
Authenticator.authenticate(InternalConnection connection,
ConnectionDescription connectionDescription) |
private void |
InternalStreamConnectionInitializer.authenticateAll(InternalConnection internalConnection,
ConnectionDescription connectionDescription) |
(package private) void |
X509Authenticator.authenticateAsync(InternalConnection connection,
ConnectionDescription connectionDescription,
SingleResultCallback<java.lang.Void> callback) |
(package private) void |
SaslAuthenticator.authenticateAsync(InternalConnection connection,
ConnectionDescription connectionDescription,
SingleResultCallback<java.lang.Void> callback) |
(package private) void |
NativeAuthenticator.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) |
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 static MongoCommandException |
CommandHelper.createCommandFailureException(BsonDocument reply,
InternalConnection internalConnection) |
private SingleResultCallback<ConnectionDescription> |
InternalStreamConnectionInitializer.createConnectionDescriptionCallback(InternalConnection internalConnection,
SingleResultCallback<ConnectionDescription> callback) |
WriteConcernResult |
WriteProtocol.execute(InternalConnection connection) |
BulkWriteResult |
WriteCommandProtocol.execute(InternalConnection connection) |
WriteConcernResult |
UpdateProtocol.execute(InternalConnection connection) |
BulkWriteResult |
UpdateCommandProtocol.execute(InternalConnection connection) |
QueryResult<T> |
QueryProtocol.execute(InternalConnection connection) |
T |
Protocol.execute(InternalConnection connection)
Execute the protocol.
|
java.lang.Void |
KillCursorProtocol.execute(InternalConnection connection) |
WriteConcernResult |
InsertProtocol.execute(InternalConnection connection) |
BulkWriteResult |
InsertCommandProtocol.execute(InternalConnection connection) |
QueryResult<T> |
GetMoreProtocol.execute(InternalConnection connection) |
WriteConcernResult |
DeleteProtocol.execute(InternalConnection connection) |
BulkWriteResult |
DeleteCommandProtocol.execute(InternalConnection connection) |
T |
CommandProtocol.execute(InternalConnection connection) |
<T> T |
ProtocolExecutor.execute(Protocol<T> protocol,
InternalConnection connection) |
<T> T |
DefaultServer.DefaultServerProtocolExecutor.execute(Protocol<T> protocol,
InternalConnection connection) |
void |
WriteCommandProtocol.executeAsync(InternalConnection connection,
SingleResultCallback<BulkWriteResult> callback) |
void |
UpdateCommandProtocol.executeAsync(InternalConnection connection,
SingleResultCallback<BulkWriteResult> callback) |
void |
InsertCommandProtocol.executeAsync(InternalConnection connection,
SingleResultCallback<BulkWriteResult> callback) |
void |
DeleteCommandProtocol.executeAsync(InternalConnection connection,
SingleResultCallback<BulkWriteResult> callback) |
void |
QueryProtocol.executeAsync(InternalConnection connection,
SingleResultCallback<QueryResult<T>> callback) |
void |
GetMoreProtocol.executeAsync(InternalConnection connection,
SingleResultCallback<QueryResult<T>> callback) |
void |
Protocol.executeAsync(InternalConnection connection,
SingleResultCallback<T> callback)
Execute the protocol asynchronously.
|
void |
CommandProtocol.executeAsync(InternalConnection connection,
SingleResultCallback<T> callback) |
void |
KillCursorProtocol.executeAsync(InternalConnection connection,
SingleResultCallback<java.lang.Void> callback) |
void |
WriteProtocol.executeAsync(InternalConnection connection,
SingleResultCallback<WriteConcernResult> callback) |
void |
UpdateProtocol.executeAsync(InternalConnection connection,
SingleResultCallback<WriteConcernResult> callback) |
void |
InsertProtocol.executeAsync(InternalConnection connection,
SingleResultCallback<WriteConcernResult> callback) |
void |
DeleteProtocol.executeAsync(InternalConnection connection,
SingleResultCallback<WriteConcernResult> callback) |
<T> void |
ProtocolExecutor.executeAsync(Protocol<T> protocol,
InternalConnection connection,
SingleResultCallback<T> callback) |
<T> void |
DefaultServer.DefaultServerProtocolExecutor.executeAsync(Protocol<T> protocol,
InternalConnection connection,
SingleResultCallback<T> callback) |
private void |
WriteProtocol.executeAsync(RequestMessage requestMessage,
InternalConnection connection,
SingleResultCallback<WriteConcernResult> callback) |
private void |
WriteCommandProtocol.executeBatchesAsync(InternalConnection connection,
BaseWriteCommandMessage message,
BulkWriteBatchCombiner bulkWriteBatchCombiner,
int batchNum,
int currentRangeStartIndex,
SingleResultCallback<BulkWriteResult> callback) |
(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 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 |
InternalStreamConnectionInitializer.initialize(InternalConnection internalConnection) |
ConnectionDescription |
InternalConnectionInitializer.initialize(InternalConnection internalConnection) |
void |
InternalStreamConnectionInitializer.initializeAsync(InternalConnection internalConnection,
SingleResultCallback<ConnectionDescription> callback) |
void |
InternalConnectionInitializer.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.receiveCommandDocument(InternalConnection internalConnection,
CommandMessage message) |
private static BsonDocument |
CommandHelper.receiveCommandResult(InternalConnection internalConnection,
CommandMessage message) |
private BsonDocument |
WriteCommandProtocol.receiveMessage(InternalConnection connection,
RequestMessage message) |
private static ReplyMessage<BsonDocument> |
CommandHelper.receiveReply(InternalConnection internalConnection,
CommandMessage message) |
private static void |
CommandHelper.receiveReplyAsync(InternalConnection internalConnection,
CommandMessage message,
SingleResultCallback<ReplyMessage<BsonDocument>> callback) |
private void |
WriteCommandProtocol.sendFailedEvent(InternalConnection connection,
BaseWriteCommandMessage message,
long startTimeNanos,
java.lang.Throwable t) |
private void |
WriteProtocol.sendFailedEvent(InternalConnection connection,
RequestMessage message,
boolean sentCommandStartedEvent,
java.lang.Throwable t,
long startTimeNanos) |
private void |
CommandProtocol.sendMessage(CommandMessage message,
InternalConnection connection) |
private void |
GetMoreProtocol.sendMessage(GetMoreMessage message,
InternalConnection connection) |
private BaseWriteCommandMessage |
WriteCommandProtocol.sendMessage(InternalConnection connection,
BaseWriteCommandMessage message,
int batchNum) |
private static CommandMessage |
CommandHelper.sendMessage(java.lang.String database,
BsonDocument command,
InternalConnection internalConnection) |
private void |
WriteCommandProtocol.sendMessageAsync(InternalConnection connection,
ByteBufferBsonOutput buffer,
BaseWriteCommandMessage message,
long startTimeNanos,
SingleResultCallback<BulkWriteResult> clientCallback,
SingleResultCallback<BsonDocument> callback) |
private static void |
CommandHelper.sendMessageAsync(java.lang.String database,
BsonDocument command,
InternalConnection internalConnection,
SingleResultCallback<CommandMessage> callback) |
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 |
WriteCommandProtocol.sendStartedEvent(InternalConnection connection,
BaseWriteCommandMessage message,
ByteBufferBsonOutput bsonOutput,
RequestMessage.EncodingMetadata encodingMetadata) |
private void |
CommandProtocol.sendStartedEvent(InternalConnection connection,
ByteBufferBsonOutput bsonOutput,
CommandMessage message,
int documentPosition) |
private void |
WriteProtocol.sendStartedEvent(InternalConnection connection,
RequestMessage message,
RequestMessage.EncodingMetadata encodingMetadata,
ByteBufferBsonOutput bsonOutput) |
private void |
WriteCommandProtocol.sendSucceededEvent(InternalConnection connection,
BaseWriteCommandMessage message,
long startTimeNanos,
BsonDocument result) |
private void |
WriteProtocol.sendSucceededEvent(InternalConnection connection,
RequestMessage message,
BsonDocument responseDocument,
long startTimeNanos) |
private void |
WriteProtocol.sendSucceededEvent(InternalConnection connection,
RequestMessage message,
RequestMessage nextMessage,
WriteConcernException e,
long startTimeNanos) |
private void |
WriteProtocol.sendSucceededEvent(InternalConnection connection,
RequestMessage message,
RequestMessage nextMessage,
WriteConcernResult writeConcernResult,
long startTimeNanos) |