org.gridgain.grid.kernal

Class GridKernalContextImpl

java.lang.Object

org.gridgain.grid.util.lang.GridMetadataAwareAdapter

org.gridgain.grid.kernal.GridKernalContextImpl

All Implemented Interfaces:

Externalizable, Serializable, Iterable<GridComponent>, GridMetadataAware, GridKernalContext

@GridToStringExclude
public class GridKernalContextImpl
extends GridMetadataAwareAdapter
implements GridKernalContext, Externalizable

Implementation of kernal context.

See Also:

Serialized Form

Constructor Summary

Constructors

Modifier	Constructor and Description
	GridKernalContextImpl() No-arg constructor is required by externalization.
protected	GridKernalContextImpl(GridLoggerProxy log, GridEx grid, GridConfiguration cfg, GridKernalGateway gw, boolean ent) Creates new kernal context.

Method Summary

Methods

Modifier and Type	Method and Description
void	add(GridComponent comp)
void	addHelper(Object helper)
GridAffinityProcessor	affinity() Gets cache data affinity processor.
GridCacheProcessor	cache() Gets caches processor.
GridCheckpointManager	checkpoint() Gets checkpoint manager.
GridClockSyncProcessor	clockSync() Gets time processor.
GridClosureProcessor	closure() Gets closure processor.
GridCollisionManager	collision() Gets collision manager.
Collection<String>	compatibleVersions() Gets list of compatible versions.
List<GridComponent>	components() Gets list of all grid components in the order they were added.
GridConfiguration	config() Gets grid configuration.
GridContinuousProcessor	continuous() Gets event continuous processor.
<K,V> GridDataLoaderProcessor<K,V>	dataLoad() Gets data loader processor.
GridDeploymentManager	deploy() Gets deployment manager.
GridDiscoveryManager	discovery() Gets discovery manager.
GridDrProcessor	dr() Gets replication processor.
ExecutorService	drPool() Gets DR pool.
GridEmailProcessorAdapter	email() Gets email processor.
GridEventStorageManager	event() Gets event storage manager.
GridFailoverManager	failover() Gets failover manager.
GridKernalGateway	gateway() Gets kernal gateway.
GridGgfsProcessorAdapter	ggfs() Gets file system processor.
GridGgfsHelper	ggfsHelper() Gets GGFS utils processor.
GridEx	grid() Gets grid instance managed by kernal.
String	gridName() Gets grid name.
GridIndexingManager	indexing() Gets indexing manager.
GridIoManager	io() Gets communication manager.
boolean	isDaemon() Checks whether this node is daemon.
boolean	isEnterprise()
boolean	isStopping()
Iterator<GridComponent>	iterator()
GridJobProcessor	job() Gets job processor.
GridJobMetricsProcessor	jobMetric() Gets job metric processor.
GridLicenseProcessor	license() Gets license processor.
GridLoadBalancerManager	loadBalancing() Gets load balancing manager.
UUID	localNodeId() Gets local node ID.
GridLogger	log() Gets logger.
GridLogger	log(Class<?> cls) Gets logger for given class.
void	markSegmented() Sets segmented flag to true when node is stopped due to segmentation issues.
GridOffHeapProcessor	offheap() Gets offheap processor.
GridPerformanceSuggestions	performance()
GridPortProcessor	ports() Gets port processor.
void	printMemoryStats() Print grid kernal memory stats (sizes of internal structures, etc.).
GridProduct	product() Gets grid product.
void	product(GridProduct product)
void	readExternal(ObjectInput in)
protected Object	readResolve() Reconstructs object on demarshalling.
GridResourceProcessor	resource() Gets resource processor.
GridRestProcessor	rest() Gets REST processor.
GridScheduleProcessorAdapter	schedule() Gets schedule processor.
GridSecureSessionManager	secureSession() Gets secure session manager.
GridSecurityManager	security() Gets authentication manager.
GridSegmentationProcessor	segmentation() Gets segmentation processor.
boolean	segmented() Gets segmented flag.
GridTaskSessionProcessor	session() Gets task session processor.
GridStreamProcessor	stream() Gets stream processor.
GridSwapSpaceManager	swap() Gets swap space manager.
GridTaskProcessor	task() Gets task processor.
GridTimeoutProcessor	timeout() Gets timeout processor.
GridClockSource	timeSource() Gets grid time source.
void	timeSource(GridClockSource clockSrc) Sets time source.
String	toString()
String	userVersion(ClassLoader ldr) Gets user version for given class loader by checking META-INF/gridgain.xml file for userVersion attribute.
GridVersionProcessor	versionConverter() Gets version converter processor.
void	writeExternal(ObjectOutput out)

