Class ClientConnectionContext
- java.lang.Object
-
- org.apache.ignite.internal.processors.odbc.ClientListenerAbstractConnectionContext
-
- org.apache.ignite.internal.processors.platform.client.ClientConnectionContext
-
- All Implemented Interfaces:
ClientListenerConnectionContext
public class ClientConnectionContext extends ClientListenerAbstractConnectionContext
Thin Client connection context.
-
-
Field Summary
Fields Modifier and Type Field Description static ClientListenerProtocolVersionDEFAULT_VERDefault version.static ClientListenerProtocolVersionVER_1_0_0Version 1.0.0.static ClientListenerProtocolVersionVER_1_1_0Version 1.1.0.static ClientListenerProtocolVersionVER_1_2_0Version 1.2.0.static ClientListenerProtocolVersionVER_1_3_0Version 1.3.0.static ClientListenerProtocolVersionVER_1_4_0Version 1.4.0.static ClientListenerProtocolVersionVER_1_5_0Version 1.5.0.static ClientListenerProtocolVersionVER_1_6_0Version 1.6.0.static ClientListenerProtocolVersionVER_1_7_0Version 1.7.0.-
Fields inherited from class org.apache.ignite.internal.processors.odbc.ClientListenerAbstractConnectionContext
ctx, NONE_TX, userAttrs
-
-
Constructor Summary
Constructors Constructor Description ClientConnectionContext(GridKernalContext ctx, GridNioSession ses, long connId, int maxCursors, ThinClientConfiguration thinCfg)Ctor.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidaddTxContext(ClientTxContext txCtx)Add new transaction context to connection.ClientAffinityTopologyVersioncheckAffinityTopologyVersion()Atomically check whether affinity topology version has changed since the last call and sets new version as a last.voidcleanupTxs()byteclientType()ClientProtocolContextcurrentProtocolContext()voiddecrementActiveTasksCount()Decrements the active compute tasks count.voiddecrementCursors()Increments the cursor count.ClientListenerProtocolVersiondefaultVersion()ClientListenerRequestHandlerhandler()Handler getter.voidincrementActiveTasksCount()Increments the active compute tasks count.voidincrementCursors()Increments the cursor count.voidinitializeFromHandshake(GridNioSession ses, ClientListenerProtocolVersion ver, BinaryReaderExImpl reader)Initialize from handshake message.booleanisVersionSupported(ClientListenerProtocolVersion ver)voidnotifyClient(ClientNotification notification)Send notification to the client.voidonDisconnected()Called whenever client is disconnected due to correct connection close or due toIOExceptionduring network operations.ClientListenerMessageParserparser()Parser gettervoidremoveTxContext(int txId)Remove transaction context from connection.ClientResourceRegistryresources()Gets the handle registry.@Nullable ClientTxContexttxContext(int txId)Transaction context by transaction id.-
Methods inherited from class org.apache.ignite.internal.processors.odbc.ClientListenerAbstractConnectionContext
attributes, authenticate, clientDescriptor, connectionId, initClientDescriptor, kernalContext, nextTxId, securityContext
-
-
-
-
Field Detail
-
VER_1_0_0
public static final ClientListenerProtocolVersion VER_1_0_0
Version 1.0.0.
-
VER_1_1_0
public static final ClientListenerProtocolVersion VER_1_1_0
Version 1.1.0.
-
VER_1_2_0
public static final ClientListenerProtocolVersion VER_1_2_0
Version 1.2.0.
-
VER_1_3_0
public static final ClientListenerProtocolVersion VER_1_3_0
Version 1.3.0.
-
VER_1_4_0
public static final ClientListenerProtocolVersion VER_1_4_0
Version 1.4.0. Added: Partition awareness, IEP-23.
-
VER_1_5_0
public static final ClientListenerProtocolVersion VER_1_5_0
Version 1.5.0. Added: Transactions support, IEP-34.
-
VER_1_6_0
public static final ClientListenerProtocolVersion VER_1_6_0
Version 1.6.0. Added: Expiration Policy configuration.
-
VER_1_7_0
public static final ClientListenerProtocolVersion VER_1_7_0
Version 1.7.0. Added: protocol features. ATTENTION! Do not add any new protocol versions unless totally necessary. UseClientBitmaskFeatureinstead.
-
DEFAULT_VER
public static final ClientListenerProtocolVersion DEFAULT_VER
Default version.
-
-
Constructor Detail
-
ClientConnectionContext
public ClientConnectionContext(GridKernalContext ctx, GridNioSession ses, long connId, int maxCursors, ThinClientConfiguration thinCfg)
Ctor.- Parameters:
ctx- Kernal context.connId- Connection ID.maxCursors- Max active cursors.thinCfg- Thin-client configuration.
-
-
Method Detail
-
resources
public ClientResourceRegistry resources()
Gets the handle registry.- Returns:
- Handle registry.
-
clientType
public byte clientType()
- Returns:
- Client type.
-
isVersionSupported
public boolean isVersionSupported(ClientListenerProtocolVersion ver)
- Parameters:
ver- Version to check.- Returns:
trueif version is supported.
-
defaultVersion
public ClientListenerProtocolVersion defaultVersion()
- Returns:
- Current context version.
-
currentProtocolContext
public ClientProtocolContext currentProtocolContext()
- Returns:
- Currently used protocol context.
-
initializeFromHandshake
public void initializeFromHandshake(GridNioSession ses, ClientListenerProtocolVersion ver, BinaryReaderExImpl reader) throws IgniteCheckedException
Initialize from handshake message.- Parameters:
ses- NIO session.ver- Protocol version.reader- Reader set to the configuration part of the handshake message.- Throws:
IgniteCheckedException- On error.
-
handler
public ClientListenerRequestHandler handler()
Handler getter.- Returns:
- Request handler for the connection.
-
parser
public ClientListenerMessageParser parser()
Parser getter- Returns:
- Message parser for the connection.
-
onDisconnected
public void onDisconnected()
Called whenever client is disconnected due to correct connection close or due toIOExceptionduring network operations.- Specified by:
onDisconnectedin interfaceClientListenerConnectionContext- Overrides:
onDisconnectedin classClientListenerAbstractConnectionContext
-
incrementCursors
public void incrementCursors()
Increments the cursor count.
-
decrementCursors
public void decrementCursors()
Increments the cursor count.
-
checkAffinityTopologyVersion
public ClientAffinityTopologyVersion checkAffinityTopologyVersion()
Atomically check whether affinity topology version has changed since the last call and sets new version as a last.- Returns:
- New version, if it has changed since the last call.
-
txContext
@Nullable public @Nullable ClientTxContext txContext(int txId)
Transaction context by transaction id.- Specified by:
txContextin classClientListenerAbstractConnectionContext- Parameters:
txId- Tx ID.
-
addTxContext
public void addTxContext(ClientTxContext txCtx)
Add new transaction context to connection.- Specified by:
addTxContextin classClientListenerAbstractConnectionContext- Parameters:
txCtx- Tx context.
-
removeTxContext
public void removeTxContext(int txId)
Remove transaction context from connection.- Specified by:
removeTxContextin classClientListenerAbstractConnectionContext- Parameters:
txId- Tx ID.
-
cleanupTxs
public void cleanupTxs()
- Specified by:
cleanupTxsin classClientListenerAbstractConnectionContext
-
notifyClient
public void notifyClient(ClientNotification notification)
Send notification to the client.- Parameters:
notification- Notification.
-
incrementActiveTasksCount
public void incrementActiveTasksCount()
Increments the active compute tasks count.
-
decrementActiveTasksCount
public void decrementActiveTasksCount()
Decrements the active compute tasks count.
-
-