Package org.jppf.server.node.remote

Class AbstractRemoteNode

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.remote.AbstractRemoteNode
All Implemented Interfaces:
Runnable, EventListener, org.jppf.comm.recovery.HeartbeatConnectionListener, org.jppf.execute.async.ExecutionManagerListener, org.jppf.node.Node, org.jppf.node.NodeInternal, org.jppf.server.node.ClassLoaderProvider
Direct Known Subclasses:
JPPFRemoteNode
public abstract class AbstractRemoteNode extends org.jppf.server.node.JPPFNode implements org.jppf.comm.recovery.HeartbeatConnectionListener
Instances of this class encapsulate execution nodes.
Since:
5.1
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
    AbstractRemoteNode(String uuid, org.jppf.utils.TypedProperties configuration, org.jppf.node.connection.DriverConnectionInfo connectionInfo, org.jppf.utils.hooks.HookFactory hookFactory)
    Default constructor.

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    closeDataChannel()
     
    void
    heartbeatConnectionFailed(org.jppf.comm.recovery.HeartbeatConnectionEvent event)
     
    protected abstract void
    initClassLoaderManager()
    Create and initialize the class loader manager.
    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

    • AbstractRemoteNode

      public AbstractRemoteNode(String uuid, org.jppf.utils.TypedProperties configuration, org.jppf.node.connection.DriverConnectionInfo connectionInfo, org.jppf.utils.hooks.HookFactory hookFactory)
      Default constructor.
      Parameters:
      uuid - this node's uuid.
      configuration - the configuration of this node.
      connectionInfo - the server connection information.
      hookFactory - used to create and invoke hook instances.

  • Method Details

    • initClassLoaderManager

      protected abstract void initClassLoaderManager()
      Create and initialize the class loader manager.

    • initDataChannel

      public void initDataChannel() throws Exception
      Specified by:
      initDataChannel in interface org.jppf.node.NodeInternal
      Throws:
      Exception

    • closeDataChannel

      public void closeDataChannel() throws Exception
      Specified by:
      closeDataChannel in interface org.jppf.node.NodeInternal
      Throws:
      Exception

    • heartbeatConnectionFailed

      public void heartbeatConnectionFailed(org.jppf.comm.recovery.HeartbeatConnectionEvent event)
      Specified by:
      heartbeatConnectionFailed in interface org.jppf.comm.recovery.HeartbeatConnectionListener

    • isLocal

      public boolean isLocal()
      Specified by:
      isLocal in interface org.jppf.node.Node