zeta.processor
Class WorkUnitFileProcessor

java.lang.Object
  |
  +--zeta.processor.DefaultWorkUnitProcessor
        |
        +--zeta.processor.WorkUnitFileProcessor

All Implemented Interfaces:

TaskProcessor, TaskRequestWorkUnitProcessor, TaskResultProcessor

public class WorkUnitFileProcessor

extends DefaultWorkUnitProcessor

Processes work units as files received through the request and the result handler.

Constructor Summary

WorkUnitFileProcessor()

Method Summary

int	activateWorkUnit(java.sql.Statement stmt, WorkUnit workUnit) Activates the specified work unit for the requested client.
boolean	processResult(java.sql.Statement stmt, WorkUnit workUnit, byte[] result, boolean recomputation) Processes work units received through the result handler

Methods inherited from class zeta.processor.DefaultWorkUnitProcessor

checkResult, getParameters, getWorkUnit, init

Methods inherited from class java.lang.Object

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

Constructor Detail

WorkUnitFileProcessor

public WorkUnitFileProcessor()

Method Detail

processResult

public boolean processResult(java.sql.Statement stmt,
                             WorkUnit workUnit,
                             byte[] result,
                             boolean recomputation)
                      throws javax.servlet.ServletException,
                             java.sql.SQLException,
                             java.io.IOException

Processes work units received through the result handler

Specified by:

processResult in interface TaskResultProcessor

Overrides:

processResult in class DefaultWorkUnitProcessor

Parameters:

stmt - statement object's database

workUnit - work unit which should be processed

result - buffer with the zipped result

recomputation - if the result was recomputed

Returns:

true if the ResultHandler shall save the result into the database.

Throws:

java.io.IOException - if an I/O error occurs.

javax.servlet.ServletException

java.sql.SQLException

activateWorkUnit

public int activateWorkUnit(java.sql.Statement stmt,
                            WorkUnit workUnit)
                     throws javax.servlet.ServletException,
                            java.sql.SQLException

Activates the specified work unit for the requested client.

Specified by:

activateWorkUnit in interface TaskRequestWorkUnitProcessor

Overrides:

activateWorkUnit in class DefaultWorkUnitProcessor

Parameters:

stmt - statement object's database

workUnit - work unit

Returns:

less than 0 if an error occurs, 0 if the specified work unit is activated but no further work unit can be activated, and greater 0 if the specified work unit is activated and further work units can be activated.

Throws:

java.sql.SQLException - if a database access error occurs.

javax.servlet.ServletException