Package 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	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.
static ClientListenerProtocolVersion	VER_1_7_0	Version 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

Modifier and Type	Method	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.
void	cleanupTxs()
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)
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.
@Nullable ClientTxContext	txContext(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

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.

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.

txContext

@Nullable
public @Nullable ClientTxContext txContext(int txId)

Transaction context by transaction id.

Specified by:

txContext in class ClientListenerAbstractConnectionContext

Parameters:

txId - Tx ID.

addTxContext

public void addTxContext(ClientTxContext txCtx)

Add new transaction context to connection.

Specified by:

addTxContext in class ClientListenerAbstractConnectionContext

Parameters:

txCtx - Tx context.

removeTxContext

public void removeTxContext(int txId)

Remove transaction context from connection.

Specified by:

removeTxContext in class ClientListenerAbstractConnectionContext

Parameters:

txId - Tx ID.

cleanupTxs

public void cleanupTxs()

Specified by:

cleanupTxs in class ClientListenerAbstractConnectionContext

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.