Package com.gigaspaces.lrmi

Class LRMIInvocationContext

java.lang.Object

com.gigaspaces.lrmi.LRMIInvocationContext

public class LRMIInvocationContext
extends Object

Represents thread local lrmi invocation context that is used for debug logging levels

Since:

7.0.1

Author:

eitany

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static enum	LRMIInvocationContext.InvocationStage	Represents the stage of the lrmi invocation
static enum	LRMIInvocationContext.ProxyWriteType

Constructor Summary

Constructors

Constructor	Description
LRMIInvocationContext()

Method Summary

Modifier and Type	Method	Description
static void	enableCallbackModeForNextInvocation()
static void	enableCustomPriorityForNextInvocation()
static void	enableDirectPriorityForNextInvocation()
static void	enableLivenessPriorityForNextInvocation()
InetSocketAddress	getClientEndPointAddress()
static String	getContextMethodLongDisplayString()
static String	getContextMethodShortDisplayString()
static LRMIInvocationContext	getCurrentContext()
static InetSocketAddress	getEndpointAddress()
static PlatformLogicalVersion	getEndpointLogicalVersion()
LRMIInvocationContext.InvocationStage	getInvocationStage()
LRMIInvocationContext.ProxyWriteType	getProxyWriteType()
PlatformLogicalVersion	getSourceLogicalVersion()
PlatformLogicalVersion	getTargetLogicalVersion()
LRMIInvocationTrace	getTrace()
boolean	isCallbackMethod()
boolean	isCustomPriorityEnabled()
boolean	isDirectPriorityEnabled()
boolean	isEmpty()
boolean	isLivenessPriorityEnabled()
boolean	isUseStubCache()
static void	resetContext()	Resets the current context
static void	restoreContext()	Restores the current context to its previous snapshot() stage.
void	setClientEndPointAddress(InetSocketAddress clientEndPointAddress)
void	setCustomPriorityEnabled(boolean customPriorityEnabled)
void	setDirectPriorityEnabled(boolean directPriorityEnabled)
void	setSourceLogicalVersion(PlatformLogicalVersion sourceLogicalVersion)
void	setTrace(LRMIInvocationTrace trace)
void	setUseStubCache(boolean useStubCache)
static void	updateContext(LRMIInvocationTrace invocationTrace, LRMIInvocationContext.ProxyWriteType proxyWriteType, LRMIInvocationContext.InvocationStage stage, PlatformLogicalVersion sourceLogicalVersion, PlatformLogicalVersion targetLogicalVersion, boolean createSnapshot, Boolean useStubCache, InetSocketAddress clientEndPointAddress)	Updates this thread lrmi invocation context

Methods inherited from class java.lang.Object

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

Constructor Details

LRMIInvocationContext

public LRMIInvocationContext()

Method Details

setTrace

public void setTrace(LRMIInvocationTrace trace)

getTrace

public LRMIInvocationTrace getTrace()

setSourceLogicalVersion

public void setSourceLogicalVersion(PlatformLogicalVersion sourceLogicalVersion)

getSourceLogicalVersion

public PlatformLogicalVersion getSourceLogicalVersion()

getTargetLogicalVersion

public PlatformLogicalVersion getTargetLogicalVersion()

getProxyWriteType

public LRMIInvocationContext.ProxyWriteType getProxyWriteType()

getInvocationStage

public LRMIInvocationContext.InvocationStage getInvocationStage()

isEmpty

public boolean isEmpty()

setClientEndPointAddress

public void setClientEndPointAddress(InetSocketAddress clientEndPointAddress)

getClientEndPointAddress

public InetSocketAddress getClientEndPointAddress()

getEndpointLogicalVersion

public static PlatformLogicalVersion getEndpointLogicalVersion()

Returns:

invocation stage related end point logical version, if this is the invocation server then the source logical version is returned, if it is the client then the target logical version is returned. if there is no lrmi invocation context then the current jar logical version is returned.

getContextMethodShortDisplayString

public static String getContextMethodShortDisplayString()

getContextMethodLongDisplayString

public static String getContextMethodLongDisplayString()

getCurrentContext

public static LRMIInvocationContext getCurrentContext()

updateContext

public static void updateContext(LRMIInvocationTrace invocationTrace,
 LRMIInvocationContext.ProxyWriteType proxyWriteType,
 LRMIInvocationContext.InvocationStage stage,
 PlatformLogicalVersion sourceLogicalVersion,
 PlatformLogicalVersion targetLogicalVersion,
 boolean createSnapshot,
 Boolean useStubCache,
 InetSocketAddress clientEndPointAddress)

Updates this thread lrmi invocation context

Parameters:

invocationTrace - trace

proxyWriteType - write type

stage - invocation stage

sourceLogicalVersion - source logical version

targetLogicalVersion - target logical version

createSnapshot - if true, the current context is kept and a new context is created

useStubCache - true if stub cache should be used for this invocation which can later be restored to the current context using the restoreContext() method. if false the current context is overriden with all the non null values parameters.

clientEndPointAddress - - The source ip/port

restoreContext

public static void restoreContext()

Restores the current context to its previous snapshot() stage.

resetContext

public static void resetContext()

Resets the current context

enableLivenessPriorityForNextInvocation

public static void enableLivenessPriorityForNextInvocation()

enableCustomPriorityForNextInvocation

public static void enableCustomPriorityForNextInvocation()

enableDirectPriorityForNextInvocation

public static void enableDirectPriorityForNextInvocation()

enableCallbackModeForNextInvocation

public static void enableCallbackModeForNextInvocation()

setUseStubCache

public void setUseStubCache(boolean useStubCache)

isUseStubCache

public boolean isUseStubCache()

isCallbackMethod

public boolean isCallbackMethod()

isLivenessPriorityEnabled

public boolean isLivenessPriorityEnabled()

setCustomPriorityEnabled

public void setCustomPriorityEnabled(boolean customPriorityEnabled)

isCustomPriorityEnabled

public boolean isCustomPriorityEnabled()

setDirectPriorityEnabled

public void setDirectPriorityEnabled(boolean directPriorityEnabled)

isDirectPriorityEnabled

public boolean isDirectPriorityEnabled()

getEndpointAddress

public static InetSocketAddress getEndpointAddress()