Package org.jppf.server.node

Interface NodeIO

All Known Implementing Classes:
AbstractNodeIO
public interface NodeIO
This interface defines how a node receives a job and sends its execution results.
Author:
Laurent Cohen

  • Method Summary

    Modifier and Type
    Method
    Description
    org.jppf.node.protocol.BundleWithTasks
    readJob()
    Read a job from the socket connection, along with its header information.
    void
    writeResults(org.jppf.node.protocol.TaskBundle bundle, List<org.jppf.node.protocol.Task<?>> tasks)
    Write the execution results to the socket stream.

  • Method Details

    • readJob

      org.jppf.node.protocol.BundleWithTasks readJob() throws Exception
      Read a job from the socket connection, along with its header information.
      Returns:
      a pair of JPPFTaskBundle and a List of Task instances.
      Throws:
      Exception - if an error is raised while reading the task data.

    • writeResults

      void writeResults(org.jppf.node.protocol.TaskBundle bundle, List<org.jppf.node.protocol.Task<?>> tasks) throws Exception
      Write the execution results to the socket stream.
      Parameters:
      bundle - the task wrapper to send along.
      tasks - the list of tasks with their result field updated.
      Throws:
      Exception - if an error occurs while writing to the socket stream.