Methods inherited from class org.gridgain.grid.util.lang.GridMetadataAwareAdapter

addMeta, addMetaIfAbsent, addMetaIfAbsent, allMeta, clone, copyMeta, copyMeta, hasMeta, hasMeta, meta, putMetaIfAbsent, putMetaIfAbsent, readExternalMeta, removeMeta, removeMeta, replaceMeta, writeExternalMeta

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.gridgain.grid.GridMetadataAware

addMeta, addMetaIfAbsent, addMetaIfAbsent, allMeta, copyMeta, copyMeta, hasMeta, hasMeta, meta, putMetaIfAbsent, putMetaIfAbsent, removeMeta, removeMeta, replaceMeta

Constructor Detail

GridKernalContextImpl

public GridKernalContextImpl()

No-arg constructor is required by externalization.

GridKernalContextImpl

protected GridKernalContextImpl(GridLoggerProxy log,
                     GridEx grid,
                     GridConfiguration cfg,
                     GridKernalGateway gw,
                     boolean ent)

Creates new kernal context.

Parameters:

log - Logger.

grid - Grid instance managed by kernal.

cfg - Grid configuration.

gw - Kernal gateway.

ent - Release enterprise flag.

Method Detail

iterator

public Iterator<GridComponent> iterator()

Specified by:

iterator in interface Iterable<GridComponent>

components

public List<GridComponent> components()

Gets list of all grid components in the order they were added.

Specified by:

components in interface GridKernalContext

Returns:

List of all grid components in the order they were added.

add

public void add(GridComponent comp)

Parameters:

comp - Manager to add.

addHelper

public void addHelper(Object helper)

Parameters:

helper - Helper to add.

compatibleVersions

public Collection<String> compatibleVersions()

Gets list of compatible versions.

Specified by:

compatibleVersions in interface GridKernalContext

Returns:

Compatible versions.

isStopping

public boolean isStopping()

Specified by:

isStopping in interface GridKernalContext

Returns:

True if grid is in the process of stopping.

localNodeId

public UUID localNodeId()

Gets local node ID.

Specified by:

localNodeId in interface GridKernalContext

Returns:

Local node ID.

gridName

public String gridName()

Gets grid name.

Specified by:

gridName in interface GridKernalContext

Returns:

Grid name.

gateway

public GridKernalGateway gateway()

Gets kernal gateway.

Specified by:

gateway in interface GridKernalContext

Returns:

Kernal gateway.

grid

public GridEx grid()

Gets grid instance managed by kernal.

Specified by:

grid in interface GridKernalContext

Returns:

Grid instance.

config

public GridConfiguration config()

Gets grid configuration.

Specified by:

config in interface GridKernalContext

Returns:

Grid configuration.

task

public GridTaskProcessor task()

Gets task processor.

Specified by:

task in interface GridKernalContext

Returns:

Task processor.

job

public GridJobProcessor job()

Gets job processor.

Specified by:

job in interface GridKernalContext

Returns:

Job processor

timeout

public GridTimeoutProcessor timeout()

Gets timeout processor.

Specified by:

timeout in interface GridKernalContext

Returns:

Timeout processor.

clockSync

public GridClockSyncProcessor clockSync()

Gets time processor.

Specified by:

clockSync in interface GridKernalContext

Returns:

Time processor.

resource

