final class com.mongodb.operation.OperationHelper
minor version: 0
major version: 59
flags: flags: (0x0030) ACC_FINAL, ACC_SUPER
this_class: com.mongodb.operation.OperationHelper
super_class: java.lang.Object
{
public static final com.mongodb.diagnostics.logging.Logger LOGGER;
descriptor: Lcom/mongodb/diagnostics/logging/Logger;
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
static void <clinit>();
descriptor: ()V
flags: (0x0008) ACC_STATIC
Code:
stack=1, locals=0, args_size=0
0: ldc "operation"
invokestatic com.mongodb.diagnostics.logging.Loggers.getLogger:(Ljava/lang/String;)Lcom/mongodb/diagnostics/logging/Logger;
putstatic com.mongodb.operation.OperationHelper.LOGGER:Lcom/mongodb/diagnostics/logging/Logger;
return
LocalVariableTable:
Start End Slot Name Signature
static void validateReadConcern(com.mongodb.connection.Connection, com.mongodb.ReadConcern);
descriptor: (Lcom/mongodb/connection/Connection;Lcom/mongodb/ReadConcern;)V
flags: (0x0008) ACC_STATIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
invokeinterface com.mongodb.connection.Connection.getDescription:()Lcom/mongodb/connection/ConnectionDescription;
aload 1
invokestatic com.mongodb.operation.OperationHelper.validateReadConcern:(Lcom/mongodb/connection/ConnectionDescription;Lcom/mongodb/ReadConcern;)V
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 connection Lcom/mongodb/connection/Connection;
0 2 1 readConcern Lcom/mongodb/ReadConcern;
MethodParameters:
Name Flags
connection final
readConcern final
static void validateReadConcern(com.mongodb.connection.ConnectionDescription, com.mongodb.ReadConcern);
descriptor: (Lcom/mongodb/connection/ConnectionDescription;Lcom/mongodb/ReadConcern;)V
flags: (0x0008) ACC_STATIC
Code:
stack=7, locals=2, args_size=2
start local 0 start local 1 0: aload 0
invokestatic com.mongodb.internal.operation.ServerVersionHelper.serverIsAtLeastVersionThreeDotTwo:(Lcom/mongodb/connection/ConnectionDescription;)Z
ifne 4
aload 1
invokevirtual com.mongodb.ReadConcern.isServerDefault:()Z
ifne 4
1: new java.lang.IllegalArgumentException
dup
ldc "ReadConcern not supported by server version: %s"
iconst_1
anewarray java.lang.Object
dup
iconst_0
2: aload 0
invokevirtual com.mongodb.connection.ConnectionDescription.getServerVersion:()Lcom/mongodb/connection/ServerVersion;
aastore
3: invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
invokespecial java.lang.IllegalArgumentException.<init>:(Ljava/lang/String;)V
athrow
4: StackMap locals:
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 description Lcom/mongodb/connection/ConnectionDescription;
0 5 1 readConcern Lcom/mongodb/ReadConcern;
MethodParameters:
Name Flags
description final
readConcern final
static void validateReadConcern(com.mongodb.connection.AsyncConnection, com.mongodb.ReadConcern, com.mongodb.operation.OperationHelper$AsyncCallableWithConnection);
descriptor: (Lcom/mongodb/connection/AsyncConnection;Lcom/mongodb/ReadConcern;Lcom/mongodb/operation/OperationHelper$AsyncCallableWithConnection;)V
flags: (0x0008) ACC_STATIC
Code:
stack=7, locals=4, args_size=3
start local 0 start local 1 start local 2 0: aconst_null
astore 3
start local 3 1: aload 0
invokeinterface com.mongodb.connection.AsyncConnection.getDescription:()Lcom/mongodb/connection/ConnectionDescription;
invokestatic com.mongodb.internal.operation.ServerVersionHelper.serverIsAtLeastVersionThreeDotTwo:(Lcom/mongodb/connection/ConnectionDescription;)Z
ifne 5
aload 1
invokevirtual com.mongodb.ReadConcern.isServerDefault:()Z
ifne 5
2: new java.lang.IllegalArgumentException
dup
ldc "ReadConcern not supported by server version: %s"
iconst_1
anewarray java.lang.Object
dup
iconst_0
3: aload 0
invokeinterface com.mongodb.connection.AsyncConnection.getDescription:()Lcom/mongodb/connection/ConnectionDescription;
invokevirtual com.mongodb.connection.ConnectionDescription.getServerVersion:()Lcom/mongodb/connection/ServerVersion;
aastore
4: invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
invokespecial java.lang.IllegalArgumentException.<init>:(Ljava/lang/String;)V
astore 3
5: StackMap locals: java.lang.Throwable
StackMap stack:
aload 2
aload 0
aload 3
invokeinterface com.mongodb.operation.OperationHelper$AsyncCallableWithConnection.call:(Lcom/mongodb/connection/AsyncConnection;Ljava/lang/Throwable;)V
6: return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 connection Lcom/mongodb/connection/AsyncConnection;
0 7 1 readConcern Lcom/mongodb/ReadConcern;
0 7 2 callable Lcom/mongodb/operation/OperationHelper$AsyncCallableWithConnection;
1 7 3 throwable Ljava/lang/Throwable;
MethodParameters:
Name Flags
connection final
readConcern final
callable final
static void validateReadConcern(com.mongodb.binding.AsyncConnectionSource, com.mongodb.connection.AsyncConnection, com.mongodb.ReadConcern, com.mongodb.operation.OperationHelper$AsyncCallableWithConnectionAndSource);
descriptor: (Lcom/mongodb/binding/AsyncConnectionSource;Lcom/mongodb/connection/AsyncConnection;Lcom/mongodb/ReadConcern;Lcom/mongodb/operation/OperationHelper$AsyncCallableWithConnectionAndSource;)V
flags: (0x0008) ACC_STATIC
Code:
stack=6, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 1
aload 2
new com.mongodb.operation.OperationHelper$1
dup
aload 3
aload 0
invokespecial com.mongodb.operation.OperationHelper$1.<init>:(Lcom/mongodb/operation/OperationHelper$AsyncCallableWithConnectionAndSource;Lcom/mongodb/binding/AsyncConnectionSource;)V
invokestatic com.mongodb.operation.OperationHelper.validateReadConcern:(Lcom/mongodb/connection/AsyncConnection;Lcom/mongodb/ReadConcern;Lcom/mongodb/operation/OperationHelper$AsyncCallableWithConnection;)V
1: return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 source Lcom/mongodb/binding/AsyncConnectionSource;
0 2 1 connection Lcom/mongodb/connection/AsyncConnection;
0 2 2 readConcern Lcom/mongodb/ReadConcern;
0 2 3 callable Lcom/mongodb/operation/OperationHelper$AsyncCallableWithConnectionAndSource;
MethodParameters:
Name Flags
source final
connection final
readConcern final
callable final
static void validateCollation(com.mongodb.connection.Connection, com.mongodb.client.model.Collation);
descriptor: (Lcom/mongodb/connection/Connection;Lcom/mongodb/client/model/Collation;)V
flags: (0x0008) ACC_STATIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
invokeinterface com.mongodb.connection.Connection.getDescription:()Lcom/mongodb/connection/ConnectionDescription;
aload 1
invokestatic com.mongodb.operation.OperationHelper.validateCollation:(Lcom/mongodb/connection/ConnectionDescription;Lcom/mongodb/client/model/Collation;)V
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 connection Lcom/mongodb/connection/Connection;
0 2 1 collation Lcom/mongodb/client/model/Collation;
MethodParameters:
Name Flags
connection final
collation final
static void validateCollation(com.mongodb.connection.ConnectionDescription, com.mongodb.client.model.Collation);
descriptor: (Lcom/mongodb/connection/ConnectionDescription;Lcom/mongodb/client/model/Collation;)V
flags: (0x0008) ACC_STATIC
Code:
stack=7, locals=2, args_size=2
start local 0 start local 1 0: aload 1
ifnull 4
aload 0
invokestatic com.mongodb.internal.operation.ServerVersionHelper.serverIsAtLeastVersionThreeDotFour:(Lcom/mongodb/connection/ConnectionDescription;)Z
ifne 4
1: new java.lang.IllegalArgumentException
dup
ldc "Collation not supported by server version: %s"
iconst_1
anewarray java.lang.Object
dup
iconst_0
2: aload 0
invokevirtual com.mongodb.connection.ConnectionDescription.getServerVersion:()Lcom/mongodb/connection/ServerVersion;
aastore
3: invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
invokespecial java.lang.IllegalArgumentException.<init>:(Ljava/lang/String;)V
athrow
4: StackMap locals:
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 connectionDescription Lcom/mongodb/connection/ConnectionDescription;
0 5 1 collation Lcom/mongodb/client/model/Collation;
MethodParameters:
Name Flags
connectionDescription final
collation final
static void validateCollationAndWriteConcern(com.mongodb.connection.ConnectionDescription, com.mongodb.client.model.Collation, com.mongodb.WriteConcern);
descriptor: (Lcom/mongodb/connection/ConnectionDescription;Lcom/mongodb/client/model/Collation;Lcom/mongodb/WriteConcern;)V
flags: (0x0008) ACC_STATIC
Code:
stack=7, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 1
ifnull 4
aload 0
invokestatic com.mongodb.internal.operation.ServerVersionHelper.serverIsAtLeastVersionThreeDotFour:(Lcom/mongodb/connection/ConnectionDescription;)Z
ifne 4
1: new java.lang.IllegalArgumentException
dup
ldc "Collation not supported by server version: %s"
iconst_1
anewarray java.lang.Object
dup
iconst_0
2: aload 0
invokevirtual com.mongodb.connection.ConnectionDescription.getServerVersion:()Lcom/mongodb/connection/ServerVersion;
aastore
3: invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
invokespecial java.lang.IllegalArgumentException.<init>:(Ljava/lang/String;)V
athrow
4: StackMap locals:
StackMap stack:
aload 1
ifnull 6
aload 2
invokevirtual com.mongodb.WriteConcern.isAcknowledged:()Z
ifne 6
5: new com.mongodb.MongoClientException
dup
ldc "Specifying collation with an unacknowledged WriteConcern is not supported"
invokespecial com.mongodb.MongoClientException.<init>:(Ljava/lang/String;)V
athrow
6: StackMap locals:
StackMap stack:
return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 connectionDescription Lcom/mongodb/connection/ConnectionDescription;
0 7 1 collation Lcom/mongodb/client/model/Collation;
0 7 2 writeConcern Lcom/mongodb/WriteConcern;
MethodParameters:
Name Flags
connectionDescription final
collation final
writeConcern final
static void validateCollation(com.mongodb.connection.AsyncConnection, com.mongodb.client.model.Collation, com.mongodb.operation.OperationHelper$AsyncCallableWithConnection);
descriptor: (Lcom/mongodb/connection/AsyncConnection;Lcom/mongodb/client/model/Collation;Lcom/mongodb/operation/OperationHelper$AsyncCallableWithConnection;)V
flags: (0x0008) ACC_STATIC
Code:
stack=7, locals=4, args_size=3
start local 0 start local 1 start local 2 0: aconst_null
astore 3
start local 3 1: aload 0
invokeinterface com.mongodb.connection.AsyncConnection.getDescription:()Lcom/mongodb/connection/ConnectionDescription;
invokestatic com.mongodb.internal.operation.ServerVersionHelper.serverIsAtLeastVersionThreeDotFour:(Lcom/mongodb/connection/ConnectionDescription;)Z
ifne 5
aload 1
ifnull 5
2: new java.lang.IllegalArgumentException
dup
ldc "Collation not supported by server version: %s"
iconst_1
anewarray java.lang.Object
dup
iconst_0
3: aload 0
invokeinterface com.mongodb.connection.AsyncConnection.getDescription:()Lcom/mongodb/connection/ConnectionDescription;
invokevirtual com.mongodb.connection.ConnectionDescription.getServerVersion:()Lcom/mongodb/connection/ServerVersion;
aastore
4: invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
invokespecial java.lang.IllegalArgumentException.<init>:(Ljava/lang/String;)V
astore 3
5: StackMap locals: java.lang.Throwable
StackMap stack:
aload 2
aload 0
aload 3
invokeinterface com.mongodb.operation.OperationHelper$AsyncCallableWithConnection.call:(Lcom/mongodb/connection/AsyncConnection;Ljava/lang/Throwable;)V
6: return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 connection Lcom/mongodb/connection/AsyncConnection;
0 7 1 collation Lcom/mongodb/client/model/Collation;
0 7 2 callable Lcom/mongodb/operation/OperationHelper$AsyncCallableWithConnection;
1 7 3 throwable Ljava/lang/Throwable;
MethodParameters:
Name Flags
connection final
collation final
callable final
static void validateCollation(com.mongodb.binding.AsyncConnectionSource, com.mongodb.connection.AsyncConnection, com.mongodb.client.model.Collation, com.mongodb.operation.OperationHelper$AsyncCallableWithConnectionAndSource);
descriptor: (Lcom/mongodb/binding/AsyncConnectionSource;Lcom/mongodb/connection/AsyncConnection;Lcom/mongodb/client/model/Collation;Lcom/mongodb/operation/OperationHelper$AsyncCallableWithConnectionAndSource;)V
flags: (0x0008) ACC_STATIC
Code:
stack=6, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 1
aload 2
new com.mongodb.operation.OperationHelper$2
dup
aload 3
aload 0
invokespecial com.mongodb.operation.OperationHelper$2.<init>:(Lcom/mongodb/operation/OperationHelper$AsyncCallableWithConnectionAndSource;Lcom/mongodb/binding/AsyncConnectionSource;)V
invokestatic com.mongodb.operation.OperationHelper.validateCollation:(Lcom/mongodb/connection/AsyncConnection;Lcom/mongodb/client/model/Collation;Lcom/mongodb/operation/OperationHelper$AsyncCallableWithConnection;)V
1: return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 source Lcom/mongodb/binding/AsyncConnectionSource;
0 2 1 connection Lcom/mongodb/connection/AsyncConnection;
0 2 2 collation Lcom/mongodb/client/model/Collation;
0 2 3 callable Lcom/mongodb/operation/OperationHelper$AsyncCallableWithConnectionAndSource;
MethodParameters:
Name Flags
source final
connection final
collation final
callable final
static void validateWriteRequestCollations(com.mongodb.connection.ConnectionDescription, java.util.List<? extends com.mongodb.bulk.WriteRequest>, com.mongodb.WriteConcern);
descriptor: (Lcom/mongodb/connection/ConnectionDescription;Ljava/util/List;Lcom/mongodb/WriteConcern;)V
flags: (0x0008) ACC_STATIC
Code:
stack=3, locals=6, args_size=3
start local 0 start local 1 start local 2 0: aconst_null
astore 3
start local 3 1: aload 1
invokeinterface java.util.List.iterator:()Ljava/util/Iterator;
astore 5
goto 10
StackMap locals: com.mongodb.connection.ConnectionDescription java.util.List com.mongodb.WriteConcern com.mongodb.client.model.Collation top java.util.Iterator
StackMap stack:
2: aload 5
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast com.mongodb.bulk.WriteRequest
astore 4
start local 4 3: aload 4
instanceof com.mongodb.bulk.UpdateRequest
ifeq 6
4: aload 4
checkcast com.mongodb.bulk.UpdateRequest
invokevirtual com.mongodb.bulk.UpdateRequest.getCollation:()Lcom/mongodb/client/model/Collation;
astore 3
5: goto 8
StackMap locals: com.mongodb.connection.ConnectionDescription java.util.List com.mongodb.WriteConcern com.mongodb.client.model.Collation com.mongodb.bulk.WriteRequest java.util.Iterator
StackMap stack:
6: aload 4
instanceof com.mongodb.bulk.DeleteRequest
ifeq 8
7: aload 4
checkcast com.mongodb.bulk.DeleteRequest
invokevirtual com.mongodb.bulk.DeleteRequest.getCollation:()Lcom/mongodb/client/model/Collation;
astore 3
8: StackMap locals:
StackMap stack:
aload 3
ifnull 10
9: goto 11
end local 4 10: StackMap locals: com.mongodb.connection.ConnectionDescription java.util.List com.mongodb.WriteConcern com.mongodb.client.model.Collation top java.util.Iterator
StackMap stack:
aload 5
invokeinterface java.util.Iterator.hasNext:()Z
ifne 2
11: StackMap locals: com.mongodb.connection.ConnectionDescription java.util.List com.mongodb.WriteConcern com.mongodb.client.model.Collation
StackMap stack:
aload 0
aload 3
aload 2
invokestatic com.mongodb.operation.OperationHelper.validateCollationAndWriteConcern:(Lcom/mongodb/connection/ConnectionDescription;Lcom/mongodb/client/model/Collation;Lcom/mongodb/WriteConcern;)V
12: return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 13 0 connectionDescription Lcom/mongodb/connection/ConnectionDescription;
0 13 1 requests Ljava/util/List<+Lcom/mongodb/bulk/WriteRequest;>;
0 13 2 writeConcern Lcom/mongodb/WriteConcern;
1 13 3 collation Lcom/mongodb/client/model/Collation;
3 10 4 request Lcom/mongodb/bulk/WriteRequest;
Signature: (Lcom/mongodb/connection/ConnectionDescription;Ljava/util/List<+Lcom/mongodb/bulk/WriteRequest;>;Lcom/mongodb/WriteConcern;)V
MethodParameters:
Name Flags
connectionDescription final
requests final
writeConcern final
static void validateWriteRequests(com.mongodb.connection.ConnectionDescription, java.lang.Boolean, java.util.List<? extends com.mongodb.bulk.WriteRequest>, com.mongodb.WriteConcern);
descriptor: (Lcom/mongodb/connection/ConnectionDescription;Ljava/lang/Boolean;Ljava/util/List;Lcom/mongodb/WriteConcern;)V
flags: (0x0008) ACC_STATIC
Code:
stack=3, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
aload 1
aload 3
invokestatic com.mongodb.operation.OperationHelper.checkBypassDocumentValidationIsSupported:(Lcom/mongodb/connection/ConnectionDescription;Ljava/lang/Boolean;Lcom/mongodb/WriteConcern;)V
1: aload 0
aload 2
aload 3
invokestatic com.mongodb.operation.OperationHelper.validateWriteRequestCollations:(Lcom/mongodb/connection/ConnectionDescription;Ljava/util/List;Lcom/mongodb/WriteConcern;)V
2: return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 connectionDescription Lcom/mongodb/connection/ConnectionDescription;
0 3 1 bypassDocumentValidation Ljava/lang/Boolean;
0 3 2 requests Ljava/util/List<+Lcom/mongodb/bulk/WriteRequest;>;
0 3 3 writeConcern Lcom/mongodb/WriteConcern;
Signature: (Lcom/mongodb/connection/ConnectionDescription;Ljava/lang/Boolean;Ljava/util/List<+Lcom/mongodb/bulk/WriteRequest;>;Lcom/mongodb/WriteConcern;)V
MethodParameters:
Name Flags
connectionDescription final
bypassDocumentValidation final
requests final
writeConcern final
static void validateWriteRequests(com.mongodb.connection.AsyncConnection, java.lang.Boolean, java.util.List<? extends com.mongodb.bulk.WriteRequest>, com.mongodb.WriteConcern, com.mongodb.operation.OperationHelper$AsyncCallableWithConnection);
descriptor: (Lcom/mongodb/connection/AsyncConnection;Ljava/lang/Boolean;Ljava/util/List;Lcom/mongodb/WriteConcern;Lcom/mongodb/operation/OperationHelper$AsyncCallableWithConnection;)V
flags: (0x0008) ACC_STATIC
Code:
stack=4, locals=6, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: aload 0
invokeinterface com.mongodb.connection.AsyncConnection.getDescription:()Lcom/mongodb/connection/ConnectionDescription;
aload 1
aload 2
aload 3
invokestatic com.mongodb.operation.OperationHelper.validateWriteRequests:(Lcom/mongodb/connection/ConnectionDescription;Ljava/lang/Boolean;Ljava/util/List;Lcom/mongodb/WriteConcern;)V
1: aload 4
aload 0
aconst_null
invokeinterface com.mongodb.operation.OperationHelper$AsyncCallableWithConnection.call:(Lcom/mongodb/connection/AsyncConnection;Ljava/lang/Throwable;)V
2: goto 5
StackMap locals:
StackMap stack: java.lang.Throwable
3: astore 5
start local 5 4: aload 4
aload 0
aload 5
invokeinterface com.mongodb.operation.OperationHelper$AsyncCallableWithConnection.call:(Lcom/mongodb/connection/AsyncConnection;Ljava/lang/Throwable;)V
end local 5 5: StackMap locals:
StackMap stack:
return
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 connection Lcom/mongodb/connection/AsyncConnection;
0 6 1 bypassDocumentValidation Ljava/lang/Boolean;
0 6 2 requests Ljava/util/List<+Lcom/mongodb/bulk/WriteRequest;>;
0 6 3 writeConcern Lcom/mongodb/WriteConcern;
0 6 4 callable Lcom/mongodb/operation/OperationHelper$AsyncCallableWithConnection;
4 5 5 t Ljava/lang/Throwable;
Exception table:
from to target type
0 2 3 Class java.lang.Throwable
Signature: (Lcom/mongodb/connection/AsyncConnection;Ljava/lang/Boolean;Ljava/util/List<+Lcom/mongodb/bulk/WriteRequest;>;Lcom/mongodb/WriteConcern;Lcom/mongodb/operation/OperationHelper$AsyncCallableWithConnection;)V
MethodParameters:
Name Flags
connection final
bypassDocumentValidation final
requests final
writeConcern final
callable final
static void validateIndexRequestCollations(com.mongodb.connection.Connection, java.util.List<com.mongodb.bulk.IndexRequest>);
descriptor: (Lcom/mongodb/connection/Connection;Ljava/util/List;)V
flags: (0x0008) ACC_STATIC
Code:
stack=2, locals=4, args_size=2
start local 0 start local 1 0: aload 1
invokeinterface java.util.List.iterator:()Ljava/util/Iterator;
astore 3
goto 5
StackMap locals: com.mongodb.connection.Connection java.util.List top java.util.Iterator
StackMap stack:
1: aload 3
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast com.mongodb.bulk.IndexRequest
astore 2
start local 2 2: aload 2
invokevirtual com.mongodb.bulk.IndexRequest.getCollation:()Lcom/mongodb/client/model/Collation;
ifnull 5
3: aload 0
aload 2
invokevirtual com.mongodb.bulk.IndexRequest.getCollation:()Lcom/mongodb/client/model/Collation;
invokestatic com.mongodb.operation.OperationHelper.validateCollation:(Lcom/mongodb/connection/Connection;Lcom/mongodb/client/model/Collation;)V
4: goto 6
end local 2 5: StackMap locals:
StackMap stack:
aload 3
invokeinterface java.util.Iterator.hasNext:()Z
ifne 1
6: StackMap locals: com.mongodb.connection.Connection java.util.List
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 connection Lcom/mongodb/connection/Connection;
0 7 1 requests Ljava/util/List<Lcom/mongodb/bulk/IndexRequest;>;
2 5 2 request Lcom/mongodb/bulk/IndexRequest;
Signature: (Lcom/mongodb/connection/Connection;Ljava/util/List<Lcom/mongodb/bulk/IndexRequest;>;)V
MethodParameters:
Name Flags
connection final
requests final
static void validateIndexRequestCollations(com.mongodb.connection.AsyncConnection, java.util.List<com.mongodb.bulk.IndexRequest>, com.mongodb.operation.OperationHelper$AsyncCallableWithConnection);
descriptor: (Lcom/mongodb/connection/AsyncConnection;Ljava/util/List;Lcom/mongodb/operation/OperationHelper$AsyncCallableWithConnection;)V
flags: (0x0008) ACC_STATIC
Code:
stack=5, locals=6, args_size=3
start local 0 start local 1 start local 2 0: iconst_0
istore 3
start local 3 1: aload 1
invokeinterface java.util.List.iterator:()Ljava/util/Iterator;
astore 5
goto 7
StackMap locals: com.mongodb.connection.AsyncConnection java.util.List com.mongodb.operation.OperationHelper$AsyncCallableWithConnection int top java.util.Iterator
StackMap stack:
2: aload 5
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast com.mongodb.bulk.IndexRequest
astore 4
start local 4 3: aload 4
invokevirtual com.mongodb.bulk.IndexRequest.getCollation:()Lcom/mongodb/client/model/Collation;
ifnull 7
4: iconst_1
istore 3
5: aload 0
aload 4
invokevirtual com.mongodb.bulk.IndexRequest.getCollation:()Lcom/mongodb/client/model/Collation;
new com.mongodb.operation.OperationHelper$3
dup
aload 2
invokespecial com.mongodb.operation.OperationHelper$3.<init>:(Lcom/mongodb/operation/OperationHelper$AsyncCallableWithConnection;)V
invokestatic com.mongodb.operation.OperationHelper.validateCollation:(Lcom/mongodb/connection/AsyncConnection;Lcom/mongodb/client/model/Collation;Lcom/mongodb/operation/OperationHelper$AsyncCallableWithConnection;)V
6: goto 8
end local 4 7: StackMap locals:
StackMap stack:
aload 5
invokeinterface java.util.Iterator.hasNext:()Z
ifne 2
8: StackMap locals: com.mongodb.connection.AsyncConnection java.util.List com.mongodb.operation.OperationHelper$AsyncCallableWithConnection int
StackMap stack:
iload 3
ifne 10
9: aload 2
aload 0
aconst_null
invokeinterface com.mongodb.operation.OperationHelper$AsyncCallableWithConnection.call:(Lcom/mongodb/connection/AsyncConnection;Ljava/lang/Throwable;)V
10: StackMap locals:
StackMap stack:
return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 11 0 connection Lcom/mongodb/connection/AsyncConnection;
0 11 1 requests Ljava/util/List<Lcom/mongodb/bulk/IndexRequest;>;
0 11 2 callable Lcom/mongodb/operation/OperationHelper$AsyncCallableWithConnection;
1 11 3 calledTheCallable Z
3 7 4 request Lcom/mongodb/bulk/IndexRequest;
Signature: (Lcom/mongodb/connection/AsyncConnection;Ljava/util/List<Lcom/mongodb/bulk/IndexRequest;>;Lcom/mongodb/operation/OperationHelper$AsyncCallableWithConnection;)V
MethodParameters:
Name Flags
connection final
requests final
callable final
static void validateReadConcernAndCollation(com.mongodb.connection.Connection, com.mongodb.ReadConcern, com.mongodb.client.model.Collation);
descriptor: (Lcom/mongodb/connection/Connection;Lcom/mongodb/ReadConcern;Lcom/mongodb/client/model/Collation;)V
flags: (0x0008) ACC_STATIC
Code:
stack=2, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
invokestatic com.mongodb.operation.OperationHelper.validateReadConcern:(Lcom/mongodb/connection/Connection;Lcom/mongodb/ReadConcern;)V
1: aload 0
aload 2
invokestatic com.mongodb.operation.OperationHelper.validateCollation:(Lcom/mongodb/connection/Connection;Lcom/mongodb/client/model/Collation;)V
2: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 connection Lcom/mongodb/connection/Connection;
0 3 1 readConcern Lcom/mongodb/ReadConcern;
0 3 2 collation Lcom/mongodb/client/model/Collation;
MethodParameters:
Name Flags
connection final
readConcern final
collation final
static void validateReadConcernAndCollation(com.mongodb.connection.ConnectionDescription, com.mongodb.ReadConcern, com.mongodb.client.model.Collation);
descriptor: (Lcom/mongodb/connection/ConnectionDescription;Lcom/mongodb/ReadConcern;Lcom/mongodb/client/model/Collation;)V
flags: (0x0008) ACC_STATIC
Code:
stack=2, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
invokestatic com.mongodb.operation.OperationHelper.validateReadConcern:(Lcom/mongodb/connection/ConnectionDescription;Lcom/mongodb/ReadConcern;)V
1: aload 0
aload 2
invokestatic com.mongodb.operation.OperationHelper.validateCollation:(Lcom/mongodb/connection/ConnectionDescription;Lcom/mongodb/client/model/Collation;)V
2: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 description Lcom/mongodb/connection/ConnectionDescription;
0 3 1 readConcern Lcom/mongodb/ReadConcern;
0 3 2 collation Lcom/mongodb/client/model/Collation;
MethodParameters:
Name Flags
description final
readConcern final
collation final
static void validateReadConcernAndCollation(com.mongodb.connection.AsyncConnection, com.mongodb.ReadConcern, com.mongodb.client.model.Collation, com.mongodb.operation.OperationHelper$AsyncCallableWithConnection);
descriptor: (Lcom/mongodb/connection/AsyncConnection;Lcom/mongodb/ReadConcern;Lcom/mongodb/client/model/Collation;Lcom/mongodb/operation/OperationHelper$AsyncCallableWithConnection;)V
flags: (0x0008) ACC_STATIC
Code:
stack=6, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
aload 1
new com.mongodb.operation.OperationHelper$4
dup
aload 3
aload 2
invokespecial com.mongodb.operation.OperationHelper$4.<init>:(Lcom/mongodb/operation/OperationHelper$AsyncCallableWithConnection;Lcom/mongodb/client/model/Collation;)V
invokestatic com.mongodb.operation.OperationHelper.validateReadConcern:(Lcom/mongodb/connection/AsyncConnection;Lcom/mongodb/ReadConcern;Lcom/mongodb/operation/OperationHelper$AsyncCallableWithConnection;)V
1: return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 connection Lcom/mongodb/connection/AsyncConnection;
0 2 1 readConcern Lcom/mongodb/ReadConcern;
0 2 2 collation Lcom/mongodb/client/model/Collation;
0 2 3 callable Lcom/mongodb/operation/OperationHelper$AsyncCallableWithConnection;
MethodParameters:
Name Flags
connection final
readConcern final
collation final
callable final
static void validateReadConcernAndCollation(com.mongodb.binding.AsyncConnectionSource, com.mongodb.connection.AsyncConnection, com.mongodb.ReadConcern, com.mongodb.client.model.Collation, com.mongodb.operation.OperationHelper$AsyncCallableWithConnectionAndSource);
descriptor: (Lcom/mongodb/binding/AsyncConnectionSource;Lcom/mongodb/connection/AsyncConnection;Lcom/mongodb/ReadConcern;Lcom/mongodb/client/model/Collation;Lcom/mongodb/operation/OperationHelper$AsyncCallableWithConnectionAndSource;)V
flags: (0x0008) ACC_STATIC
Code:
stack=7, locals=5, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: aload 1
aload 2
aload 3
new com.mongodb.operation.OperationHelper$5
dup
aload 4
aload 0
invokespecial com.mongodb.operation.OperationHelper$5.<init>:(Lcom/mongodb/operation/OperationHelper$AsyncCallableWithConnectionAndSource;Lcom/mongodb/binding/AsyncConnectionSource;)V
invokestatic com.mongodb.operation.OperationHelper.validateReadConcernAndCollation:(Lcom/mongodb/connection/AsyncConnection;Lcom/mongodb/ReadConcern;Lcom/mongodb/client/model/Collation;Lcom/mongodb/operation/OperationHelper$AsyncCallableWithConnection;)V
1: return
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 source Lcom/mongodb/binding/AsyncConnectionSource;
0 2 1 connection Lcom/mongodb/connection/AsyncConnection;
0 2 2 readConcern Lcom/mongodb/ReadConcern;
0 2 3 collation Lcom/mongodb/client/model/Collation;
0 2 4 callable Lcom/mongodb/operation/OperationHelper$AsyncCallableWithConnectionAndSource;
MethodParameters:
Name Flags
source final
connection final
readConcern final
collation final
callable final
static void checkBypassDocumentValidationIsSupported(com.mongodb.connection.ConnectionDescription, java.lang.Boolean, com.mongodb.WriteConcern);
descriptor: (Lcom/mongodb/connection/ConnectionDescription;Ljava/lang/Boolean;Lcom/mongodb/WriteConcern;)V
flags: (0x0008) ACC_STATIC
Code:
stack=3, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 1
ifnull 3
aload 0
invokestatic com.mongodb.internal.operation.ServerVersionHelper.serverIsAtLeastVersionThreeDotTwo:(Lcom/mongodb/connection/ConnectionDescription;)Z
ifeq 3
1: aload 2
invokevirtual com.mongodb.WriteConcern.isAcknowledged:()Z
ifne 3
2: new com.mongodb.MongoClientException
dup
ldc "Specifying bypassDocumentValidation with an unacknowledged WriteConcern is not supported"
invokespecial com.mongodb.MongoClientException.<init>:(Ljava/lang/String;)V
athrow
3: StackMap locals:
StackMap stack:
return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 connectionDescription Lcom/mongodb/connection/ConnectionDescription;
0 4 1 bypassDocumentValidation Ljava/lang/Boolean;
0 4 2 writeConcern Lcom/mongodb/WriteConcern;
MethodParameters:
Name Flags
connectionDescription final
bypassDocumentValidation final
writeConcern final
static boolean isRetryableWrite(boolean, com.mongodb.WriteConcern, com.mongodb.connection.ServerDescription, com.mongodb.connection.ConnectionDescription, com.mongodb.session.SessionContext);
descriptor: (ZLcom/mongodb/WriteConcern;Lcom/mongodb/connection/ServerDescription;Lcom/mongodb/connection/ConnectionDescription;Lcom/mongodb/session/SessionContext;)Z
flags: (0x0008) ACC_STATIC
Code:
stack=3, locals=5, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: iload 0
ifne 2
1: iconst_0
ireturn
2: StackMap locals:
StackMap stack:
aload 1
invokevirtual com.mongodb.WriteConcern.isAcknowledged:()Z
ifne 5
3: getstatic com.mongodb.operation.OperationHelper.LOGGER:Lcom/mongodb/diagnostics/logging/Logger;
ldc "retryWrites set to true but the writeConcern is unacknowledged."
invokeinterface com.mongodb.diagnostics.logging.Logger.debug:(Ljava/lang/String;)V
4: iconst_0
ireturn
5: StackMap locals:
StackMap stack:
aload 4
invokeinterface com.mongodb.session.SessionContext.hasActiveTransaction:()Z
ifeq 8
6: getstatic com.mongodb.operation.OperationHelper.LOGGER:Lcom/mongodb/diagnostics/logging/Logger;
ldc "retryWrites set to true but in an active transaction."
invokeinterface com.mongodb.diagnostics.logging.Logger.debug:(Ljava/lang/String;)V
7: iconst_0
ireturn
8: StackMap locals:
StackMap stack:
aload 2
aload 3
aload 4
invokestatic com.mongodb.operation.OperationHelper.canRetryWrite:(Lcom/mongodb/connection/ServerDescription;Lcom/mongodb/connection/ConnectionDescription;Lcom/mongodb/session/SessionContext;)Z
ireturn
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 9 0 retryWrites Z
0 9 1 writeConcern Lcom/mongodb/WriteConcern;
0 9 2 serverDescription Lcom/mongodb/connection/ServerDescription;
0 9 3 connectionDescription Lcom/mongodb/connection/ConnectionDescription;
0 9 4 sessionContext Lcom/mongodb/session/SessionContext;
MethodParameters:
Name Flags
retryWrites final
writeConcern final
serverDescription final
connectionDescription final
sessionContext final
static boolean canRetryWrite(com.mongodb.connection.ServerDescription, com.mongodb.connection.ConnectionDescription, com.mongodb.session.SessionContext);
descriptor: (Lcom/mongodb/connection/ServerDescription;Lcom/mongodb/connection/ConnectionDescription;Lcom/mongodb/session/SessionContext;)Z
flags: (0x0008) ACC_STATIC
Code:
stack=2, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 1
invokestatic com.mongodb.internal.operation.ServerVersionHelper.serverIsLessThanVersionThreeDotSix:(Lcom/mongodb/connection/ConnectionDescription;)Z
ifeq 3
1: getstatic com.mongodb.operation.OperationHelper.LOGGER:Lcom/mongodb/diagnostics/logging/Logger;
ldc "retryWrites set to true but the server does not support retryable writes."
invokeinterface com.mongodb.diagnostics.logging.Logger.debug:(Ljava/lang/String;)V
2: iconst_0
ireturn
3: StackMap locals:
StackMap stack:
aload 0
invokevirtual com.mongodb.connection.ServerDescription.getLogicalSessionTimeoutMinutes:()Ljava/lang/Integer;
ifnonnull 6
4: getstatic com.mongodb.operation.OperationHelper.LOGGER:Lcom/mongodb/diagnostics/logging/Logger;
ldc "retryWrites set to true but the server does not have 3.6 feature compatibility enabled."
invokeinterface com.mongodb.diagnostics.logging.Logger.debug:(Ljava/lang/String;)V
5: iconst_0
ireturn
6: StackMap locals:
StackMap stack:
aload 1
invokevirtual com.mongodb.connection.ConnectionDescription.getServerType:()Lcom/mongodb/connection/ServerType;
getstatic com.mongodb.connection.ServerType.STANDALONE:Lcom/mongodb/connection/ServerType;
invokevirtual com.mongodb.connection.ServerType.equals:(Ljava/lang/Object;)Z
ifeq 9
7: getstatic com.mongodb.operation.OperationHelper.LOGGER:Lcom/mongodb/diagnostics/logging/Logger;
ldc "retryWrites set to true but the server is a standalone server."
invokeinterface com.mongodb.diagnostics.logging.Logger.debug:(Ljava/lang/String;)V
8: iconst_0
ireturn
9: StackMap locals:
StackMap stack:
aload 2
invokeinterface com.mongodb.session.SessionContext.hasSession:()Z
ifne 12
10: getstatic com.mongodb.operation.OperationHelper.LOGGER:Lcom/mongodb/diagnostics/logging/Logger;
ldc "retryWrites set to true but there is no implicit session, likely because the MongoClient was created with multiple MongoCredential instances and sessions can only be used with a single MongoCredential"
invokeinterface com.mongodb.diagnostics.logging.Logger.debug:(Ljava/lang/String;)V
11: iconst_0
ireturn
12: StackMap locals:
StackMap stack:
iconst_1
ireturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 13 0 serverDescription Lcom/mongodb/connection/ServerDescription;
0 13 1 connectionDescription Lcom/mongodb/connection/ConnectionDescription;
0 13 2 sessionContext Lcom/mongodb/session/SessionContext;
MethodParameters:
Name Flags
serverDescription final
connectionDescription final
sessionContext final
static boolean isRetryableRead(boolean, com.mongodb.connection.ServerDescription, com.mongodb.connection.ConnectionDescription, com.mongodb.session.SessionContext);
descriptor: (ZLcom/mongodb/connection/ServerDescription;Lcom/mongodb/connection/ConnectionDescription;Lcom/mongodb/session/SessionContext;)Z
flags: (0x0008) ACC_STATIC
Code:
stack=3, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: iload 0
ifne 2
1: iconst_0
ireturn
2: StackMap locals:
StackMap stack:
aload 3
invokeinterface com.mongodb.session.SessionContext.hasActiveTransaction:()Z
ifeq 5
3: getstatic com.mongodb.operation.OperationHelper.LOGGER:Lcom/mongodb/diagnostics/logging/Logger;
ldc "retryReads set to true but in an active transaction."
invokeinterface com.mongodb.diagnostics.logging.Logger.debug:(Ljava/lang/String;)V
4: iconst_0
ireturn
5: StackMap locals:
StackMap stack:
aload 1
aload 2
aload 3
invokestatic com.mongodb.operation.OperationHelper.canRetryRead:(Lcom/mongodb/connection/ServerDescription;Lcom/mongodb/connection/ConnectionDescription;Lcom/mongodb/session/SessionContext;)Z
ireturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 retryReads Z
0 6 1 serverDescription Lcom/mongodb/connection/ServerDescription;
0 6 2 connectionDescription Lcom/mongodb/connection/ConnectionDescription;
0 6 3 sessionContext Lcom/mongodb/session/SessionContext;
MethodParameters:
Name Flags
retryReads final
serverDescription final
connectionDescription final
sessionContext final
static boolean canRetryRead(com.mongodb.connection.ServerDescription, com.mongodb.connection.ConnectionDescription, com.mongodb.session.SessionContext);
descriptor: (Lcom/mongodb/connection/ServerDescription;Lcom/mongodb/connection/ConnectionDescription;Lcom/mongodb/session/SessionContext;)Z
flags: (0x0008) ACC_STATIC
Code:
stack=2, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 1
invokestatic com.mongodb.internal.operation.ServerVersionHelper.serverIsLessThanVersionThreeDotSix:(Lcom/mongodb/connection/ConnectionDescription;)Z
ifeq 3
1: getstatic com.mongodb.operation.OperationHelper.LOGGER:Lcom/mongodb/diagnostics/logging/Logger;
ldc "retryReads set to true but the server does not support retryable reads."
invokeinterface com.mongodb.diagnostics.logging.Logger.debug:(Ljava/lang/String;)V
2: iconst_0
ireturn
3: StackMap locals:
StackMap stack:
aload 0
invokevirtual com.mongodb.connection.ServerDescription.getLogicalSessionTimeoutMinutes:()Ljava/lang/Integer;
ifnonnull 6
4: getstatic com.mongodb.operation.OperationHelper.LOGGER:Lcom/mongodb/diagnostics/logging/Logger;
ldc "retryReads set to true but the server does not have 3.6 feature compatibility enabled."
invokeinterface com.mongodb.diagnostics.logging.Logger.debug:(Ljava/lang/String;)V
5: iconst_0
ireturn
6: StackMap locals:
StackMap stack:
aload 0
invokevirtual com.mongodb.connection.ServerDescription.getType:()Lcom/mongodb/connection/ServerType;
getstatic com.mongodb.connection.ServerType.STANDALONE:Lcom/mongodb/connection/ServerType;
if_acmpeq 9
aload 2
invokeinterface com.mongodb.session.SessionContext.hasSession:()Z
ifne 9
7: getstatic com.mongodb.operation.OperationHelper.LOGGER:Lcom/mongodb/diagnostics/logging/Logger;
ldc "retryReads set to true but there is no implicit session, likely because the MongoClient was created with multiple MongoCredential instances and sessions can only be used with a single MongoCredential"
invokeinterface com.mongodb.diagnostics.logging.Logger.debug:(Ljava/lang/String;)V
8: iconst_0
ireturn
9: StackMap locals:
StackMap stack:
iconst_1
ireturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 10 0 serverDescription Lcom/mongodb/connection/ServerDescription;
0 10 1 connectionDescription Lcom/mongodb/connection/ConnectionDescription;
0 10 2 sessionContext Lcom/mongodb/session/SessionContext;
MethodParameters:
Name Flags
serverDescription final
connectionDescription final
sessionContext final
static <T> com.mongodb.operation.QueryBatchCursor<T> createEmptyBatchCursor(com.mongodb.MongoNamespace, org.bson.codecs.Decoder<T>, com.mongodb.ServerAddress, int);
descriptor: (Lcom/mongodb/MongoNamespace;Lorg/bson/codecs/Decoder;Lcom/mongodb/ServerAddress;I)Lcom/mongodb/operation/QueryBatchCursor;
flags: (0x0008) ACC_STATIC
Code:
stack=9, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: new com.mongodb.operation.QueryBatchCursor
dup
new com.mongodb.connection.QueryResult
dup
aload 0
invokestatic java.util.Collections.emptyList:()Ljava/util/List;
lconst_0
1: aload 2
invokespecial com.mongodb.connection.QueryResult.<init>:(Lcom/mongodb/MongoNamespace;Ljava/util/List;JLcom/mongodb/ServerAddress;)V
2: iconst_0
iload 3
aload 1
3: invokespecial com.mongodb.operation.QueryBatchCursor.<init>:(Lcom/mongodb/connection/QueryResult;IILorg/bson/codecs/Decoder;)V
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 namespace Lcom/mongodb/MongoNamespace;
0 4 1 decoder Lorg/bson/codecs/Decoder<TT;>;
0 4 2 serverAddress Lcom/mongodb/ServerAddress;
0 4 3 batchSize I
Signature: <T:Ljava/lang/Object;>(Lcom/mongodb/MongoNamespace;Lorg/bson/codecs/Decoder<TT;>;Lcom/mongodb/ServerAddress;I)Lcom/mongodb/operation/QueryBatchCursor<TT;>;
MethodParameters:
Name Flags
namespace final
decoder final
serverAddress final
batchSize final
static <T> com.mongodb.async.AsyncBatchCursor<T> createEmptyAsyncBatchCursor(com.mongodb.MongoNamespace, com.mongodb.ServerAddress);
descriptor: (Lcom/mongodb/MongoNamespace;Lcom/mongodb/ServerAddress;)Lcom/mongodb/async/AsyncBatchCursor;
flags: (0x0008) ACC_STATIC
Code:
stack=9, locals=2, args_size=2
start local 0 start local 1 0: new com.mongodb.operation.AsyncSingleBatchQueryCursor
dup
new com.mongodb.connection.QueryResult
dup
aload 0
invokestatic java.util.Collections.emptyList:()Ljava/util/List;
lconst_0
aload 1
invokespecial com.mongodb.connection.QueryResult.<init>:(Lcom/mongodb/MongoNamespace;Ljava/util/List;JLcom/mongodb/ServerAddress;)V
invokespecial com.mongodb.operation.AsyncSingleBatchQueryCursor.<init>:(Lcom/mongodb/connection/QueryResult;)V
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 namespace Lcom/mongodb/MongoNamespace;
0 1 1 serverAddress Lcom/mongodb/ServerAddress;
Signature: <T:Ljava/lang/Object;>(Lcom/mongodb/MongoNamespace;Lcom/mongodb/ServerAddress;)Lcom/mongodb/async/AsyncBatchCursor<TT;>;
MethodParameters:
Name Flags
namespace final
serverAddress final
static <T> com.mongodb.operation.BatchCursor<T> cursorDocumentToBatchCursor(org.bson.BsonDocument, org.bson.codecs.Decoder<T>, com.mongodb.binding.ConnectionSource, int);
descriptor: (Lorg/bson/BsonDocument;Lorg/bson/codecs/Decoder;Lcom/mongodb/binding/ConnectionSource;I)Lcom/mongodb/operation/BatchCursor;
flags: (0x0008) ACC_STATIC
Code:
stack=7, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: new com.mongodb.operation.QueryBatchCursor
dup
aload 0
1: aload 2
invokeinterface com.mongodb.binding.ConnectionSource.getServerDescription:()Lcom/mongodb/connection/ServerDescription;
invokevirtual com.mongodb.connection.ServerDescription.getAddress:()Lcom/mongodb/ServerAddress;
2: invokestatic com.mongodb.operation.OperationHelper.cursorDocumentToQueryResult:(Lorg/bson/BsonDocument;Lcom/mongodb/ServerAddress;)Lcom/mongodb/connection/QueryResult;
3: iconst_0
iload 3
aload 1
aload 2
4: invokespecial com.mongodb.operation.QueryBatchCursor.<init>:(Lcom/mongodb/connection/QueryResult;IILorg/bson/codecs/Decoder;Lcom/mongodb/binding/ConnectionSource;)V
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 cursorDocument Lorg/bson/BsonDocument;
0 5 1 decoder Lorg/bson/codecs/Decoder<TT;>;
0 5 2 source Lcom/mongodb/binding/ConnectionSource;
0 5 3 batchSize I
Signature: <T:Ljava/lang/Object;>(Lorg/bson/BsonDocument;Lorg/bson/codecs/Decoder<TT;>;Lcom/mongodb/binding/ConnectionSource;I)Lcom/mongodb/operation/BatchCursor<TT;>;
MethodParameters:
Name Flags
cursorDocument final
decoder final
source final
batchSize final
static <T> com.mongodb.async.AsyncBatchCursor<T> cursorDocumentToAsyncBatchCursor(org.bson.BsonDocument, org.bson.codecs.Decoder<T>, com.mongodb.binding.AsyncConnectionSource, com.mongodb.connection.AsyncConnection, int);
descriptor: (Lorg/bson/BsonDocument;Lorg/bson/codecs/Decoder;Lcom/mongodb/binding/AsyncConnectionSource;Lcom/mongodb/connection/AsyncConnection;I)Lcom/mongodb/async/AsyncBatchCursor;
flags: (0x0008) ACC_STATIC
Code:
stack=11, locals=5, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: new com.mongodb.operation.AsyncQueryBatchCursor
dup
aload 0
1: aload 2
invokeinterface com.mongodb.binding.AsyncConnectionSource.getServerDescription:()Lcom/mongodb/connection/ServerDescription;
invokevirtual com.mongodb.connection.ServerDescription.getAddress:()Lcom/mongodb/ServerAddress;
2: invokestatic com.mongodb.operation.OperationHelper.cursorDocumentToQueryResult:(Lorg/bson/BsonDocument;Lcom/mongodb/ServerAddress;)Lcom/mongodb/connection/QueryResult;
3: iconst_0
iload 4
lconst_0
aload 1
aload 2
aload 3
aload 0
4: invokespecial com.mongodb.operation.AsyncQueryBatchCursor.<init>:(Lcom/mongodb/connection/QueryResult;IIJLorg/bson/codecs/Decoder;Lcom/mongodb/binding/AsyncConnectionSource;Lcom/mongodb/connection/AsyncConnection;Lorg/bson/BsonDocument;)V
areturn
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 cursorDocument Lorg/bson/BsonDocument;
0 5 1 decoder Lorg/bson/codecs/Decoder<TT;>;
0 5 2 source Lcom/mongodb/binding/AsyncConnectionSource;
0 5 3 connection Lcom/mongodb/connection/AsyncConnection;
0 5 4 batchSize I
Signature: <T:Ljava/lang/Object;>(Lorg/bson/BsonDocument;Lorg/bson/codecs/Decoder<TT;>;Lcom/mongodb/binding/AsyncConnectionSource;Lcom/mongodb/connection/AsyncConnection;I)Lcom/mongodb/async/AsyncBatchCursor<TT;>;
MethodParameters:
Name Flags
cursorDocument final
decoder final
source final
connection final
batchSize final
static <T> com.mongodb.connection.QueryResult<T> cursorDocumentToQueryResult(org.bson.BsonDocument, com.mongodb.ServerAddress);
descriptor: (Lorg/bson/BsonDocument;Lcom/mongodb/ServerAddress;)Lcom/mongodb/connection/QueryResult;
flags: (0x0008) ACC_STATIC
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
ldc "firstBatch"
invokestatic com.mongodb.operation.OperationHelper.cursorDocumentToQueryResult:(Lorg/bson/BsonDocument;Lcom/mongodb/ServerAddress;Ljava/lang/String;)Lcom/mongodb/connection/QueryResult;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 cursorDocument Lorg/bson/BsonDocument;
0 1 1 serverAddress Lcom/mongodb/ServerAddress;
Signature: <T:Ljava/lang/Object;>(Lorg/bson/BsonDocument;Lcom/mongodb/ServerAddress;)Lcom/mongodb/connection/QueryResult<TT;>;
MethodParameters:
Name Flags
cursorDocument final
serverAddress final
static <T> com.mongodb.connection.QueryResult<T> getMoreCursorDocumentToQueryResult(org.bson.BsonDocument, com.mongodb.ServerAddress);
descriptor: (Lorg/bson/BsonDocument;Lcom/mongodb/ServerAddress;)Lcom/mongodb/connection/QueryResult;
flags: (0x0008) ACC_STATIC
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
ldc "nextBatch"
invokestatic com.mongodb.operation.OperationHelper.cursorDocumentToQueryResult:(Lorg/bson/BsonDocument;Lcom/mongodb/ServerAddress;Ljava/lang/String;)Lcom/mongodb/connection/QueryResult;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 cursorDocument Lorg/bson/BsonDocument;
0 1 1 serverAddress Lcom/mongodb/ServerAddress;
Signature: <T:Ljava/lang/Object;>(Lorg/bson/BsonDocument;Lcom/mongodb/ServerAddress;)Lcom/mongodb/connection/QueryResult<TT;>;
MethodParameters:
Name Flags
cursorDocument final
serverAddress final
private static <T> com.mongodb.connection.QueryResult<T> cursorDocumentToQueryResult(org.bson.BsonDocument, com.mongodb.ServerAddress, java.lang.String);
descriptor: (Lorg/bson/BsonDocument;Lcom/mongodb/ServerAddress;Ljava/lang/String;)Lcom/mongodb/connection/QueryResult;
flags: (0x000a) ACC_PRIVATE, ACC_STATIC
Code:
stack=7, locals=6, args_size=3
start local 0 start local 1 start local 2 0: aload 0
ldc "id"
invokevirtual org.bson.BsonDocument.get:(Ljava/lang/Object;)Lorg/bson/BsonValue;
checkcast org.bson.BsonInt64
invokevirtual org.bson.BsonInt64.getValue:()J
lstore 3
start local 3 1: new com.mongodb.MongoNamespace
dup
aload 0
ldc "ns"
invokevirtual org.bson.BsonDocument.getString:(Ljava/lang/Object;)Lorg/bson/BsonString;
invokevirtual org.bson.BsonString.getValue:()Ljava/lang/String;
invokespecial com.mongodb.MongoNamespace.<init>:(Ljava/lang/String;)V
astore 5
start local 5 2: new com.mongodb.connection.QueryResult
dup
aload 5
aload 0
aload 2
invokestatic com.mongodb.operation.BsonDocumentWrapperHelper.toList:(Lorg/bson/BsonDocument;Ljava/lang/String;)Ljava/util/List;
3: lload 3
aload 1
4: invokespecial com.mongodb.connection.QueryResult.<init>:(Lcom/mongodb/MongoNamespace;Ljava/util/List;JLcom/mongodb/ServerAddress;)V
areturn
end local 5 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 cursorDocument Lorg/bson/BsonDocument;
0 5 1 serverAddress Lcom/mongodb/ServerAddress;
0 5 2 fieldNameContainingBatch Ljava/lang/String;
1 5 3 cursorId J
2 5 5 queryResultNamespace Lcom/mongodb/MongoNamespace;
Signature: <T:Ljava/lang/Object;>(Lorg/bson/BsonDocument;Lcom/mongodb/ServerAddress;Ljava/lang/String;)Lcom/mongodb/connection/QueryResult<TT;>;
MethodParameters:
Name Flags
cursorDocument final
serverAddress final
fieldNameContainingBatch final
static <T> com.mongodb.async.SingleResultCallback<T> releasingCallback(com.mongodb.async.SingleResultCallback<T>, com.mongodb.binding.AsyncConnectionSource);
descriptor: (Lcom/mongodb/async/SingleResultCallback;Lcom/mongodb/binding/AsyncConnectionSource;)Lcom/mongodb/async/SingleResultCallback;
flags: (0x0008) ACC_STATIC
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: new com.mongodb.operation.OperationHelper$ReferenceCountedReleasingWrappedCallback
dup
aload 0
aload 1
invokestatic java.util.Collections.singletonList:(Ljava/lang/Object;)Ljava/util/List;
invokespecial com.mongodb.operation.OperationHelper$ReferenceCountedReleasingWrappedCallback.<init>:(Lcom/mongodb/async/SingleResultCallback;Ljava/util/List;)V
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 wrapped Lcom/mongodb/async/SingleResultCallback<TT;>;
0 1 1 source Lcom/mongodb/binding/AsyncConnectionSource;
Signature: <T:Ljava/lang/Object;>(Lcom/mongodb/async/SingleResultCallback<TT;>;Lcom/mongodb/binding/AsyncConnectionSource;)Lcom/mongodb/async/SingleResultCallback<TT;>;
MethodParameters:
Name Flags
wrapped final
source final
static <T> com.mongodb.async.SingleResultCallback<T> releasingCallback(com.mongodb.async.SingleResultCallback<T>, com.mongodb.connection.AsyncConnection);
descriptor: (Lcom/mongodb/async/SingleResultCallback;Lcom/mongodb/connection/AsyncConnection;)Lcom/mongodb/async/SingleResultCallback;
flags: (0x0008) ACC_STATIC
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: new com.mongodb.operation.OperationHelper$ReferenceCountedReleasingWrappedCallback
dup
aload 0
aload 1
invokestatic java.util.Collections.singletonList:(Ljava/lang/Object;)Ljava/util/List;
invokespecial com.mongodb.operation.OperationHelper$ReferenceCountedReleasingWrappedCallback.<init>:(Lcom/mongodb/async/SingleResultCallback;Ljava/util/List;)V
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 wrapped Lcom/mongodb/async/SingleResultCallback<TT;>;
0 1 1 connection Lcom/mongodb/connection/AsyncConnection;
Signature: <T:Ljava/lang/Object;>(Lcom/mongodb/async/SingleResultCallback<TT;>;Lcom/mongodb/connection/AsyncConnection;)Lcom/mongodb/async/SingleResultCallback<TT;>;
MethodParameters:
Name Flags
wrapped final
connection final
static <T> com.mongodb.async.SingleResultCallback<T> releasingCallback(com.mongodb.async.SingleResultCallback<T>, com.mongodb.binding.AsyncConnectionSource, com.mongodb.connection.AsyncConnection);
descriptor: (Lcom/mongodb/async/SingleResultCallback;Lcom/mongodb/binding/AsyncConnectionSource;Lcom/mongodb/connection/AsyncConnection;)Lcom/mongodb/async/SingleResultCallback;
flags: (0x0008) ACC_STATIC
Code:
stack=7, locals=3, args_size=3
start local 0 start local 1 start local 2 0: new com.mongodb.operation.OperationHelper$ReferenceCountedReleasingWrappedCallback
dup
aload 0
iconst_2
anewarray com.mongodb.binding.ReferenceCounted
dup
iconst_0
aload 2
aastore
dup
iconst_1
aload 1
aastore
invokestatic java.util.Arrays.asList:([Ljava/lang/Object;)Ljava/util/List;
invokespecial com.mongodb.operation.OperationHelper$ReferenceCountedReleasingWrappedCallback.<init>:(Lcom/mongodb/async/SingleResultCallback;Ljava/util/List;)V
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 wrapped Lcom/mongodb/async/SingleResultCallback<TT;>;
0 1 1 source Lcom/mongodb/binding/AsyncConnectionSource;
0 1 2 connection Lcom/mongodb/connection/AsyncConnection;
Signature: <T:Ljava/lang/Object;>(Lcom/mongodb/async/SingleResultCallback<TT;>;Lcom/mongodb/binding/AsyncConnectionSource;Lcom/mongodb/connection/AsyncConnection;)Lcom/mongodb/async/SingleResultCallback<TT;>;
MethodParameters:
Name Flags
wrapped final
source final
connection final
static <T> com.mongodb.async.SingleResultCallback<T> releasingCallback(com.mongodb.async.SingleResultCallback<T>, com.mongodb.binding.AsyncReadBinding, com.mongodb.binding.AsyncConnectionSource, com.mongodb.connection.AsyncConnection);
descriptor: (Lcom/mongodb/async/SingleResultCallback;Lcom/mongodb/binding/AsyncReadBinding;Lcom/mongodb/binding/AsyncConnectionSource;Lcom/mongodb/connection/AsyncConnection;)Lcom/mongodb/async/SingleResultCallback;
flags: (0x0008) ACC_STATIC
Code:
stack=7, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: new com.mongodb.operation.OperationHelper$ReferenceCountedReleasingWrappedCallback
dup
aload 0
iconst_3
anewarray com.mongodb.binding.ReferenceCounted
dup
iconst_0
aload 1
aastore
dup
iconst_1
aload 3
aastore
dup
iconst_2
aload 2
aastore
invokestatic java.util.Arrays.asList:([Ljava/lang/Object;)Ljava/util/List;
invokespecial com.mongodb.operation.OperationHelper$ReferenceCountedReleasingWrappedCallback.<init>:(Lcom/mongodb/async/SingleResultCallback;Ljava/util/List;)V
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 wrapped Lcom/mongodb/async/SingleResultCallback<TT;>;
0 1 1 readBinding Lcom/mongodb/binding/AsyncReadBinding;
0 1 2 source Lcom/mongodb/binding/AsyncConnectionSource;
0 1 3 connection Lcom/mongodb/connection/AsyncConnection;
Signature: <T:Ljava/lang/Object;>(Lcom/mongodb/async/SingleResultCallback<TT;>;Lcom/mongodb/binding/AsyncReadBinding;Lcom/mongodb/binding/AsyncConnectionSource;Lcom/mongodb/connection/AsyncConnection;)Lcom/mongodb/async/SingleResultCallback<TT;>;
MethodParameters:
Name Flags
wrapped final
readBinding final
source final
connection final
static <T> T withConnection(com.mongodb.binding.ReadBinding, com.mongodb.operation.OperationHelper$CallableWithConnection<T>);
descriptor: (Lcom/mongodb/binding/ReadBinding;Lcom/mongodb/operation/OperationHelper$CallableWithConnection;)Ljava/lang/Object;
flags: (0x0008) ACC_STATIC
Code:
stack=2, locals=5, args_size=2
start local 0 start local 1 0: aload 0
invokeinterface com.mongodb.binding.ReadBinding.getReadConnectionSource:()Lcom/mongodb/binding/ConnectionSource;
astore 2
start local 2 1: aload 2
aload 1
invokestatic com.mongodb.operation.OperationHelper.withConnectionSource:(Lcom/mongodb/binding/ConnectionSource;Lcom/mongodb/operation/OperationHelper$CallableWithConnection;)Ljava/lang/Object;
astore 4
2: aload 2
invokeinterface com.mongodb.binding.ConnectionSource.release:()V
3: aload 4
areturn
4: StackMap locals: com.mongodb.binding.ReadBinding com.mongodb.operation.OperationHelper$CallableWithConnection com.mongodb.binding.ConnectionSource
StackMap stack: java.lang.Throwable
astore 3
5: aload 2
invokeinterface com.mongodb.binding.ConnectionSource.release:()V
6: aload 3
athrow
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 binding Lcom/mongodb/binding/ReadBinding;
0 7 1 callable Lcom/mongodb/operation/OperationHelper$CallableWithConnection<TT;>;
1 7 2 source Lcom/mongodb/binding/ConnectionSource;
Exception table:
from to target type
1 2 4 any
Signature: <T:Ljava/lang/Object;>(Lcom/mongodb/binding/ReadBinding;Lcom/mongodb/operation/OperationHelper$CallableWithConnection<TT;>;)TT;
MethodParameters:
Name Flags
binding final
callable final
static <T> T withConnection(com.mongodb.binding.ReadBinding, com.mongodb.operation.OperationHelper$CallableWithConnectionAndSource<T>);
descriptor: (Lcom/mongodb/binding/ReadBinding;Lcom/mongodb/operation/OperationHelper$CallableWithConnectionAndSource;)Ljava/lang/Object;
flags: (0x0008) ACC_STATIC
Code:
stack=2, locals=5, args_size=2
start local 0 start local 1 0: aload 0
invokeinterface com.mongodb.binding.ReadBinding.getReadConnectionSource:()Lcom/mongodb/binding/ConnectionSource;
astore 2
start local 2 1: aload 2
aload 1
invokestatic com.mongodb.operation.OperationHelper.withConnectionSource:(Lcom/mongodb/binding/ConnectionSource;Lcom/mongodb/operation/OperationHelper$CallableWithConnectionAndSource;)Ljava/lang/Object;
astore 4
2: aload 2
invokeinterface com.mongodb.binding.ConnectionSource.release:()V
3: aload 4
areturn
4: StackMap locals: com.mongodb.binding.ReadBinding com.mongodb.operation.OperationHelper$CallableWithConnectionAndSource com.mongodb.binding.ConnectionSource
StackMap stack: java.lang.Throwable
astore 3
5: aload 2
invokeinterface com.mongodb.binding.ConnectionSource.release:()V
6: aload 3
athrow
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 binding Lcom/mongodb/binding/ReadBinding;
0 7 1 callable Lcom/mongodb/operation/OperationHelper$CallableWithConnectionAndSource<TT;>;
1 7 2 source Lcom/mongodb/binding/ConnectionSource;
Exception table:
from to target type
1 2 4 any
Signature: <T:Ljava/lang/Object;>(Lcom/mongodb/binding/ReadBinding;Lcom/mongodb/operation/OperationHelper$CallableWithConnectionAndSource<TT;>;)TT;
MethodParameters:
Name Flags
binding final
callable final
static <T> T withReadConnectionSource(com.mongodb.binding.ReadBinding, com.mongodb.operation.OperationHelper$CallableWithSource<T>);
descriptor: (Lcom/mongodb/binding/ReadBinding;Lcom/mongodb/operation/OperationHelper$CallableWithSource;)Ljava/lang/Object;
flags: (0x0008) ACC_STATIC
Code:
stack=2, locals=5, args_size=2
start local 0 start local 1 0: aload 0
invokeinterface com.mongodb.binding.ReadBinding.getReadConnectionSource:()Lcom/mongodb/binding/ConnectionSource;
astore 2
start local 2 1: aload 1
aload 2
invokeinterface com.mongodb.operation.OperationHelper$CallableWithSource.call:(Lcom/mongodb/binding/ConnectionSource;)Ljava/lang/Object;
astore 4
2: aload 2
invokeinterface com.mongodb.binding.ConnectionSource.release:()V
3: aload 4
areturn
4: StackMap locals: com.mongodb.binding.ReadBinding com.mongodb.operation.OperationHelper$CallableWithSource com.mongodb.binding.ConnectionSource
StackMap stack: java.lang.Throwable
astore 3
5: aload 2
invokeinterface com.mongodb.binding.ConnectionSource.release:()V
6: aload 3
athrow
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 binding Lcom/mongodb/binding/ReadBinding;
0 7 1 callable Lcom/mongodb/operation/OperationHelper$CallableWithSource<TT;>;
1 7 2 source Lcom/mongodb/binding/ConnectionSource;
Exception table:
from to target type
1 2 4 any
Signature: <T:Ljava/lang/Object;>(Lcom/mongodb/binding/ReadBinding;Lcom/mongodb/operation/OperationHelper$CallableWithSource<TT;>;)TT;
MethodParameters:
Name Flags
binding final
callable final
static <T> T withReleasableConnection(com.mongodb.binding.ReadBinding, com.mongodb.MongoException, com.mongodb.operation.OperationHelper$CallableWithConnectionAndSource<T>);
descriptor: (Lcom/mongodb/binding/ReadBinding;Lcom/mongodb/MongoException;Lcom/mongodb/operation/OperationHelper$CallableWithConnectionAndSource;)Ljava/lang/Object;
flags: (0x0008) ACC_STATIC
Code:
stack=3, locals=7, args_size=3
start local 0 start local 1 start local 2 0: aconst_null
astore 3
start local 3 1: aload 0
invokeinterface com.mongodb.binding.ReadBinding.getReadConnectionSource:()Lcom/mongodb/binding/ConnectionSource;
astore 3
2: aload 3
invokeinterface com.mongodb.binding.ConnectionSource.getConnection:()Lcom/mongodb/connection/Connection;
astore 4
start local 4 3: goto 8
end local 4 StackMap locals: com.mongodb.binding.ReadBinding com.mongodb.MongoException com.mongodb.operation.OperationHelper$CallableWithConnectionAndSource com.mongodb.binding.ConnectionSource
StackMap stack: java.lang.Throwable
4: pop
5: aload 3
ifnull 7
6: aload 3
invokeinterface com.mongodb.binding.ConnectionSource.release:()V
7: StackMap locals:
StackMap stack:
aload 1
athrow
start local 4 8: StackMap locals: com.mongodb.connection.Connection
StackMap stack:
aload 2
aload 3
aload 4
invokeinterface com.mongodb.operation.OperationHelper$CallableWithConnectionAndSource.call:(Lcom/mongodb/binding/ConnectionSource;Lcom/mongodb/connection/Connection;)Ljava/lang/Object;
astore 6
9: aload 3
invokeinterface com.mongodb.binding.ConnectionSource.release:()V
10: aload 6
areturn
11: StackMap locals:
StackMap stack: java.lang.Throwable
astore 5
12: aload 3
invokeinterface com.mongodb.binding.ConnectionSource.release:()V
13: aload 5
athrow
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 14 0 binding Lcom/mongodb/binding/ReadBinding;
0 14 1 connectionException Lcom/mongodb/MongoException;
0 14 2 callable Lcom/mongodb/operation/OperationHelper$CallableWithConnectionAndSource<TT;>;
1 14 3 source Lcom/mongodb/binding/ConnectionSource;
3 4 4 connection Lcom/mongodb/connection/Connection;
8 14 4 connection Lcom/mongodb/connection/Connection;
Exception table:
from to target type
1 3 4 Class java.lang.Throwable
8 9 11 any
Signature: <T:Ljava/lang/Object;>(Lcom/mongodb/binding/ReadBinding;Lcom/mongodb/MongoException;Lcom/mongodb/operation/OperationHelper$CallableWithConnectionAndSource<TT;>;)TT;
MethodParameters:
Name Flags
binding final
connectionException final
callable final
static <T> T withConnection(com.mongodb.binding.WriteBinding, com.mongodb.operation.OperationHelper$CallableWithConnection<T>);
descriptor: (Lcom/mongodb/binding/WriteBinding;Lcom/mongodb/operation/OperationHelper$CallableWithConnection;)Ljava/lang/Object;
flags: (0x0008) ACC_STATIC
Code:
stack=2, locals=5, args_size=2
start local 0 start local 1 0: aload 0
invokeinterface com.mongodb.binding.WriteBinding.getWriteConnectionSource:()Lcom/mongodb/binding/ConnectionSource;
astore 2
start local 2 1: aload 2
aload 1
invokestatic com.mongodb.operation.OperationHelper.withConnectionSource:(Lcom/mongodb/binding/ConnectionSource;Lcom/mongodb/operation/OperationHelper$CallableWithConnection;)Ljava/lang/Object;
astore 4
2: aload 2
invokeinterface com.mongodb.binding.ConnectionSource.release:()V
3: aload 4
areturn
4: StackMap locals: com.mongodb.binding.WriteBinding com.mongodb.operation.OperationHelper$CallableWithConnection com.mongodb.binding.ConnectionSource
StackMap stack: java.lang.Throwable
astore 3
5: aload 2
invokeinterface com.mongodb.binding.ConnectionSource.release:()V
6: aload 3
athrow
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 binding Lcom/mongodb/binding/WriteBinding;
0 7 1 callable Lcom/mongodb/operation/OperationHelper$CallableWithConnection<TT;>;
1 7 2 source Lcom/mongodb/binding/ConnectionSource;
Exception table:
from to target type
1 2 4 any
Signature: <T:Ljava/lang/Object;>(Lcom/mongodb/binding/WriteBinding;Lcom/mongodb/operation/OperationHelper$CallableWithConnection<TT;>;)TT;
MethodParameters:
Name Flags
binding final
callable final
static <T> T withReleasableConnection(com.mongodb.binding.WriteBinding, com.mongodb.operation.OperationHelper$CallableWithConnectionAndSource<T>);
descriptor: (Lcom/mongodb/binding/WriteBinding;Lcom/mongodb/operation/OperationHelper$CallableWithConnectionAndSource;)Ljava/lang/Object;
flags: (0x0008) ACC_STATIC
Code:
stack=3, locals=5, args_size=2
start local 0 start local 1 0: aload 0
invokeinterface com.mongodb.binding.WriteBinding.getWriteConnectionSource:()Lcom/mongodb/binding/ConnectionSource;
astore 2
start local 2 1: aload 1
aload 2
aload 2
invokeinterface com.mongodb.binding.ConnectionSource.getConnection:()Lcom/mongodb/connection/Connection;
invokeinterface com.mongodb.operation.OperationHelper$CallableWithConnectionAndSource.call:(Lcom/mongodb/binding/ConnectionSource;Lcom/mongodb/connection/Connection;)Ljava/lang/Object;
astore 4
2: aload 2
invokeinterface com.mongodb.binding.ConnectionSource.release:()V
3: aload 4
areturn
4: StackMap locals: com.mongodb.binding.WriteBinding com.mongodb.operation.OperationHelper$CallableWithConnectionAndSource com.mongodb.binding.ConnectionSource
StackMap stack: java.lang.Throwable
astore 3
5: aload 2
invokeinterface com.mongodb.binding.ConnectionSource.release:()V
6: aload 3
athrow
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 binding Lcom/mongodb/binding/WriteBinding;
0 7 1 callable Lcom/mongodb/operation/OperationHelper$CallableWithConnectionAndSource<TT;>;
1 7 2 source Lcom/mongodb/binding/ConnectionSource;
Exception table:
from to target type
1 2 4 any
Signature: <T:Ljava/lang/Object;>(Lcom/mongodb/binding/WriteBinding;Lcom/mongodb/operation/OperationHelper$CallableWithConnectionAndSource<TT;>;)TT;
MethodParameters:
Name Flags
binding final
callable final
static <T> T withReleasableConnection(com.mongodb.binding.WriteBinding, com.mongodb.MongoException, com.mongodb.operation.OperationHelper$CallableWithConnectionAndSource<T>);
descriptor: (Lcom/mongodb/binding/WriteBinding;Lcom/mongodb/MongoException;Lcom/mongodb/operation/OperationHelper$CallableWithConnectionAndSource;)Ljava/lang/Object;
flags: (0x0008) ACC_STATIC
Code:
stack=3, locals=7, args_size=3
start local 0 start local 1 start local 2 0: aconst_null
astore 3
start local 3 1: aload 0
invokeinterface com.mongodb.binding.WriteBinding.getWriteConnectionSource:()Lcom/mongodb/binding/ConnectionSource;
astore 3
2: aload 3
invokeinterface com.mongodb.binding.ConnectionSource.getConnection:()Lcom/mongodb/connection/Connection;
astore 4
start local 4 3: goto 8
end local 4 StackMap locals: com.mongodb.binding.WriteBinding com.mongodb.MongoException com.mongodb.operation.OperationHelper$CallableWithConnectionAndSource com.mongodb.binding.ConnectionSource
StackMap stack: java.lang.Throwable
4: pop
5: aload 3
ifnull 7
6: aload 3
invokeinterface com.mongodb.binding.ConnectionSource.release:()V
7: StackMap locals:
StackMap stack:
aload 1
athrow
start local 4 8: StackMap locals: com.mongodb.connection.Connection
StackMap stack:
aload 2
aload 3
aload 4
invokeinterface com.mongodb.operation.OperationHelper$CallableWithConnectionAndSource.call:(Lcom/mongodb/binding/ConnectionSource;Lcom/mongodb/connection/Connection;)Ljava/lang/Object;
astore 6
9: aload 3
invokeinterface com.mongodb.binding.ConnectionSource.release:()V
10: aload 6
areturn
11: StackMap locals:
StackMap stack: java.lang.Throwable
astore 5
12: aload 3
invokeinterface com.mongodb.binding.ConnectionSource.release:()V
13: aload 5
athrow
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 14 0 binding Lcom/mongodb/binding/WriteBinding;
0 14 1 connectionException Lcom/mongodb/MongoException;
0 14 2 callable Lcom/mongodb/operation/OperationHelper$CallableWithConnectionAndSource<TT;>;
1 14 3 source Lcom/mongodb/binding/ConnectionSource;
3 4 4 connection Lcom/mongodb/connection/Connection;
8 14 4 connection Lcom/mongodb/connection/Connection;
Exception table:
from to target type
1 3 4 Class java.lang.Throwable
8 9 11 any
Signature: <T:Ljava/lang/Object;>(Lcom/mongodb/binding/WriteBinding;Lcom/mongodb/MongoException;Lcom/mongodb/operation/OperationHelper$CallableWithConnectionAndSource<TT;>;)TT;
MethodParameters:
Name Flags
binding final
connectionException final
callable final
static <T> T withConnectionSource(com.mongodb.binding.ConnectionSource, com.mongodb.operation.OperationHelper$CallableWithConnection<T>);
descriptor: (Lcom/mongodb/binding/ConnectionSource;Lcom/mongodb/operation/OperationHelper$CallableWithConnection;)Ljava/lang/Object;
flags: (0x0008) ACC_STATIC
Code:
stack=2, locals=5, args_size=2
start local 0 start local 1 0: aload 0
invokeinterface com.mongodb.binding.ConnectionSource.getConnection:()Lcom/mongodb/connection/Connection;
astore 2
start local 2 1: aload 1
aload 2
invokeinterface com.mongodb.operation.OperationHelper$CallableWithConnection.call:(Lcom/mongodb/connection/Connection;)Ljava/lang/Object;
astore 4
2: aload 2
invokeinterface com.mongodb.connection.Connection.release:()V
3: aload 4
areturn
4: StackMap locals: com.mongodb.binding.ConnectionSource com.mongodb.operation.OperationHelper$CallableWithConnection com.mongodb.connection.Connection
StackMap stack: java.lang.Throwable
astore 3
5: aload 2
invokeinterface com.mongodb.connection.Connection.release:()V
6: aload 3
athrow
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 source Lcom/mongodb/binding/ConnectionSource;
0 7 1 callable Lcom/mongodb/operation/OperationHelper$CallableWithConnection<TT;>;
1 7 2 connection Lcom/mongodb/connection/Connection;
Exception table:
from to target type
1 2 4 any
Signature: <T:Ljava/lang/Object;>(Lcom/mongodb/binding/ConnectionSource;Lcom/mongodb/operation/OperationHelper$CallableWithConnection<TT;>;)TT;
MethodParameters:
Name Flags
source final
callable final
static <T> T withConnectionSource(com.mongodb.binding.ConnectionSource, com.mongodb.operation.OperationHelper$CallableWithConnectionAndSource<T>);
descriptor: (Lcom/mongodb/binding/ConnectionSource;Lcom/mongodb/operation/OperationHelper$CallableWithConnectionAndSource;)Ljava/lang/Object;
flags: (0x0008) ACC_STATIC
Code:
stack=3, locals=5, args_size=2
start local 0 start local 1 0: aload 0
invokeinterface com.mongodb.binding.ConnectionSource.getConnection:()Lcom/mongodb/connection/Connection;
astore 2
start local 2 1: aload 1
aload 0
aload 2
invokeinterface com.mongodb.operation.OperationHelper$CallableWithConnectionAndSource.call:(Lcom/mongodb/binding/ConnectionSource;Lcom/mongodb/connection/Connection;)Ljava/lang/Object;
astore 4
2: aload 2
invokeinterface com.mongodb.connection.Connection.release:()V
3: aload 4
areturn
4: StackMap locals: com.mongodb.binding.ConnectionSource com.mongodb.operation.OperationHelper$CallableWithConnectionAndSource com.mongodb.connection.Connection
StackMap stack: java.lang.Throwable
astore 3
5: aload 2
invokeinterface com.mongodb.connection.Connection.release:()V
6: aload 3
athrow
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 source Lcom/mongodb/binding/ConnectionSource;
0 7 1 callable Lcom/mongodb/operation/OperationHelper$CallableWithConnectionAndSource<TT;>;
1 7 2 connection Lcom/mongodb/connection/Connection;
Exception table:
from to target type
1 2 4 any
Signature: <T:Ljava/lang/Object;>(Lcom/mongodb/binding/ConnectionSource;Lcom/mongodb/operation/OperationHelper$CallableWithConnectionAndSource<TT;>;)TT;
MethodParameters:
Name Flags
source final
callable final
static void withAsyncConnection(com.mongodb.binding.AsyncWriteBinding, com.mongodb.operation.OperationHelper$AsyncCallableWithConnection);
descriptor: (Lcom/mongodb/binding/AsyncWriteBinding;Lcom/mongodb/operation/OperationHelper$AsyncCallableWithConnection;)V
flags: (0x0008) ACC_STATIC
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: aload 0
new com.mongodb.operation.OperationHelper$AsyncCallableWithConnectionCallback
dup
aload 1
invokespecial com.mongodb.operation.OperationHelper$AsyncCallableWithConnectionCallback.<init>:(Lcom/mongodb/operation/OperationHelper$AsyncCallableWithConnection;)V
getstatic com.mongodb.operation.OperationHelper.LOGGER:Lcom/mongodb/diagnostics/logging/Logger;
invokestatic com.mongodb.internal.async.ErrorHandlingResultCallback.errorHandlingCallback:(Lcom/mongodb/async/SingleResultCallback;Lcom/mongodb/diagnostics/logging/Logger;)Lcom/mongodb/async/SingleResultCallback;
invokeinterface com.mongodb.binding.AsyncWriteBinding.getWriteConnectionSource:(Lcom/mongodb/async/SingleResultCallback;)V
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 binding Lcom/mongodb/binding/AsyncWriteBinding;
0 2 1 callable Lcom/mongodb/operation/OperationHelper$AsyncCallableWithConnection;
MethodParameters:
Name Flags
binding final
callable final
static void withAsyncConnection(com.mongodb.binding.AsyncWriteBinding, com.mongodb.operation.OperationHelper$AsyncCallableWithConnectionAndSource);
descriptor: (Lcom/mongodb/binding/AsyncWriteBinding;Lcom/mongodb/operation/OperationHelper$AsyncCallableWithConnectionAndSource;)V
flags: (0x0008) ACC_STATIC
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: aload 0
new com.mongodb.operation.OperationHelper$AsyncCallableWithConnectionAndSourceCallback
dup
aload 1
invokespecial com.mongodb.operation.OperationHelper$AsyncCallableWithConnectionAndSourceCallback.<init>:(Lcom/mongodb/operation/OperationHelper$AsyncCallableWithConnectionAndSource;)V
getstatic com.mongodb.operation.OperationHelper.LOGGER:Lcom/mongodb/diagnostics/logging/Logger;
invokestatic com.mongodb.internal.async.ErrorHandlingResultCallback.errorHandlingCallback:(Lcom/mongodb/async/SingleResultCallback;Lcom/mongodb/diagnostics/logging/Logger;)Lcom/mongodb/async/SingleResultCallback;
invokeinterface com.mongodb.binding.AsyncWriteBinding.getWriteConnectionSource:(Lcom/mongodb/async/SingleResultCallback;)V
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 binding Lcom/mongodb/binding/AsyncWriteBinding;
0 2 1 callable Lcom/mongodb/operation/OperationHelper$AsyncCallableWithConnectionAndSource;
MethodParameters:
Name Flags
binding final
callable final
static void withAsyncReadConnection(com.mongodb.binding.AsyncReadBinding, com.mongodb.operation.OperationHelper$AsyncCallableWithSource);
descriptor: (Lcom/mongodb/binding/AsyncReadBinding;Lcom/mongodb/operation/OperationHelper$AsyncCallableWithSource;)V
flags: (0x0008) ACC_STATIC
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: aload 0
new com.mongodb.operation.OperationHelper$AsyncCallableWithSourceCallback
dup
aload 1
invokespecial com.mongodb.operation.OperationHelper$AsyncCallableWithSourceCallback.<init>:(Lcom/mongodb/operation/OperationHelper$AsyncCallableWithSource;)V
getstatic com.mongodb.operation.OperationHelper.LOGGER:Lcom/mongodb/diagnostics/logging/Logger;
invokestatic com.mongodb.internal.async.ErrorHandlingResultCallback.errorHandlingCallback:(Lcom/mongodb/async/SingleResultCallback;Lcom/mongodb/diagnostics/logging/Logger;)Lcom/mongodb/async/SingleResultCallback;
invokeinterface com.mongodb.binding.AsyncReadBinding.getReadConnectionSource:(Lcom/mongodb/async/SingleResultCallback;)V
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 binding Lcom/mongodb/binding/AsyncReadBinding;
0 2 1 callable Lcom/mongodb/operation/OperationHelper$AsyncCallableWithSource;
MethodParameters:
Name Flags
binding final
callable final
static void withAsyncReadConnection(com.mongodb.binding.AsyncReadBinding, com.mongodb.operation.OperationHelper$AsyncCallableWithConnectionAndSource);
descriptor: (Lcom/mongodb/binding/AsyncReadBinding;Lcom/mongodb/operation/OperationHelper$AsyncCallableWithConnectionAndSource;)V
flags: (0x0008) ACC_STATIC
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: aload 0
new com.mongodb.operation.OperationHelper$AsyncCallableWithConnectionAndSourceCallback
dup
aload 1
invokespecial com.mongodb.operation.OperationHelper$AsyncCallableWithConnectionAndSourceCallback.<init>:(Lcom/mongodb/operation/OperationHelper$AsyncCallableWithConnectionAndSource;)V
getstatic com.mongodb.operation.OperationHelper.LOGGER:Lcom/mongodb/diagnostics/logging/Logger;
invokestatic com.mongodb.internal.async.ErrorHandlingResultCallback.errorHandlingCallback:(Lcom/mongodb/async/SingleResultCallback;Lcom/mongodb/diagnostics/logging/Logger;)Lcom/mongodb/async/SingleResultCallback;
invokeinterface com.mongodb.binding.AsyncReadBinding.getReadConnectionSource:(Lcom/mongodb/async/SingleResultCallback;)V
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 binding Lcom/mongodb/binding/AsyncReadBinding;
0 2 1 callable Lcom/mongodb/operation/OperationHelper$AsyncCallableWithConnectionAndSource;
MethodParameters:
Name Flags
binding final
callable final
private static void withAsyncConnectionSourceCallableConnection(com.mongodb.binding.AsyncConnectionSource, com.mongodb.operation.OperationHelper$AsyncCallableWithConnection);
descriptor: (Lcom/mongodb/binding/AsyncConnectionSource;Lcom/mongodb/operation/OperationHelper$AsyncCallableWithConnection;)V
flags: (0x000a) ACC_PRIVATE, ACC_STATIC
Code:
stack=5, locals=2, args_size=2
start local 0 start local 1 0: aload 0
new com.mongodb.operation.OperationHelper$6
dup
aload 0
aload 1
invokespecial com.mongodb.operation.OperationHelper$6.<init>:(Lcom/mongodb/binding/AsyncConnectionSource;Lcom/mongodb/operation/OperationHelper$AsyncCallableWithConnection;)V
invokeinterface com.mongodb.binding.AsyncConnectionSource.getConnection:(Lcom/mongodb/async/SingleResultCallback;)V
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 source Lcom/mongodb/binding/AsyncConnectionSource;
0 2 1 callable Lcom/mongodb/operation/OperationHelper$AsyncCallableWithConnection;
MethodParameters:
Name Flags
source final
callable final
private static void withAsyncConnectionSource(com.mongodb.binding.AsyncConnectionSource, com.mongodb.operation.OperationHelper$AsyncCallableWithSource);
descriptor: (Lcom/mongodb/binding/AsyncConnectionSource;Lcom/mongodb/operation/OperationHelper$AsyncCallableWithSource;)V
flags: (0x000a) ACC_PRIVATE, ACC_STATIC
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 1
aload 0
aconst_null
invokeinterface com.mongodb.operation.OperationHelper$AsyncCallableWithSource.call:(Lcom/mongodb/binding/AsyncConnectionSource;Ljava/lang/Throwable;)V
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 source Lcom/mongodb/binding/AsyncConnectionSource;
0 2 1 callable Lcom/mongodb/operation/OperationHelper$AsyncCallableWithSource;
MethodParameters:
Name Flags
source final
callable final
private static void withAsyncConnectionSource(com.mongodb.binding.AsyncConnectionSource, com.mongodb.operation.OperationHelper$AsyncCallableWithConnectionAndSource);
descriptor: (Lcom/mongodb/binding/AsyncConnectionSource;Lcom/mongodb/operation/OperationHelper$AsyncCallableWithConnectionAndSource;)V
flags: (0x000a) ACC_PRIVATE, ACC_STATIC
Code:
stack=5, locals=2, args_size=2
start local 0 start local 1 0: aload 0
new com.mongodb.operation.OperationHelper$7
dup
aload 1
aload 0
invokespecial com.mongodb.operation.OperationHelper$7.<init>:(Lcom/mongodb/operation/OperationHelper$AsyncCallableWithConnectionAndSource;Lcom/mongodb/binding/AsyncConnectionSource;)V
invokeinterface com.mongodb.binding.AsyncConnectionSource.getConnection:(Lcom/mongodb/async/SingleResultCallback;)V
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 source Lcom/mongodb/binding/AsyncConnectionSource;
0 2 1 callable Lcom/mongodb/operation/OperationHelper$AsyncCallableWithConnectionAndSource;
MethodParameters:
Name Flags
source final
callable final
private void <init>();
descriptor: ()V
flags: (0x0002) ACC_PRIVATE
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
invokespecial java.lang.Object.<init>:()V
1: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lcom/mongodb/operation/OperationHelper;
}
SourceFile: "OperationHelper.java"
NestMembers:
com.mongodb.operation.OperationHelper$1 com.mongodb.operation.OperationHelper$2 com.mongodb.operation.OperationHelper$3 com.mongodb.operation.OperationHelper$4 com.mongodb.operation.OperationHelper$5 com.mongodb.operation.OperationHelper$6 com.mongodb.operation.OperationHelper$7 com.mongodb.operation.OperationHelper$AsyncCallableWithConnection com.mongodb.operation.OperationHelper$AsyncCallableWithConnectionAndSource com.mongodb.operation.OperationHelper$AsyncCallableWithConnectionAndSourceCallback com.mongodb.operation.OperationHelper$AsyncCallableWithConnectionCallback com.mongodb.operation.OperationHelper$AsyncCallableWithSource com.mongodb.operation.OperationHelper$AsyncCallableWithSourceCallback com.mongodb.operation.OperationHelper$CallableWithConnection com.mongodb.operation.OperationHelper$CallableWithConnectionAndSource com.mongodb.operation.OperationHelper$CallableWithSource com.mongodb.operation.OperationHelper$ConnectionReleasingWrappedCallback com.mongodb.operation.OperationHelper$ReferenceCountedReleasingWrappedCallback
InnerClasses:
com.mongodb.operation.OperationHelper$1
com.mongodb.operation.OperationHelper$2
com.mongodb.operation.OperationHelper$3
com.mongodb.operation.OperationHelper$4
com.mongodb.operation.OperationHelper$5
com.mongodb.operation.OperationHelper$6
com.mongodb.operation.OperationHelper$7
abstract AsyncCallableWithConnection = com.mongodb.operation.OperationHelper$AsyncCallableWithConnection of com.mongodb.operation.OperationHelper
abstract AsyncCallableWithConnectionAndSource = com.mongodb.operation.OperationHelper$AsyncCallableWithConnectionAndSource of com.mongodb.operation.OperationHelper
private AsyncCallableWithConnectionAndSourceCallback = com.mongodb.operation.OperationHelper$AsyncCallableWithConnectionAndSourceCallback of com.mongodb.operation.OperationHelper
private AsyncCallableWithConnectionCallback = com.mongodb.operation.OperationHelper$AsyncCallableWithConnectionCallback of com.mongodb.operation.OperationHelper
abstract AsyncCallableWithSource = com.mongodb.operation.OperationHelper$AsyncCallableWithSource of com.mongodb.operation.OperationHelper
private AsyncCallableWithSourceCallback = com.mongodb.operation.OperationHelper$AsyncCallableWithSourceCallback of com.mongodb.operation.OperationHelper
abstract CallableWithConnection = com.mongodb.operation.OperationHelper$CallableWithConnection of com.mongodb.operation.OperationHelper
abstract CallableWithConnectionAndSource = com.mongodb.operation.OperationHelper$CallableWithConnectionAndSource of com.mongodb.operation.OperationHelper
abstract CallableWithSource = com.mongodb.operation.OperationHelper$CallableWithSource of com.mongodb.operation.OperationHelper
ConnectionReleasingWrappedCallback = com.mongodb.operation.OperationHelper$ConnectionReleasingWrappedCallback of com.mongodb.operation.OperationHelper
private ReferenceCountedReleasingWrappedCallback = com.mongodb.operation.OperationHelper$ReferenceCountedReleasingWrappedCallback of com.mongodb.operation.OperationHelper
OperationHelper
LOGGER: Logger
withAsyncConnectionSourceCallableConnection(AsyncConnectionSource, OperationHelper$AsyncCallableWithConnection): void
http://www.mongodb.org: The MongoDB Java Driver uber-artifact, containing the legacy driver, the mongodb-driver, mongodb-driver-core, and bson