public class com.mongodb.operation.CommitTransactionOperation extends com.mongodb.operation.TransactionOperation
minor version: 0
major version: 59
flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
this_class: com.mongodb.operation.CommitTransactionOperation
super_class: com.mongodb.operation.TransactionOperation
{
private final boolean alreadyCommitted;
descriptor: Z
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private org.bson.BsonDocument recoveryToken;
descriptor: Lorg/bson/BsonDocument;
flags: (0x0002) ACC_PRIVATE
private java.lang.Long maxCommitTimeMS;
descriptor: Ljava/lang/Long;
flags: (0x0002) ACC_PRIVATE
private static final java.util.List<java.lang.Integer> NON_RETRYABLE_WRITE_CONCERN_ERROR_CODES;
descriptor: Ljava/util/List;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
Signature: Ljava/util/List<Ljava/lang/Integer;>;
static void <clinit>();
descriptor: ()V
flags: (0x0008) ACC_STATIC
Code:
stack=4, locals=0, args_size=0
0: iconst_2
anewarray java.lang.Integer
dup
iconst_0
bipush 79
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
aastore
dup
iconst_1
bipush 100
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
aastore
invokestatic java.util.Arrays.asList:([Ljava/lang/Object;)Ljava/util/List;
putstatic com.mongodb.operation.CommitTransactionOperation.NON_RETRYABLE_WRITE_CONCERN_ERROR_CODES:Ljava/util/List;
return
LocalVariableTable:
Start End Slot Name Signature
public void <init>(com.mongodb.WriteConcern);
descriptor: (Lcom/mongodb/WriteConcern;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
iconst_0
invokespecial com.mongodb.operation.CommitTransactionOperation.<init>:(Lcom/mongodb/WriteConcern;Z)V
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lcom/mongodb/operation/CommitTransactionOperation;
0 2 1 writeConcern Lcom/mongodb/WriteConcern;
MethodParameters:
Name Flags
writeConcern final
public void <init>(com.mongodb.WriteConcern, boolean);
descriptor: (Lcom/mongodb/WriteConcern;Z)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
invokespecial com.mongodb.operation.TransactionOperation.<init>:(Lcom/mongodb/WriteConcern;)V
1: aload 0
iload 2
putfield com.mongodb.operation.CommitTransactionOperation.alreadyCommitted:Z
2: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lcom/mongodb/operation/CommitTransactionOperation;
0 3 1 writeConcern Lcom/mongodb/WriteConcern;
0 3 2 alreadyCommitted Z
MethodParameters:
Name Flags
writeConcern final
alreadyCommitted final
public com.mongodb.operation.CommitTransactionOperation recoveryToken(org.bson.BsonDocument);
descriptor: (Lorg/bson/BsonDocument;)Lcom/mongodb/operation/CommitTransactionOperation;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
putfield com.mongodb.operation.CommitTransactionOperation.recoveryToken:Lorg/bson/BsonDocument;
1: aload 0
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lcom/mongodb/operation/CommitTransactionOperation;
0 2 1 recoveryToken Lorg/bson/BsonDocument;
MethodParameters:
Name Flags
recoveryToken final
public com.mongodb.operation.CommitTransactionOperation maxCommitTime(java.lang.Long, java.util.concurrent.TimeUnit);
descriptor: (Ljava/lang/Long;Ljava/util/concurrent/TimeUnit;)Lcom/mongodb/operation/CommitTransactionOperation;
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 1
ifnonnull 3
1: aload 0
aconst_null
putfield com.mongodb.operation.CommitTransactionOperation.maxCommitTimeMS:Ljava/lang/Long;
2: goto 8
3: StackMap locals:
StackMap stack:
ldc "timeUnit"
aload 2
invokestatic com.mongodb.assertions.Assertions.notNull:(Ljava/lang/String;Ljava/lang/Object;)Ljava/lang/Object;
pop
4: ldc "maxCommitTime > 0"
aload 1
invokevirtual java.lang.Long.longValue:()J
lconst_0
lcmp
ifle 5
iconst_1
goto 6
StackMap locals:
StackMap stack: java.lang.String
5: iconst_0
StackMap locals: com.mongodb.operation.CommitTransactionOperation java.lang.Long java.util.concurrent.TimeUnit
StackMap stack: java.lang.String int
6: invokestatic com.mongodb.assertions.Assertions.isTrueArgument:(Ljava/lang/String;Z)V
7: aload 0
getstatic java.util.concurrent.TimeUnit.MILLISECONDS:Ljava/util/concurrent/TimeUnit;
aload 1
invokevirtual java.lang.Long.longValue:()J
aload 2
invokevirtual java.util.concurrent.TimeUnit.convert:(JLjava/util/concurrent/TimeUnit;)J
invokestatic java.lang.Long.valueOf:(J)Ljava/lang/Long;
putfield com.mongodb.operation.CommitTransactionOperation.maxCommitTimeMS:Ljava/lang/Long;
8: StackMap locals:
StackMap stack:
aload 0
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 9 0 this Lcom/mongodb/operation/CommitTransactionOperation;
0 9 1 maxCommitTime Ljava/lang/Long;
0 9 2 timeUnit Ljava/util/concurrent/TimeUnit;
RuntimeVisibleParameterAnnotations:
0:
com.mongodb.lang.Nullable()
1:
MethodParameters:
Name Flags
maxCommitTime final
timeUnit final
public java.lang.Long getMaxCommitTime(java.util.concurrent.TimeUnit);
descriptor: (Ljava/util/concurrent/TimeUnit;)Ljava/lang/Long;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: ldc "timeUnit"
aload 1
invokestatic com.mongodb.assertions.Assertions.notNull:(Ljava/lang/String;Ljava/lang/Object;)Ljava/lang/Object;
pop
1: aload 0
getfield com.mongodb.operation.CommitTransactionOperation.maxCommitTimeMS:Ljava/lang/Long;
ifnonnull 3
2: aconst_null
areturn
3: StackMap locals:
StackMap stack:
aload 1
aload 0
getfield com.mongodb.operation.CommitTransactionOperation.maxCommitTimeMS:Ljava/lang/Long;
invokevirtual java.lang.Long.longValue:()J
getstatic java.util.concurrent.TimeUnit.MILLISECONDS:Ljava/util/concurrent/TimeUnit;
invokevirtual java.util.concurrent.TimeUnit.convert:(JLjava/util/concurrent/TimeUnit;)J
invokestatic java.lang.Long.valueOf:(J)Ljava/lang/Long;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lcom/mongodb/operation/CommitTransactionOperation;
0 4 1 timeUnit Ljava/util/concurrent/TimeUnit;
RuntimeVisibleAnnotations:
com.mongodb.lang.Nullable()
MethodParameters:
Name Flags
timeUnit final
public java.lang.Void execute(com.mongodb.binding.WriteBinding);
descriptor: (Lcom/mongodb/binding/WriteBinding;)Ljava/lang/Void;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=3, args_size=2
start local 0 start local 1 0: aload 0
aload 1
invokespecial com.mongodb.operation.TransactionOperation.execute:(Lcom/mongodb/binding/WriteBinding;)Ljava/lang/Void;
1: areturn
2: StackMap locals:
StackMap stack: com.mongodb.MongoException
astore 2
start local 2 3: aload 0
aload 2
invokevirtual com.mongodb.operation.CommitTransactionOperation.addErrorLabels:(Lcom/mongodb/MongoException;)V
4: aload 2
athrow
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lcom/mongodb/operation/CommitTransactionOperation;
0 5 1 binding Lcom/mongodb/binding/WriteBinding;
3 5 2 e Lcom/mongodb/MongoException;
Exception table:
from to target type
0 1 2 Class com.mongodb.MongoException
MethodParameters:
Name Flags
binding final
public void executeAsync(com.mongodb.binding.AsyncWriteBinding, com.mongodb.async.SingleResultCallback<java.lang.Void>);
descriptor: (Lcom/mongodb/binding/AsyncWriteBinding;Lcom/mongodb/async/SingleResultCallback;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=6, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
new com.mongodb.operation.CommitTransactionOperation$1
dup
aload 0
aload 2
invokespecial com.mongodb.operation.CommitTransactionOperation$1.<init>:(Lcom/mongodb/operation/CommitTransactionOperation;Lcom/mongodb/async/SingleResultCallback;)V
invokespecial com.mongodb.operation.TransactionOperation.executeAsync:(Lcom/mongodb/binding/AsyncWriteBinding;Lcom/mongodb/async/SingleResultCallback;)V
1: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lcom/mongodb/operation/CommitTransactionOperation;
0 2 1 binding Lcom/mongodb/binding/AsyncWriteBinding;
0 2 2 callback Lcom/mongodb/async/SingleResultCallback<Ljava/lang/Void;>;
Signature: (Lcom/mongodb/binding/AsyncWriteBinding;Lcom/mongodb/async/SingleResultCallback<Ljava/lang/Void;>;)V
MethodParameters:
Name Flags
binding final
callback final
private void addErrorLabels(com.mongodb.MongoException);
descriptor: (Lcom/mongodb/MongoException;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 1
invokestatic com.mongodb.operation.CommitTransactionOperation.shouldAddUnknownTransactionCommitResultLabel:(Ljava/lang/Throwable;)Z
ifeq 2
1: aload 1
ldc "UnknownTransactionCommitResult"
invokevirtual com.mongodb.MongoException.addLabel:(Ljava/lang/String;)V
2: StackMap locals:
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lcom/mongodb/operation/CommitTransactionOperation;
0 3 1 e Lcom/mongodb/MongoException;
MethodParameters:
Name Flags
e final
private static boolean shouldAddUnknownTransactionCommitResultLabel(java.lang.Throwable);
descriptor: (Ljava/lang/Throwable;)Z
flags: (0x000a) ACC_PRIVATE, ACC_STATIC
Code:
stack=2, locals=2, args_size=1
start local 0 0: aload 0
instanceof com.mongodb.MongoException
ifne 2
1: iconst_0
ireturn
2: StackMap locals:
StackMap stack:
aload 0
checkcast com.mongodb.MongoException
astore 1
start local 1 3: aload 1
instanceof com.mongodb.MongoSocketException
ifne 6
aload 1
instanceof com.mongodb.MongoTimeoutException
ifne 6
4: aload 1
instanceof com.mongodb.MongoNotPrimaryException
ifne 6
aload 1
instanceof com.mongodb.MongoNodeIsRecoveringException
ifne 6
5: aload 1
instanceof com.mongodb.MongoExecutionTimeoutException
ifeq 7
6: StackMap locals: com.mongodb.MongoException
StackMap stack:
iconst_1
ireturn
7: StackMap locals:
StackMap stack:
aload 1
instanceof com.mongodb.MongoWriteConcernException
ifeq 11
8: getstatic com.mongodb.operation.CommitTransactionOperation.NON_RETRYABLE_WRITE_CONCERN_ERROR_CODES:Ljava/util/List;
aload 1
invokevirtual com.mongodb.MongoException.getCode:()I
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
invokeinterface java.util.List.contains:(Ljava/lang/Object;)Z
ifeq 9
iconst_0
goto 10
StackMap locals:
StackMap stack:
9: iconst_1
StackMap locals:
StackMap stack: int
10: ireturn
11: StackMap locals:
StackMap stack:
iconst_0
ireturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 12 0 t Ljava/lang/Throwable;
3 12 1 e Lcom/mongodb/MongoException;
MethodParameters:
Name Flags
t final
protected java.lang.String getCommandName();
descriptor: ()Ljava/lang/String;
flags: (0x0004) ACC_PROTECTED
Code:
stack=1, locals=1, args_size=1
start local 0 0: ldc "commitTransaction"
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lcom/mongodb/operation/CommitTransactionOperation;
com.mongodb.operation.CommandOperationHelper$CommandCreator getCommandCreator();
descriptor: ()Lcom/mongodb/operation/CommandOperationHelper$CommandCreator;
flags: (0x0000)
Code:
stack=4, locals=2, args_size=1
start local 0 0: new com.mongodb.operation.CommitTransactionOperation$2
dup
aload 0
invokespecial com.mongodb.operation.CommitTransactionOperation$2.<init>:(Lcom/mongodb/operation/CommitTransactionOperation;)V
astore 1
start local 1 1: aload 0
getfield com.mongodb.operation.CommitTransactionOperation.alreadyCommitted:Z
ifeq 3
2: new com.mongodb.operation.CommitTransactionOperation$3
dup
aload 0
aload 1
invokespecial com.mongodb.operation.CommitTransactionOperation$3.<init>:(Lcom/mongodb/operation/CommitTransactionOperation;Lcom/mongodb/operation/CommandOperationHelper$CommandCreator;)V
areturn
3: StackMap locals: com.mongodb.operation.CommandOperationHelper$CommandCreator
StackMap stack:
aload 0
getfield com.mongodb.operation.CommitTransactionOperation.recoveryToken:Lorg/bson/BsonDocument;
ifnull 5
4: new com.mongodb.operation.CommitTransactionOperation$4
dup
aload 0
aload 1
invokespecial com.mongodb.operation.CommitTransactionOperation$4.<init>:(Lcom/mongodb/operation/CommitTransactionOperation;Lcom/mongodb/operation/CommandOperationHelper$CommandCreator;)V
areturn
5: StackMap locals:
StackMap stack:
aload 1
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lcom/mongodb/operation/CommitTransactionOperation;
1 6 1 creator Lcom/mongodb/operation/CommandOperationHelper$CommandCreator;
protected com.mongodb.Function<org.bson.BsonDocument, org.bson.BsonDocument> getRetryCommandModifier();
descriptor: ()Lcom/mongodb/Function;
flags: (0x0004) ACC_PROTECTED
Code:
stack=3, locals=1, args_size=1
start local 0 0: new com.mongodb.operation.CommitTransactionOperation$5
dup
aload 0
invokespecial com.mongodb.operation.CommitTransactionOperation$5.<init>:(Lcom/mongodb/operation/CommitTransactionOperation;)V
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lcom/mongodb/operation/CommitTransactionOperation;
Signature: ()Lcom/mongodb/Function<Lorg/bson/BsonDocument;Lorg/bson/BsonDocument;>;
static com.mongodb.operation.CommandOperationHelper$CommandCreator access$0(com.mongodb.operation.CommitTransactionOperation);
descriptor: (Lcom/mongodb/operation/CommitTransactionOperation;)Lcom/mongodb/operation/CommandOperationHelper$CommandCreator;
flags: (0x1008) ACC_STATIC, ACC_SYNTHETIC
Code:
stack=1, locals=1, args_size=1
0: aload 0
invokespecial com.mongodb.operation.TransactionOperation.getCommandCreator:()Lcom/mongodb/operation/CommandOperationHelper$CommandCreator;
areturn
LocalVariableTable:
Start End Slot Name Signature
}
SourceFile: "CommitTransactionOperation.java"
NestMembers:
com.mongodb.operation.CommitTransactionOperation$1 com.mongodb.operation.CommitTransactionOperation$2 com.mongodb.operation.CommitTransactionOperation$3 com.mongodb.operation.CommitTransactionOperation$4 com.mongodb.operation.CommitTransactionOperation$5
InnerClasses:
abstract CommandCreator = com.mongodb.operation.CommandOperationHelper$CommandCreator of com.mongodb.operation.CommandOperationHelper
com.mongodb.operation.CommitTransactionOperation$1
com.mongodb.operation.CommitTransactionOperation$2
com.mongodb.operation.CommitTransactionOperation$3
com.mongodb.operation.CommitTransactionOperation$4
com.mongodb.operation.CommitTransactionOperation$5
RuntimeVisibleAnnotations:
java.lang.Deprecated()