Package org.jppf.server.node.remote

Class RemoteNodeIO

java.lang.Object
org.jppf.server.node.AbstractNodeIO<AbstractRemoteNode>
org.jppf.server.node.remote.RemoteNodeIO
All Implemented Interfaces:
org.jppf.server.node.NodeIO
public class RemoteNodeIO extends org.jppf.server.node.AbstractNodeIO<AbstractRemoteNode>
This class performs the I/O operations requested by the JPPFNode, for reading the task bundles and sending the results back.
Author:
Laurent Cohen

  • Field Summary

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

    node

  • Constructor Summary

    Constructors
    Constructor
    Description
    RemoteNodeIO(AbstractRemoteNode node)
    Initialize this TaskIO with the specified node.

  • Method Summary

    Modifier and Type
    Method
    Description
    protected Object[]
    deserializeObjects()
     
    protected Object[]
    deserializeObjects(org.jppf.node.protocol.TaskBundle bundle)
     
    protected void
    handleReload()
    Performs the actions required if reloading the classes is necessary.
    protected void
    sendResults(org.jppf.node.protocol.TaskBundle bundle, List<org.jppf.node.protocol.Task<?>> tasks)
     

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

    finalizeBundleData, initializeBundleData, postSendResults, readJob, readObjects, writeResults

    Methods inherited from class java.lang.Object

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

  • Constructor Details

    • RemoteNodeIO

      public RemoteNodeIO(AbstractRemoteNode node)
      Initialize this TaskIO with the specified node.
      Parameters:
      node - the node who owns this TaskIO.

  • Method Details

    • deserializeObjects

      protected Object[] deserializeObjects() throws Exception
      Specified by:
      deserializeObjects in class org.jppf.server.node.AbstractNodeIO<AbstractRemoteNode>
      Throws:
      Exception

    • deserializeObjects

      protected Object[] deserializeObjects(org.jppf.node.protocol.TaskBundle bundle) throws Exception
      Specified by:
      deserializeObjects in class org.jppf.server.node.AbstractNodeIO<AbstractRemoteNode>
      Throws:
      Exception

    • handleReload

      protected void handleReload() throws Exception
      Performs the actions required if reloading the classes is necessary.
      Specified by:
      handleReload in class org.jppf.server.node.AbstractNodeIO<AbstractRemoteNode>
      Throws:
      Exception - if any error occurs.

    • sendResults

      protected void sendResults(org.jppf.node.protocol.TaskBundle bundle, List<org.jppf.node.protocol.Task<?>> tasks) throws Exception
      Specified by:
      sendResults in class org.jppf.server.node.AbstractNodeIO<AbstractRemoteNode>
      Throws:
      Exception