com.mongodb.internal.session

Class ClientSessionImpl

java.lang.Object

com.mongodb.internal.session.ClientSessionImpl

All Implemented Interfaces:

ClientSession, java.io.Closeable, java.lang.AutoCloseable

public class ClientSessionImpl
extends java.lang.Object
implements ClientSession

Field Summary

Fields

Modifier and Type	Field and Description
private boolean	closed
private static java.lang.String	CLUSTER_TIME_KEY
private BsonDocument	clusterTime
private BsonTimestamp	operationTime
private ClientSessionOptions	options
private java.lang.Object	originator
private ServerSession	serverSession
private ServerSessionPool	serverSessionPool

Constructor Summary

Constructors

Constructor and Description
ClientSessionImpl(ServerSessionPool serverSessionPool, java.lang.Object originator, ClientSessionOptions options)

Method Summary

Modifier and Type	Method and Description
void	advanceClusterTime(BsonDocument newClusterTime)
void	advanceOperationTime(BsonTimestamp newOperationTime) Set the operation time of the last operation executed in this session.
void	close()
BsonDocument	getClusterTime()
BsonTimestamp	getOperationTime() Gets the operation time of the last operation executed in this session.
ClientSessionOptions	getOptions() Get the options for this session.
java.lang.Object	getOriginator() Gets the originator for the session.
ServerSession	getServerSession()
private BsonDocument	greaterOf(BsonDocument newClusterTime)
private BsonTimestamp	greaterOf(BsonTimestamp newOperationTime)
boolean	isCausallyConsistent() Returns true if operations in this session must be causally consistent

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

CLUSTER_TIME_KEY

private static final java.lang.String CLUSTER_TIME_KEY

See Also:

Constant Field Values

serverSessionPool

private final ServerSessionPool serverSessionPool

serverSession

private final ServerSession serverSession

originator

private final java.lang.Object originator

options

private final ClientSessionOptions options

clusterTime

private BsonDocument clusterTime

operationTime

private BsonTimestamp operationTime

closed

private volatile boolean closed

Constructor Detail

ClientSessionImpl

public ClientSessionImpl(ServerSessionPool serverSessionPool,
                         java.lang.Object originator,
                         ClientSessionOptions options)

Method Detail

getOptions

public ClientSessionOptions getOptions()

Description copied from interface: ClientSession

Get the options for this session.

Specified by:

getOptions in interface ClientSession

Returns:

the options, which may not be null

isCausallyConsistent

public boolean isCausallyConsistent()

Description copied from interface: ClientSession

Returns true if operations in this session must be causally consistent

Specified by:

isCausallyConsistent in interface ClientSession

Returns:

whether operations in this session must be causally consistent.

getOriginator

public java.lang.Object getOriginator()

Description copied from interface: ClientSession

Gets the originator for the session.

Important because sessions must only be used by their own originator.

Specified by:

getOriginator in interface ClientSession

Returns:

the sessions originator

getClusterTime

public BsonDocument getClusterTime()

Specified by:

getClusterTime in interface ClientSession

Returns:

the latest cluster time seen by this session

getOperationTime

public BsonTimestamp getOperationTime()

Description copied from interface: ClientSession

Gets the operation time of the last operation executed in this session.

Specified by:

getOperationTime in interface ClientSession

Returns:

the operation time

getServerSession

public ServerSession getServerSession()

Specified by:

getServerSession in interface ClientSession

Returns:

the server session

advanceOperationTime

public void advanceOperationTime(BsonTimestamp newOperationTime)

Description copied from interface: ClientSession

Set the operation time of the last operation executed in this session.

Specified by:

advanceOperationTime in interface ClientSession

Parameters:

newOperationTime - the operation time

advanceClusterTime

public void advanceClusterTime(BsonDocument newClusterTime)

Specified by:

advanceClusterTime in interface ClientSession

Parameters:

newClusterTime - the cluster time to advance to

greaterOf

private BsonDocument greaterOf(BsonDocument newClusterTime)

greaterOf

private BsonTimestamp greaterOf(BsonTimestamp newOperationTime)

close

public void close()

Specified by:

close in interface ClientSession

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface java.lang.AutoCloseable