Package org.jppf.server.node.local

Class JPPFLocalNode

java.lang.Object
org.jppf.utils.concurrent.ThreadSynchronization
org.jppf.node.AbstractNode
org.jppf.server.node.AbstractCommonNode
org.jppf.server.node.JPPFNode
org.jppf.server.node.local.JPPFLocalNode
All Implemented Interfaces:
Runnable, org.jppf.execute.async.ExecutionManagerListener, org.jppf.node.Node, org.jppf.node.NodeInternal, org.jppf.server.node.ClassLoaderProvider
public class JPPFLocalNode extends org.jppf.server.node.JPPFNode
Local (in-VM) node implementation.
Author:
Laurent Cohen

  • Field Summary

    Fields inherited from class org.jppf.server.node.AbstractCommonNode

    classLoaderManager, reconnectionNotification

    Fields inherited from class org.jppf.node.AbstractNode

    configuration, helper, hookFactory, jmxEnabled, jmxServer, lifeCycleEventHandler, nodeConnection, nodeIO, serializer, systemInformation, uuid

    Fields inherited from class org.jppf.utils.concurrent.ThreadSynchronization

    stopped

  • Constructor Summary

    Constructors
    Constructor
    Description
    JPPFLocalNode(org.jppf.utils.TypedProperties configuration, AsyncLocalNodeConnection nodeConnection, org.jppf.classloader.AbstractClassLoaderConnection<?> classLoaderConnection, org.jppf.utils.hooks.HookFactory hookFactory)
    Initialize this local node with the specified I/O handler.

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    closeDataChannel()
     
    void
    initDataChannel()
     
    boolean
    isLocal()
     

    Methods inherited from class org.jppf.server.node.JPPFNode

    bundleExecuted, getClassLoader, getHandshakeUuidPath, getJobWriter, getNodeConfigNotifier, getSlaveManager, init, initHelper, run, stopNode, triggerConfigChanged

    Methods inherited from class org.jppf.server.node.AbstractCommonNode

    cancelPendingAction, getClassLoader, getClassLoaderManager, getContainer, getExecutionManager, getJmxServer, getNodeAdmin, getPendingAction, getReconnectionNotification, getSerializationExecutor, hasPendingAction, isExecuting, isOffline, isRestart, isShutdownRequested, isStartedFromMain, isSuspended, requestResourceCacheReset, resetTaskClassLoader, setClassLoader, setExecuting, setNodeAdmin, setPendingAction, setReconnectionNotification, setStartedFromMain, setSuspended, setupBundleParameters, shutdown, stopJmxServer

    Methods inherited from class org.jppf.node.AbstractNode

    getConfiguration, getExecutedTaskCount, getHelper, getHookFactory, getJPPFClassLoader, getLifeCycleEventHandler, getManagementInfo, getMasterNodeUuid, getNodeConnection, getNodeIO, getShuttingDown, getSystemInformation, getUuid, isJmxEnabled, isMasterNode, isSlaveNode, setExecutedTaskCount, setJPPFClassLoader, updateSystemInformation

    Methods inherited from class org.jppf.utils.concurrent.ThreadSynchronization

    goToSleep, goToSleep, goToSleep, isStopped, setStopped, wakeUp

    Methods inherited from class java.lang.Object

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

    Methods inherited from interface org.jppf.node.Node

    isAndroid, isDotnetCapable

  • Constructor Details

    • JPPFLocalNode

      public JPPFLocalNode(org.jppf.utils.TypedProperties configuration, AsyncLocalNodeConnection nodeConnection, org.jppf.classloader.AbstractClassLoaderConnection<?> classLoaderConnection, org.jppf.utils.hooks.HookFactory hookFactory)
      Initialize this local node with the specified I/O handler.
      Parameters:
      configuration - the configuration of this node.
      nodeConnection - wraps the connection to the driver's job server.
      classLoaderConnection - wraps the connection to the driver's class server.
      hookFactory - used to create and invoke hook instances.

  • Method Details

    • initDataChannel

      public void initDataChannel() throws Exception
      Throws:
      Exception

    • closeDataChannel

      public void closeDataChannel() throws Exception
      Throws:
      Exception

    • isLocal

      public boolean isLocal()