omero.grid

Interface _ProcessorOperations

All Known Subinterfaces:

Processor

All Known Implementing Classes:

_ProcessorDisp, _ProcessorTie

public interface _ProcessorOperations

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, Ice.Current __current) Parses a job and returns metadata definition required for properly submitting the job.
ProcessPrx	processJob(java.lang.String session, JobParams params, Job jobObject, Ice.Current __current) 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, Ice.Current __current) Used by servers to find out what jobs are still active.
void	willAccept(Experimenter userContext, ExperimenterGroup groupContext, Job scriptContext, ProcessorCallbackPrx cb, Ice.Current __current) 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,
                Ice.Current __current)

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.

Parameters:

__current - The Current object for the invocation.

requestRunning

void requestRunning(ProcessorCallbackPrx cb,
                    Ice.Current __current)

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

Parameters:

__current - The Current object for the invocation.

parseJob

JobParams parseJob(java.lang.String session,
                   Job jobObject,
                   Ice.Current __current)
            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

Parameters:

__current - The Current object for the invocation.

Throws:

ServerError

processJob

ProcessPrx processJob(java.lang.String session,
                      JobParams params,
                      Job jobObject,
                      Ice.Current __current)
               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.

Parameters:

__current - The Current object for the invocation.

Throws:

ServerError