org.apache.ignite.internal.processors.platform.client

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 and Description
static ClientListenerProtocolVersion	DEFAULT_VER Default version.
static ClientListenerProtocolVersion	VER_1_0_0 Version 1.0.0.
static ClientListenerProtocolVersion	VER_1_1_0 Version 1.1.0.
static ClientListenerProtocolVersion	VER_1_2_0 Version 1.2.0.
static ClientListenerProtocolVersion	VER_1_3_0 Version 1.3.0.
static ClientListenerProtocolVersion	VER_1_4_0 Version 1.4.0.
static ClientListenerProtocolVersion	VER_1_5_0 Version 1.5.0.
static ClientListenerProtocolVersion	VER_1_6_0 Version 1.6.0.

Fields inherited from class org.apache.ignite.internal.processors.odbc.ClientListenerAbstractConnectionContext

ctx

Constructor Summary

Constructors

Constructor and Description
ClientConnectionContext(GridKernalContext ctx, long connId, int maxCursors, ThinClientConfiguration thinCfg) Ctor.

Method Summary

Modifier and Type	Method and Description
void	addTxContext(ClientTxContext txCtx) Add new transaction context to connection.
ClientAffinityTopologyVersion	checkAffinityTopologyVersion() Atomically check whether affinity topology version has changed since the last call and sets new version as a last.
ClientListenerProtocolVersion	currentVersion()
void	decrementCursors() Increments the cursor count.
ClientListenerProtocolVersion	defaultVersion()
ClientListenerRequestHandler	handler() Handler getter.
void	incrementCursors() Increments the cursor count.
void	initializeFromHandshake(ClientListenerProtocolVersion ver, BinaryReaderExImpl reader) Initialize from handshake message.
boolean	isVersionSupported(ClientListenerProtocolVersion ver)
int	nextTxId() Next transaction id for this connection.
void	onDisconnected() Called whenever client is disconnected due to correct connection close or due to IOException during network operations.
ClientListenerMessageParser	parser() Parser getter
void	removeTxContext(int txId) Remove transaction context from connection.
ClientResourceRegistry	resources() Gets the handle registry.
ClientTxContext	txContext(int txId) Transaction context by transaction id.

Methods inherited from class org.apache.ignite.internal.processors.odbc.ClientListenerAbstractConnectionContext

authenticate, authorizationContext, connectionId, kernalContext, securityContext

Methods inherited from class java.lang.Object

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

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.

DEFAULT_VER

public static final ClientListenerProtocolVersion DEFAULT_VER

Default version.

Constructor Detail

ClientConnectionContext

public ClientConnectionContext(GridKernalContext ctx,
                               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.

isVersionSupported

public boolean isVersionSupported(ClientListenerProtocolVersion ver)

Parameters:

ver - Version to check.

Returns:

true if version is supported.

defaultVersion

public ClientListenerProtocolVersion defaultVersion()

Returns:

Current context version.

currentVersion

public ClientListenerProtocolVersion currentVersion()

Returns:

Currently used protocol version.

initializeFromHandshake

public void initializeFromHandshake(ClientListenerProtocolVersion ver,
                                    BinaryReaderExImpl reader)
                             throws IgniteCheckedException

Initialize from handshake message.

Parameters:

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 to IOException during network operations.

Specified by:

onDisconnected in interface ClientListenerConnectionContext

Overrides:

onDisconnected in class ClientListenerAbstractConnectionContext

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.

nextTxId

public int nextTxId()

Next transaction id for this connection.

txContext

public ClientTxContext txContext(int txId)

Transaction context by transaction id.

Parameters:

txId - Tx ID.

addTxContext

public void addTxContext(ClientTxContext txCtx)

Add new transaction context to connection.

Parameters:

txCtx - Tx context.

removeTxContext

public void removeTxContext(int txId)

Remove transaction context from connection.

Parameters:

txId - Tx ID.