public GridResourceProcessor resource()

Gets resource processor.

Specified by:

resource in interface GridKernalContext

Returns:

Resource processor.

jobMetric

public GridJobMetricsProcessor jobMetric()

Gets job metric processor.

Specified by:

jobMetric in interface GridKernalContext

Returns:

Metrics processor.

cache

public GridCacheProcessor cache()

Gets caches processor.

Specified by:

cache in interface GridKernalContext

Returns:

Cache processor.

session

public GridTaskSessionProcessor session()

Gets task session processor.

Specified by:

session in interface GridKernalContext

Returns:

Session processor.

closure

public GridClosureProcessor closure()

Gets closure processor.

Specified by:

closure in interface GridKernalContext

Returns:

Closure processor.

ports

public GridPortProcessor ports()

Gets port processor.

Specified by:

ports in interface GridKernalContext

Returns:

Port processor.

email

public GridEmailProcessorAdapter email()

Gets email processor.

Specified by:

email in interface GridKernalContext

Returns:

Email processor.

offheap

public GridOffHeapProcessor offheap()

Gets offheap processor.

Specified by:

offheap in interface GridKernalContext

Returns:

Off-heap processor.

schedule

public GridScheduleProcessorAdapter schedule()

Gets schedule processor.

Specified by:

schedule in interface GridKernalContext

Returns:

Schedule processor.

stream

public GridStreamProcessor stream()

Gets stream processor.

Specified by:

stream in interface GridKernalContext

Returns:

Stream processor.

deploy

public GridDeploymentManager deploy()

Gets deployment manager.

Specified by:

deploy in interface GridKernalContext

Returns:

Deployment manager.

io

public GridIoManager io()

Gets communication manager.

Specified by:

io in interface GridKernalContext

Returns:

Communication manager.

discovery

public GridDiscoveryManager discovery()

Gets discovery manager.

Specified by:

discovery in interface GridKernalContext

Returns:

Discovery manager.

checkpoint

public GridCheckpointManager checkpoint()

Gets checkpoint manager.

Specified by:

checkpoint in interface GridKernalContext

Returns:

Checkpoint manager.

event

public GridEventStorageManager event()

Gets event storage manager.

Specified by:

event in interface GridKernalContext

Returns:

Event storage manager.

failover

public GridFailoverManager failover()

Gets failover manager.

Specified by:

failover in interface GridKernalContext

Returns:

Failover manager.

collision

public GridCollisionManager collision()

Gets collision manager.

Specified by:

collision in interface GridKernalContext

Returns:

Collision manager.

security

public GridSecurityManager security()

Gets authentication manager.

Specified by:

security in interface GridKernalContext

Returns:

Authentication manager.

secureSession

public GridSecureSessionManager secureSession()

Gets secure session manager.

Specified by:

secureSession in interface GridKernalContext

Returns:

Secure session manager.

loadBalancing

public GridLoadBalancerManager loadBalancing()

Gets load balancing manager.

Specified by:

loadBalancing in interface GridKernalContext

Returns:

Load balancing manager.

swap

public GridSwapSpaceManager swap()

Gets swap space manager.

Specified by:

swap in interface GridKernalContext

Returns:

Swap space manager.

indexing

public GridIndexingManager indexing()

Gets indexing manager.

Specified by:

indexing in interface GridKernalContext

Returns:

Indexing manager.

license

public GridLicenseProcessor license()

Gets license processor.

Specified by:

license in interface GridKernalContext

Returns:

License processor.

affinity

public GridAffinityProcessor affinity()

Gets cache data affinity processor.

Specified by:

affinity in interface GridKernalContext

Returns:

Cache data affinity processor.

rest

public GridRestProcessor rest()

Gets REST processor.

Specified by:

rest in interface GridKernalContext

Returns:

REST processor.

segmentation

public GridSegmentationProcessor segmentation()

Gets segmentation processor.

Specified by:

segmentation in interface GridKernalContext

Returns:

Segmentation processor.

dataLoad

