omero.grid

Class InteractiveProcessorI

java.lang.Object

omero.grid.InteractiveProcessorI

All Implemented Interfaces:

omero.grid._InteractiveProcessorOperations, CloseableServant

public class InteractiveProcessorI
extends Object
implements omero.grid._InteractiveProcessorOperations, CloseableServant

Processor implementation which delegates to an omero.grid.Processor servant. Functions as a state machine. A single ProcessPrx can be active at any given time. Once it's complete, then the results can be obtained, then a new Job can be submitted, until stop is set. Any other use throws an ApiUsageException.

Since:

3.0-Beta3

Author:

Josh Moore, josh at glencoesoftware.com

Constructor Summary

Constructors

Constructor and Description
InteractiveProcessorI(Principal p, SessionManager mgr, Executor ex, omero.grid.ProcessorPrx prx, omero.model.Job job, long timeout, Glacier2.SessionControlPrx control, ParamsCache paramsCache, ParamsHelper paramsHelper, ScriptRepoHelper scriptRepoHelper, Ice.Current current)

Method Summary

Methods

Modifier and Type	Method and Description
void	close(Ice.Current current)
protected void	doStop()
omero.grid.ProcessPrx	execute(omero.RMap inputs, Ice.Current __current)
long	expires(Ice.Current __current)
omero.model.Job	getJob(Ice.Current __current)
omero.RMap	getResults(omero.grid.ProcessPrx proc, Ice.Current __current)
omero.grid.JobParams	params(Ice.Current __current)
boolean	setDetach(boolean detach, Ice.Current __current)
void	stop(Ice.Current __current) Cancels the current process, nulls the value, and returns immediately if detach is false.

Methods inherited from class java.lang.Object

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

Constructor Detail

InteractiveProcessorI

public InteractiveProcessorI(Principal p,
                     SessionManager mgr,
                     Executor ex,
                     omero.grid.ProcessorPrx prx,
                     omero.model.Job job,
                     long timeout,
                     Glacier2.SessionControlPrx control,
                     ParamsCache paramsCache,
                     ParamsHelper paramsHelper,
                     ScriptRepoHelper scriptRepoHelper,
                     Ice.Current current)
                      throws omero.ServerError

Parameters:

p -

mgr -

prx -

job - Unloaded Job instance, which will be used by Processor to reload the Job

timeout -

Throws:

omero.ServerError

Method Detail

params

public omero.grid.JobParams params(Ice.Current __current)
                            throws omero.ServerError

Specified by:

params in interface omero.grid._InteractiveProcessorOperations

Throws:

omero.ServerError

execute

public omero.grid.ProcessPrx execute(omero.RMap inputs,
                            Ice.Current __current)
                              throws omero.ServerError

Specified by:

execute in interface omero.grid._InteractiveProcessorOperations

Throws:

omero.ServerError

getResults

public omero.RMap getResults(omero.grid.ProcessPrx proc,
                    Ice.Current __current)
                      throws omero.ServerError

Specified by:

getResults in interface omero.grid._InteractiveProcessorOperations

Throws:

omero.ServerError

expires

public long expires(Ice.Current __current)

Specified by:

expires in interface omero.grid._InteractiveProcessorOperations

getJob

public omero.model.Job getJob(Ice.Current __current)

Specified by:

getJob in interface omero.grid._InteractiveProcessorOperations

setDetach

public boolean setDetach(boolean detach,
                Ice.Current __current)

Specified by:

setDetach in interface omero.grid._InteractiveProcessorOperations

stop

public void stop(Ice.Current __current)
          throws omero.ServerError

Cancels the current process, nulls the value, and returns immediately if detach is false.

Specified by:

stop in interface omero.grid._InteractiveProcessorOperations

Throws:

omero.ServerError

doStop

protected void doStop()
               throws omero.ServerError

Throws:

omero.ServerError

close

public void close(Ice.Current current)
           throws Exception

Specified by:

close in interface CloseableServant

Throws:

Exception