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	CURRENT_VER Version 1.2.0.
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.

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) Ctor.

Method Summary

Modifier and Type	Method and Description
ClientListenerProtocolVersion	currentVersion()
void	decrementCursors() Increments the cursor count.
ClientListenerRequestHandler	handler() Handler getter.
void	incrementCursors() Increments the cursor count.
void	initializeFromHandshake(ClientListenerProtocolVersion ver, BinaryReaderExImpl reader) Initialize from handshake message.
boolean	isVersionSupported(ClientListenerProtocolVersion ver)
void	onDisconnected() Called whenever client is disconnected due to correct connection close or due to IOException during network operations.
ClientListenerMessageParser	parser() Parser getter
ClientResourceRegistry	resources() Gets the handle registry.

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.

CURRENT_VER

public static final ClientListenerProtocolVersion CURRENT_VER

Version 1.2.0.

Constructor Detail

ClientConnectionContext

public ClientConnectionContext(GridKernalContext ctx,
                               long connId,
                               int maxCursors)

Ctor.

Parameters:

ctx - Kernal context.

connId - Connection ID.

maxCursors - Max active cursors.

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.

currentVersion

public ClientListenerProtocolVersion currentVersion()

Returns:

Current context 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.

incrementCursors

public void incrementCursors()

Increments the cursor count.

decrementCursors

public void decrementCursors()

Increments the cursor count.