omero.grid

Interface _ProcessorOperationsNC

All Known Subinterfaces:

Processor

All Known Implementing Classes:

_ProcessorDisp, _ProcessorTie

public interface _ProcessorOperationsNC

Simple controller for Processes. Uses the session id given to create an Ice.Config file which is used as the sole argument to an execution of the given job. Jobs are responsible for loading arguments from the environment via the session id.

Method Summary

Modifier and Type	Method and Description
JobParams	parseJob(java.lang.String session, Job jobObject) Parses a job and returns metadata definition required for properly submitting the job.
ProcessPrx	processJob(java.lang.String session, JobParams params, Job jobObject) Starts a process based on the given job If this processor cannot handle the given job, a null process will be returned.
void	requestRunning(ProcessorCallbackPrx cb) Used by servers to find out what jobs are still active.
void	willAccept(Experimenter userContext, ExperimenterGroup groupContext, Job scriptContext, ProcessorCallbackPrx cb) Called by SharedResources to find a suitable target for omero.grid.SharedResources.acquireProcessor.

Method Detail

willAccept

void willAccept(Experimenter userContext,
                ExperimenterGroup groupContext,
                Job scriptContext,
                ProcessorCallbackPrx cb)

Called by SharedResources to find a suitable target for omero.grid.SharedResources.acquireProcessor. New processor instances are added to the checklist by using omero.grid.SharedResources.addProcessor. All processors must respond with their session uuid in order to authorize the action.

requestRunning

void requestRunning(ProcessorCallbackPrx cb)

Used by servers to find out what jobs are still active. Response will be sent to ProcessorCallback.responseRunning

parseJob

JobParams parseJob(java.lang.String session,
                   Job jobObject)
            throws ServerError

Parses a job and returns metadata definition required for properly submitting the job. This object will be cached by the server, and passed back into processJob

Throws:

ServerError

processJob

ProcessPrx processJob(java.lang.String session,
                      JobParams params,
                      Job jobObject)
               throws ServerError

Starts a process based on the given job If this processor cannot handle the given job, a null process will be returned. The params argument was created by a previously call to parseJob.

Throws:

ServerError