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 ClientProtocolContext	DEFAULT_PROTOCOL_CONTEXT Default protocol context.
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.
static ClientListenerProtocolVersion	VER_1_7_0 Version 1.7.0.

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

ctx, userAttrs

Constructor Summary

Constructors

Constructor and Description
ClientConnectionContext(GridKernalContext ctx, GridNioSession ses, 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.
byte	clientType()
ClientProtocolContext	currentProtocolContext()
void	decrementActiveTasksCount() Decrements the active compute tasks count.
void	decrementCursors() Increments the cursor count.
ClientListenerProtocolVersion	defaultVersion()
ClientListenerRequestHandler	handler() Handler getter.
void	incrementActiveTasksCount() Increments the active compute tasks count.
void	incrementCursors() Increments the cursor count.
void	initializeFromHandshake(GridNioSession ses, ClientListenerProtocolVersion ver, BinaryReaderExImpl reader) Initialize from handshake message.
boolean	isVersionSupported(ClientListenerProtocolVersion ver)
int	nextTxId() Next transaction id for this connection.
void	notifyClient(ClientNotification notification) Send notification to the client.
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, clientDescriptor, connectionId, initClientDescriptor, 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.

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. Use ClientBitmaskFeature instead.

DEFAULT_VER

public static final ClientListenerProtocolVersion DEFAULT_VER

Default version.

DEFAULT_PROTOCOL_CONTEXT

public static final ClientProtocolContext DEFAULT_PROTOCOL_CONTEXT

Default protocol context.

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:

true if 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 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.

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.