class com.mongodb.internal.connection.DefaultServer implements com.mongodb.internal.connection.ClusterableServer
minor version: 0
major version: 59
flags: flags: (0x0020) ACC_SUPER
this_class: com.mongodb.internal.connection.DefaultServer
super_class: java.lang.Object
{
private static final com.mongodb.diagnostics.logging.Logger LOGGER;
descriptor: Lcom/mongodb/diagnostics/logging/Logger;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
private static final java.util.List<java.lang.Integer> SHUTDOWN_CODES;
descriptor: Ljava/util/List;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
Signature: Ljava/util/List<Ljava/lang/Integer;>;
private final com.mongodb.connection.ServerId serverId;
descriptor: Lcom/mongodb/connection/ServerId;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final com.mongodb.internal.connection.ConnectionPool connectionPool;
descriptor: Lcom/mongodb/internal/connection/ConnectionPool;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final com.mongodb.connection.ClusterConnectionMode clusterConnectionMode;
descriptor: Lcom/mongodb/connection/ClusterConnectionMode;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final com.mongodb.internal.connection.ConnectionFactory connectionFactory;
descriptor: Lcom/mongodb/internal/connection/ConnectionFactory;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final com.mongodb.internal.connection.ServerMonitor serverMonitor;
descriptor: Lcom/mongodb/internal/connection/ServerMonitor;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final com.mongodb.internal.connection.ChangeListener<com.mongodb.connection.ServerDescription> serverStateListener;
descriptor: Lcom/mongodb/internal/connection/ChangeListener;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Lcom/mongodb/internal/connection/ChangeListener<Lcom/mongodb/connection/ServerDescription;>;
private final com.mongodb.event.ServerListener serverListener;
descriptor: Lcom/mongodb/event/ServerListener;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final com.mongodb.event.CommandListener commandListener;
descriptor: Lcom/mongodb/event/CommandListener;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final com.mongodb.internal.connection.ClusterClock clusterClock;
descriptor: Lcom/mongodb/internal/connection/ClusterClock;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private volatile com.mongodb.connection.ServerDescription description;
descriptor: Lcom/mongodb/connection/ServerDescription;
flags: (0x0042) ACC_PRIVATE, ACC_VOLATILE
private volatile boolean isClosed;
descriptor: Z
flags: (0x0042) ACC_PRIVATE, ACC_VOLATILE
static void <clinit>();
descriptor: ()V
flags: (0x0008) ACC_STATIC
Code:
stack=4, locals=0, args_size=0
0: ldc "connection"
invokestatic com.mongodb.diagnostics.logging.Loggers.getLogger:(Ljava/lang/String;)Lcom/mongodb/diagnostics/logging/Logger;
putstatic com.mongodb.internal.connection.DefaultServer.LOGGER:Lcom/mongodb/diagnostics/logging/Logger;
1: iconst_2
anewarray java.lang.Integer
dup
iconst_0
bipush 91
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
aastore
dup
iconst_1
sipush 11600
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
aastore
invokestatic java.util.Arrays.asList:([Ljava/lang/Object;)Ljava/util/List;
putstatic com.mongodb.internal.connection.DefaultServer.SHUTDOWN_CODES:Ljava/util/List;
return
LocalVariableTable:
Start End Slot Name Signature
void <init>(com.mongodb.connection.ServerId, com.mongodb.connection.ClusterConnectionMode, com.mongodb.internal.connection.ConnectionPool, com.mongodb.internal.connection.ConnectionFactory, com.mongodb.internal.connection.ServerMonitorFactory, com.mongodb.event.ServerListener, com.mongodb.event.CommandListener, com.mongodb.internal.connection.ClusterClock);
descriptor: (Lcom/mongodb/connection/ServerId;Lcom/mongodb/connection/ClusterConnectionMode;Lcom/mongodb/internal/connection/ConnectionPool;Lcom/mongodb/internal/connection/ConnectionFactory;Lcom/mongodb/internal/connection/ServerMonitorFactory;Lcom/mongodb/event/ServerListener;Lcom/mongodb/event/CommandListener;Lcom/mongodb/internal/connection/ClusterClock;)V
flags: (0x0000)
Code:
stack=4, locals=9, args_size=9
start local 0 start local 1 start local 2 start local 3 start local 4 start local 5 start local 6 start local 7 start local 8 0: aload 0
invokespecial java.lang.Object.<init>:()V
1: aload 0
ldc "serverListener"
aload 6
invokestatic com.mongodb.assertions.Assertions.notNull:(Ljava/lang/String;Ljava/lang/Object;)Ljava/lang/Object;
checkcast com.mongodb.event.ServerListener
putfield com.mongodb.internal.connection.DefaultServer.serverListener:Lcom/mongodb/event/ServerListener;
2: aload 0
aload 7
putfield com.mongodb.internal.connection.DefaultServer.commandListener:Lcom/mongodb/event/CommandListener;
3: aload 0
ldc "clusterClock"
aload 8
invokestatic com.mongodb.assertions.Assertions.notNull:(Ljava/lang/String;Ljava/lang/Object;)Ljava/lang/Object;
checkcast com.mongodb.internal.connection.ClusterClock
putfield com.mongodb.internal.connection.DefaultServer.clusterClock:Lcom/mongodb/internal/connection/ClusterClock;
4: ldc "serverAddress"
aload 1
invokestatic com.mongodb.assertions.Assertions.notNull:(Ljava/lang/String;Ljava/lang/Object;)Ljava/lang/Object;
pop
5: ldc "serverMonitorFactory"
aload 5
invokestatic com.mongodb.assertions.Assertions.notNull:(Ljava/lang/String;Ljava/lang/Object;)Ljava/lang/Object;
pop
6: aload 0
ldc "clusterConnectionMode"
aload 2
invokestatic com.mongodb.assertions.Assertions.notNull:(Ljava/lang/String;Ljava/lang/Object;)Ljava/lang/Object;
checkcast com.mongodb.connection.ClusterConnectionMode
putfield com.mongodb.internal.connection.DefaultServer.clusterConnectionMode:Lcom/mongodb/connection/ClusterConnectionMode;
7: aload 0
ldc "connectionFactory"
aload 4
invokestatic com.mongodb.assertions.Assertions.notNull:(Ljava/lang/String;Ljava/lang/Object;)Ljava/lang/Object;
checkcast com.mongodb.internal.connection.ConnectionFactory
putfield com.mongodb.internal.connection.DefaultServer.connectionFactory:Lcom/mongodb/internal/connection/ConnectionFactory;
8: aload 0
ldc "connectionPool"
aload 3
invokestatic com.mongodb.assertions.Assertions.notNull:(Ljava/lang/String;Ljava/lang/Object;)Ljava/lang/Object;
checkcast com.mongodb.internal.connection.ConnectionPool
putfield com.mongodb.internal.connection.DefaultServer.connectionPool:Lcom/mongodb/internal/connection/ConnectionPool;
9: aload 0
new com.mongodb.internal.connection.DefaultServer$DefaultServerStateListener
dup
aload 0
invokespecial com.mongodb.internal.connection.DefaultServer$DefaultServerStateListener.<init>:(Lcom/mongodb/internal/connection/DefaultServer;)V
putfield com.mongodb.internal.connection.DefaultServer.serverStateListener:Lcom/mongodb/internal/connection/ChangeListener;
10: aload 0
aload 1
putfield com.mongodb.internal.connection.DefaultServer.serverId:Lcom/mongodb/connection/ServerId;
11: aload 6
new com.mongodb.event.ServerOpeningEvent
dup
aload 0
getfield com.mongodb.internal.connection.DefaultServer.serverId:Lcom/mongodb/connection/ServerId;
invokespecial com.mongodb.event.ServerOpeningEvent.<init>:(Lcom/mongodb/connection/ServerId;)V
invokeinterface com.mongodb.event.ServerListener.serverOpening:(Lcom/mongodb/event/ServerOpeningEvent;)V
12: aload 0
invokestatic com.mongodb.connection.ServerDescription.builder:()Lcom/mongodb/connection/ServerDescription$Builder;
getstatic com.mongodb.connection.ServerConnectionState.CONNECTING:Lcom/mongodb/connection/ServerConnectionState;
invokevirtual com.mongodb.connection.ServerDescription$Builder.state:(Lcom/mongodb/connection/ServerConnectionState;)Lcom/mongodb/connection/ServerDescription$Builder;
aload 1
invokevirtual com.mongodb.connection.ServerId.getAddress:()Lcom/mongodb/ServerAddress;
invokevirtual com.mongodb.connection.ServerDescription$Builder.address:(Lcom/mongodb/ServerAddress;)Lcom/mongodb/connection/ServerDescription$Builder;
invokevirtual com.mongodb.connection.ServerDescription$Builder.build:()Lcom/mongodb/connection/ServerDescription;
putfield com.mongodb.internal.connection.DefaultServer.description:Lcom/mongodb/connection/ServerDescription;
13: aload 0
aload 5
aload 0
getfield com.mongodb.internal.connection.DefaultServer.serverStateListener:Lcom/mongodb/internal/connection/ChangeListener;
invokeinterface com.mongodb.internal.connection.ServerMonitorFactory.create:(Lcom/mongodb/internal/connection/ChangeListener;)Lcom/mongodb/internal/connection/ServerMonitor;
putfield com.mongodb.internal.connection.DefaultServer.serverMonitor:Lcom/mongodb/internal/connection/ServerMonitor;
14: aload 0
getfield com.mongodb.internal.connection.DefaultServer.serverMonitor:Lcom/mongodb/internal/connection/ServerMonitor;
invokeinterface com.mongodb.internal.connection.ServerMonitor.start:()V
15: return
end local 8 end local 7 end local 6 end local 5 end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 16 0 this Lcom/mongodb/internal/connection/DefaultServer;
0 16 1 serverId Lcom/mongodb/connection/ServerId;
0 16 2 clusterConnectionMode Lcom/mongodb/connection/ClusterConnectionMode;
0 16 3 connectionPool Lcom/mongodb/internal/connection/ConnectionPool;
0 16 4 connectionFactory Lcom/mongodb/internal/connection/ConnectionFactory;
0 16 5 serverMonitorFactory Lcom/mongodb/internal/connection/ServerMonitorFactory;
0 16 6 serverListener Lcom/mongodb/event/ServerListener;
0 16 7 commandListener Lcom/mongodb/event/CommandListener;
0 16 8 clusterClock Lcom/mongodb/internal/connection/ClusterClock;
MethodParameters:
Name Flags
serverId final
clusterConnectionMode final
connectionPool final
connectionFactory final
serverMonitorFactory final
serverListener final
commandListener final
clusterClock final
public com.mongodb.connection.Connection getConnection();
descriptor: ()Lcom/mongodb/connection/Connection;
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=2, args_size=1
start local 0 0: ldc "open"
aload 0
invokevirtual com.mongodb.internal.connection.DefaultServer.isClosed:()Z
ifeq 1
iconst_0
goto 2
StackMap locals:
StackMap stack: java.lang.String
1: iconst_1
StackMap locals: com.mongodb.internal.connection.DefaultServer
StackMap stack: java.lang.String int
2: invokestatic com.mongodb.assertions.Assertions.isTrue:(Ljava/lang/String;Z)V
3: aload 0
getfield com.mongodb.internal.connection.DefaultServer.connectionFactory:Lcom/mongodb/internal/connection/ConnectionFactory;
aload 0
getfield com.mongodb.internal.connection.DefaultServer.connectionPool:Lcom/mongodb/internal/connection/ConnectionPool;
invokeinterface com.mongodb.internal.connection.ConnectionPool.get:()Lcom/mongodb/internal/connection/InternalConnection;
new com.mongodb.internal.connection.DefaultServer$DefaultServerProtocolExecutor
dup
aload 0
invokespecial com.mongodb.internal.connection.DefaultServer$DefaultServerProtocolExecutor.<init>:(Lcom/mongodb/internal/connection/DefaultServer;)V
aload 0
getfield com.mongodb.internal.connection.DefaultServer.clusterConnectionMode:Lcom/mongodb/connection/ClusterConnectionMode;
invokeinterface com.mongodb.internal.connection.ConnectionFactory.create:(Lcom/mongodb/internal/connection/InternalConnection;Lcom/mongodb/internal/connection/ProtocolExecutor;Lcom/mongodb/connection/ClusterConnectionMode;)Lcom/mongodb/connection/Connection;
4: areturn
5: StackMap locals:
StackMap stack: com.mongodb.MongoSecurityException
astore 1
start local 1 6: aload 0
getfield com.mongodb.internal.connection.DefaultServer.connectionPool:Lcom/mongodb/internal/connection/ConnectionPool;
invokeinterface com.mongodb.internal.connection.ConnectionPool.invalidate:()V
7: aload 1
athrow
end local 1 8: StackMap locals:
StackMap stack: com.mongodb.MongoSocketException
astore 1
start local 1 9: aload 0
invokevirtual com.mongodb.internal.connection.DefaultServer.invalidate:()V
10: aload 1
athrow
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 11 0 this Lcom/mongodb/internal/connection/DefaultServer;
6 8 1 e Lcom/mongodb/MongoSecurityException;
9 11 1 e Lcom/mongodb/MongoSocketException;
Exception table:
from to target type
3 4 5 Class com.mongodb.MongoSecurityException
3 4 8 Class com.mongodb.MongoSocketException
public void getConnectionAsync(com.mongodb.async.SingleResultCallback<com.mongodb.connection.AsyncConnection>);
descriptor: (Lcom/mongodb/async/SingleResultCallback;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=2, args_size=2
start local 0 start local 1 0: ldc "open"
aload 0
invokevirtual com.mongodb.internal.connection.DefaultServer.isClosed:()Z
ifeq 1
iconst_0
goto 2
StackMap locals:
StackMap stack: java.lang.String
1: iconst_1
StackMap locals: com.mongodb.internal.connection.DefaultServer com.mongodb.async.SingleResultCallback
StackMap stack: java.lang.String int
2: invokestatic com.mongodb.assertions.Assertions.isTrue:(Ljava/lang/String;Z)V
3: aload 0
getfield com.mongodb.internal.connection.DefaultServer.connectionPool:Lcom/mongodb/internal/connection/ConnectionPool;
new com.mongodb.internal.connection.DefaultServer$1
dup
aload 0
aload 1
invokespecial com.mongodb.internal.connection.DefaultServer$1.<init>:(Lcom/mongodb/internal/connection/DefaultServer;Lcom/mongodb/async/SingleResultCallback;)V
invokeinterface com.mongodb.internal.connection.ConnectionPool.getAsync:(Lcom/mongodb/async/SingleResultCallback;)V
4: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lcom/mongodb/internal/connection/DefaultServer;
0 5 1 callback Lcom/mongodb/async/SingleResultCallback<Lcom/mongodb/connection/AsyncConnection;>;
Signature: (Lcom/mongodb/async/SingleResultCallback<Lcom/mongodb/connection/AsyncConnection;>;)V
MethodParameters:
Name Flags
callback final
public com.mongodb.connection.ServerDescription getDescription();
descriptor: ()Lcom/mongodb/connection/ServerDescription;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: ldc "open"
aload 0
invokevirtual com.mongodb.internal.connection.DefaultServer.isClosed:()Z
ifeq 1
iconst_0
goto 2
StackMap locals:
StackMap stack: java.lang.String
1: iconst_1
StackMap locals: com.mongodb.internal.connection.DefaultServer
StackMap stack: java.lang.String int
2: invokestatic com.mongodb.assertions.Assertions.isTrue:(Ljava/lang/String;Z)V
3: aload 0
getfield com.mongodb.internal.connection.DefaultServer.description:Lcom/mongodb/connection/ServerDescription;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lcom/mongodb/internal/connection/DefaultServer;
public void invalidate();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=6, locals=1, args_size=1
start local 0 0: aload 0
invokevirtual com.mongodb.internal.connection.DefaultServer.isClosed:()Z
ifne 8
1: aload 0
getfield com.mongodb.internal.connection.DefaultServer.serverStateListener:Lcom/mongodb/internal/connection/ChangeListener;
new com.mongodb.internal.connection.ChangeEvent
dup
aload 0
getfield com.mongodb.internal.connection.DefaultServer.description:Lcom/mongodb/connection/ServerDescription;
invokestatic com.mongodb.connection.ServerDescription.builder:()Lcom/mongodb/connection/ServerDescription$Builder;
2: getstatic com.mongodb.connection.ServerConnectionState.CONNECTING:Lcom/mongodb/connection/ServerConnectionState;
invokevirtual com.mongodb.connection.ServerDescription$Builder.state:(Lcom/mongodb/connection/ServerConnectionState;)Lcom/mongodb/connection/ServerDescription$Builder;
3: aload 0
getfield com.mongodb.internal.connection.DefaultServer.serverId:Lcom/mongodb/connection/ServerId;
invokevirtual com.mongodb.connection.ServerId.getAddress:()Lcom/mongodb/ServerAddress;
invokevirtual com.mongodb.connection.ServerDescription$Builder.address:(Lcom/mongodb/ServerAddress;)Lcom/mongodb/connection/ServerDescription$Builder;
4: invokevirtual com.mongodb.connection.ServerDescription$Builder.build:()Lcom/mongodb/connection/ServerDescription;
invokespecial com.mongodb.internal.connection.ChangeEvent.<init>:(Ljava/lang/Object;Ljava/lang/Object;)V
5: invokeinterface com.mongodb.internal.connection.ChangeListener.stateChanged:(Lcom/mongodb/internal/connection/ChangeEvent;)V
6: aload 0
getfield com.mongodb.internal.connection.DefaultServer.connectionPool:Lcom/mongodb/internal/connection/ConnectionPool;
invokeinterface com.mongodb.internal.connection.ConnectionPool.invalidate:()V
7: aload 0
invokevirtual com.mongodb.internal.connection.DefaultServer.connect:()V
8: StackMap locals:
StackMap stack:
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 9 0 this Lcom/mongodb/internal/connection/DefaultServer;
public void invalidate(java.lang.Throwable);
descriptor: (Ljava/lang/Throwable;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=3, args_size=2
start local 0 start local 1 0: aload 0
invokevirtual com.mongodb.internal.connection.DefaultServer.isClosed:()Z
ifne 16
1: aload 1
instanceof com.mongodb.MongoSocketException
ifeq 4
aload 1
instanceof com.mongodb.MongoSocketReadTimeoutException
ifne 4
2: aload 0
invokevirtual com.mongodb.internal.connection.DefaultServer.invalidate:()V
3: goto 16
StackMap locals:
StackMap stack:
4: aload 1
instanceof com.mongodb.MongoNotPrimaryException
ifne 5
aload 1
instanceof com.mongodb.MongoNodeIsRecoveringException
ifeq 16
5: StackMap locals:
StackMap stack:
aload 0
getfield com.mongodb.internal.connection.DefaultServer.description:Lcom/mongodb/connection/ServerDescription;
invokevirtual com.mongodb.connection.ServerDescription.getMaxWireVersion:()I
bipush 8
if_icmpge 8
6: aload 0
invokevirtual com.mongodb.internal.connection.DefaultServer.invalidate:()V
7: goto 16
StackMap locals:
StackMap stack:
8: getstatic com.mongodb.internal.connection.DefaultServer.SHUTDOWN_CODES:Ljava/util/List;
aload 1
checkcast com.mongodb.MongoCommandException
invokevirtual com.mongodb.MongoCommandException.getErrorCode:()I
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
invokeinterface java.util.List.contains:(Ljava/lang/Object;)Z
ifeq 11
9: aload 0
invokevirtual com.mongodb.internal.connection.DefaultServer.invalidate:()V
10: goto 16
11: StackMap locals:
StackMap stack:
new com.mongodb.internal.connection.ChangeEvent
dup
aload 0
getfield com.mongodb.internal.connection.DefaultServer.description:Lcom/mongodb/connection/ServerDescription;
invokestatic com.mongodb.connection.ServerDescription.builder:()Lcom/mongodb/connection/ServerDescription$Builder;
12: getstatic com.mongodb.connection.ServerConnectionState.CONNECTING:Lcom/mongodb/connection/ServerConnectionState;
invokevirtual com.mongodb.connection.ServerDescription$Builder.state:(Lcom/mongodb/connection/ServerConnectionState;)Lcom/mongodb/connection/ServerDescription$Builder;
getstatic com.mongodb.connection.ServerType.UNKNOWN:Lcom/mongodb/connection/ServerType;
invokevirtual com.mongodb.connection.ServerDescription$Builder.type:(Lcom/mongodb/connection/ServerType;)Lcom/mongodb/connection/ServerDescription$Builder;
aload 0
getfield com.mongodb.internal.connection.DefaultServer.serverId:Lcom/mongodb/connection/ServerId;
invokevirtual com.mongodb.connection.ServerId.getAddress:()Lcom/mongodb/ServerAddress;
invokevirtual com.mongodb.connection.ServerDescription$Builder.address:(Lcom/mongodb/ServerAddress;)Lcom/mongodb/connection/ServerDescription$Builder;
aload 1
invokevirtual com.mongodb.connection.ServerDescription$Builder.exception:(Ljava/lang/Throwable;)Lcom/mongodb/connection/ServerDescription$Builder;
invokevirtual com.mongodb.connection.ServerDescription$Builder.build:()Lcom/mongodb/connection/ServerDescription;
13: invokespecial com.mongodb.internal.connection.ChangeEvent.<init>:(Ljava/lang/Object;Ljava/lang/Object;)V
astore 2
start local 2 14: aload 0
getfield com.mongodb.internal.connection.DefaultServer.serverStateListener:Lcom/mongodb/internal/connection/ChangeListener;
aload 2
invokeinterface com.mongodb.internal.connection.ChangeListener.stateChanged:(Lcom/mongodb/internal/connection/ChangeEvent;)V
15: aload 0
invokevirtual com.mongodb.internal.connection.DefaultServer.connect:()V
end local 2 16: StackMap locals:
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 17 0 this Lcom/mongodb/internal/connection/DefaultServer;
0 17 1 t Ljava/lang/Throwable;
14 16 2 event Lcom/mongodb/internal/connection/ChangeEvent<Lcom/mongodb/connection/ServerDescription;>;
MethodParameters:
Name Flags
t final
public void invalidate(java.lang.Throwable, com.mongodb.session.SessionContext);
descriptor: (Ljava/lang/Throwable;Lcom/mongodb/session/SessionContext;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=3, args_size=3
start local 0 start local 1 start local 2 0: ldc "sessionContext"
aload 2
invokestatic com.mongodb.assertions.Assertions.notNull:(Ljava/lang/String;Ljava/lang/Object;)Ljava/lang/Object;
pop
1: aload 0
aload 1
invokevirtual com.mongodb.internal.connection.DefaultServer.invalidate:(Ljava/lang/Throwable;)V
2: aload 1
instanceof com.mongodb.MongoSocketException
ifeq 4
aload 2
invokeinterface com.mongodb.session.SessionContext.hasSession:()Z
ifeq 4
3: aload 2
invokeinterface com.mongodb.session.SessionContext.markSessionDirty:()V
4: StackMap locals:
StackMap stack:
return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lcom/mongodb/internal/connection/DefaultServer;
0 5 1 t Ljava/lang/Throwable;
0 5 2 sessionContext Lcom/mongodb/session/SessionContext;
MethodParameters:
Name Flags
t final
sessionContext final
public void close();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=1, args_size=1
start local 0 0: aload 0
invokevirtual com.mongodb.internal.connection.DefaultServer.isClosed:()Z
ifne 5
1: aload 0
getfield com.mongodb.internal.connection.DefaultServer.connectionPool:Lcom/mongodb/internal/connection/ConnectionPool;
invokeinterface com.mongodb.internal.connection.ConnectionPool.close:()V
2: aload 0
getfield com.mongodb.internal.connection.DefaultServer.serverMonitor:Lcom/mongodb/internal/connection/ServerMonitor;
invokeinterface com.mongodb.internal.connection.ServerMonitor.close:()V
3: aload 0
iconst_1
putfield com.mongodb.internal.connection.DefaultServer.isClosed:Z
4: aload 0
getfield com.mongodb.internal.connection.DefaultServer.serverListener:Lcom/mongodb/event/ServerListener;
new com.mongodb.event.ServerClosedEvent
dup
aload 0
getfield com.mongodb.internal.connection.DefaultServer.serverId:Lcom/mongodb/connection/ServerId;
invokespecial com.mongodb.event.ServerClosedEvent.<init>:(Lcom/mongodb/connection/ServerId;)V
invokeinterface com.mongodb.event.ServerListener.serverClosed:(Lcom/mongodb/event/ServerClosedEvent;)V
5: StackMap locals:
StackMap stack:
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lcom/mongodb/internal/connection/DefaultServer;
public boolean isClosed();
descriptor: ()Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield com.mongodb.internal.connection.DefaultServer.isClosed:Z
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lcom/mongodb/internal/connection/DefaultServer;
public void connect();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield com.mongodb.internal.connection.DefaultServer.serverMonitor:Lcom/mongodb/internal/connection/ServerMonitor;
invokeinterface com.mongodb.internal.connection.ServerMonitor.connect:()V
1: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lcom/mongodb/internal/connection/DefaultServer;
com.mongodb.internal.connection.ConnectionPool getConnectionPool();
descriptor: ()Lcom/mongodb/internal/connection/ConnectionPool;
flags: (0x0000)
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield com.mongodb.internal.connection.DefaultServer.connectionPool:Lcom/mongodb/internal/connection/ConnectionPool;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lcom/mongodb/internal/connection/DefaultServer;
}
SourceFile: "DefaultServer.java"
NestMembers:
com.mongodb.internal.connection.DefaultServer$1 com.mongodb.internal.connection.DefaultServer$DefaultServerProtocolExecutor com.mongodb.internal.connection.DefaultServer$DefaultServerProtocolExecutor$1 com.mongodb.internal.connection.DefaultServer$DefaultServerProtocolExecutor$2 com.mongodb.internal.connection.DefaultServer$DefaultServerStateListener
InnerClasses:
public Builder = com.mongodb.connection.ServerDescription$Builder of com.mongodb.connection.ServerDescription
com.mongodb.internal.connection.DefaultServer$1
private DefaultServerProtocolExecutor = com.mongodb.internal.connection.DefaultServer$DefaultServerProtocolExecutor of com.mongodb.internal.connection.DefaultServer
private final DefaultServerStateListener = com.mongodb.internal.connection.DefaultServer$DefaultServerStateListener of com.mongodb.internal.connection.DefaultServer