org.jppf.server.node
Interface NodeIO

All Known Implementing Classes:

AbstractNodeIO, LocalNodeIO, RemoteNodeIO

public interface NodeIO

This interface defines how a node receives a job and sends its execution results.

Author:

Laurent Cohen

Method Summary

Pair<JPPFTaskBundle,List<JPPFTask>>	readTask() Read a task from the socket connection, along with its header information.
void	writeResults(JPPFTaskBundle bundle, List<JPPFTask> tasks) Write the execution results to the socket stream.

Method Detail

readTask

Pair<JPPFTaskBundle,List<JPPFTask>> readTask()
                                             throws Exception

Read a task from the socket connection, along with its header information.

Returns:

a pair of JPPFTaskBundle and a List of JPPFTask instances.

Throws:

Exception - if an error is raised while reading the task data.

writeResults

void writeResults(JPPFTaskBundle bundle,
                  List<JPPFTask> 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 writtng to the socket stream.