org.apache.ignite.internal.processors.igfs

Class IgfsContext

java.lang.Object

org.apache.ignite.internal.processors.igfs.IgfsContext

public class IgfsContext
extends Object

IGFS context holding all required components for IGFS instance.

Field Summary

Fields

Modifier and Type	Field and Description
protected IgniteLogger	log Logger.

Constructor Summary

Constructors

Constructor and Description
IgfsContext(GridKernalContext ctx, FileSystemConfiguration cfg, IgfsMetaManager metaMgr, IgfsDataManager dataMgr, IgfsServerManager srvMgr, IgfsFragmentizerManager fragmentizerMgr)

Method Summary

Methods

Modifier and Type	Method and Description
FileSystemConfiguration	configuration()
IgfsDataManager	data()
IgfsFragmentizerManager	fragmentizer()
IgfsEx	igfs()
boolean	igfsNode(ClusterNode node) Checks if given node is a IGFS node.
GridKernalContext	kernalContext()
ClusterNode	localNode() Get local node.
List<IgfsManager>	managers()
IgfsMetaManager	meta()
IgfsLocalMetrics	metrics() Get local metrics.
void	runInIgfsThreadPool(Runnable r) Executes runnable in IGFS executor service.
void	send(ClusterNode node, Object topic, IgfsCommunicationMessage msg, byte plc)
void	send(UUID nodeId, Object topic, IgfsCommunicationMessage msg, byte plc)
IgfsServerManager	server()

Methods inherited from class java.lang.Object

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

Field Detail

log

protected IgniteLogger log

Logger.

Constructor Detail

IgfsContext

public IgfsContext(GridKernalContext ctx,
           FileSystemConfiguration cfg,
           IgfsMetaManager metaMgr,
           IgfsDataManager dataMgr,
           IgfsServerManager srvMgr,
           IgfsFragmentizerManager fragmentizerMgr)
            throws IgniteCheckedException

Parameters:

ctx - Kernal context.

cfg - IGFS configuration.

metaMgr - Meta manager.

dataMgr - Data manager.

srvMgr - Server manager.

fragmentizerMgr - Fragmentizer manager.

Throws:

IgniteCheckedException - If IGFS context instantiation is failed.

Method Detail

igfs

public IgfsEx igfs()

Returns:

IGFS instance.

kernalContext

public GridKernalContext kernalContext()

Returns:

Kernal context.

configuration

public FileSystemConfiguration configuration()

Returns:

IGFS configuration.

managers

public List<IgfsManager> managers()

Returns:

List of managers, in starting order.

meta

public IgfsMetaManager meta()

Returns:

Meta manager.

data

public IgfsDataManager data()

Returns:

Data manager.

server

public IgfsServerManager server()

Returns:

Server manager.

fragmentizer

public IgfsFragmentizerManager fragmentizer()

Returns:

Fragmentizer manager.

send

public void send(UUID nodeId,
        Object topic,
        IgfsCommunicationMessage msg,
        byte plc)
          throws IgniteCheckedException

Parameters:

nodeId - Node ID.

topic - Topic.

msg - Message.

plc - Policy.

Throws:

IgniteCheckedException - In case of error.

send

public void send(ClusterNode node,
        Object topic,
        IgfsCommunicationMessage msg,
        byte plc)
          throws IgniteCheckedException

Parameters:

node - Node.

topic - Topic.

msg - Message.

plc - Policy.

Throws:

IgniteCheckedException - In case of error.

igfsNode

public boolean igfsNode(ClusterNode node)

Checks if given node is a IGFS node.

Parameters:

node - Node to check.

Returns:

True if node has IGFS with this name, false otherwise.

metrics

public IgfsLocalMetrics metrics()

Get local metrics.

Returns:

Local metrics.

localNode

public ClusterNode localNode()

Get local node.

Returns:

Local node.

runInIgfsThreadPool

public void runInIgfsThreadPool(Runnable r)

Executes runnable in IGFS executor service. If execution rejected, runnable will be executed in caller thread.

Parameters:

r - Runnable to execute.