public <K,V> GridDataLoaderProcessor<K,V> dataLoad()

Gets data loader processor.

Specified by:

dataLoad in interface GridKernalContext

Returns:

Data loader processor.

ggfs

public GridGgfsProcessorAdapter ggfs()

Gets file system processor.

Specified by:

ggfs in interface GridKernalContext

Returns:

File system processor.

ggfsHelper

public GridGgfsHelper ggfsHelper()

Gets GGFS utils processor.

Specified by:

ggfsHelper in interface GridKernalContext

Returns:

GGFS utils processor.

continuous

public GridContinuousProcessor continuous()

Gets event continuous processor.

Specified by:

continuous in interface GridKernalContext

Returns:

Event continuous processor.

dr

public GridDrProcessor dr()

Gets replication processor.

Specified by:

dr in interface GridKernalContext

Returns:

Replication processor.

drPool

public ExecutorService drPool()

Gets DR pool.

Specified by:

drPool in interface GridKernalContext

Returns:

DR pool.

versionConverter

public GridVersionProcessor versionConverter()

Gets version converter processor.

Specified by:

versionConverter in interface GridKernalContext

Returns:

Version converter processor.

log

public GridLogger log()

Gets logger.

Specified by:

log in interface GridKernalContext

Returns:

Logger.

log

public GridLogger log(Class<?> cls)

Gets logger for given class.

Specified by:

log in interface GridKernalContext

Parameters:

cls - Class to get logger for.

Returns:

Logger.

markSegmented

public void markSegmented()

Sets segmented flag to true when node is stopped due to segmentation issues.

Specified by:

markSegmented in interface GridKernalContext

segmented

public boolean segmented()

Gets segmented flag.

Specified by:

segmented in interface GridKernalContext

Returns:

True if network is currently segmented, false otherwise.

timeSource

public GridClockSource timeSource()

Gets grid time source.

Specified by:

timeSource in interface GridKernalContext

Returns:

Time source.

product

public void product(GridProduct product)

Parameters:

product - Product.

product

public GridProduct product()

Gets grid product.

Specified by:

product in interface GridKernalContext

Returns:

Grid product.

timeSource

public void timeSource(GridClockSource clockSrc)

Sets time source. For test purposes only.

Parameters:

clockSrc - Time source.

performance

public GridPerformanceSuggestions performance()

Specified by:

performance in interface GridKernalContext

Returns:

Performance suggestions object.

isEnterprise

public boolean isEnterprise()

Specified by:

isEnterprise in interface GridKernalContext

Returns:

Enterprise release flag.

printMemoryStats

public void printMemoryStats()

Print grid kernal memory stats (sizes of internal structures, etc.). NOTE: This method is for testing and profiling purposes only.

Specified by:

printMemoryStats in interface GridKernalContext

isDaemon

public boolean isDaemon()

Checks whether this node is daemon.

Specified by:

isDaemon in interface GridKernalContext

Returns:

True if this node is daemon, false otherwise.

userVersion

public String userVersion(ClassLoader ldr)

Gets user version for given class loader by checking META-INF/gridgain.xml file for userVersion attribute. If gridgain.xml file is not found, or user version is not specified there, then default version (empty string) is returned.

Specified by:

userVersion in interface GridKernalContext

Parameters:

ldr - Class loader.

Returns:

User version for given class loader or empty string if no version was explicitly specified.

writeExternal

public void writeExternal(ObjectOutput out)
                   throws IOException

Specified by:

writeExternal in interface Externalizable

Throws:

IOException

readExternal

public void readExternal(ObjectInput in)
                  throws IOException,
                         ClassNotFoundException

Specified by:

readExternal in interface Externalizable

Throws:

IOException

ClassNotFoundException

readResolve

protected Object readResolve()
                      throws ObjectStreamException

Reconstructs object on demarshalling.

Returns:

Reconstructed object.

Throws:

ObjectStreamException - Thrown in case of demarshalling error.

toString

public String toString()

Overrides:

toString in class Object