Package org.jppf.server.node.local

Class AsyncLocalNodeIO

java.lang.Object
org.jppf.server.node.AbstractNodeIO<JPPFLocalNode>
org.jppf.server.node.local.AsyncLocalNodeIO
All Implemented Interfaces:
org.jppf.server.node.NodeIO
public class AsyncLocalNodeIO extends org.jppf.server.node.AbstractNodeIO<JPPFLocalNode>
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
    AsyncLocalNodeIO(JPPFLocalNode 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 Object[]
    deserializeObjects(org.jppf.node.protocol.TaskBundle bundle, LocalNodeMessage currentMessage)
    Perform the deserialization of the objects received through the socket connection.
    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

    • AsyncLocalNodeIO

      public AsyncLocalNodeIO(JPPFLocalNode 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<JPPFLocalNode>
      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<JPPFLocalNode>
      Throws:
      Exception - if any error occurs.

    • deserializeObjects

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

    • deserializeObjects

      protected Object[] deserializeObjects(org.jppf.node.protocol.TaskBundle bundle, LocalNodeMessage currentMessage) throws Exception
      Perform the deserialization of the objects received through the socket connection.
      Parameters:
      bundle - the message header that contains information about the tasks and data provider.
      currentMessage - contains the tasks and data provider inserialized form.
      Returns:
      an array of objects deserialized from the socket stream.
      Throws:
      Exception - if an error occurs while deserializing.

    • 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<JPPFLocalNode>
      Throws:
      Exception