public class InteractiveProcessorI extends java.lang.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
.コンストラクタと説明 |
---|
InteractiveProcessorI(ome.system.Principal p,
ome.services.sessions.SessionManager mgr,
ome.services.util.Executor ex,
omero.grid.ProcessorPrx prx,
omero.model.Job job,
long timeout,
Glacier2.SessionControlPrx control,
ParamsHelper paramsHelper,
ome.services.scripts.ScriptRepoHelper scriptRepoHelper,
Ice.Current current) |
修飾子とタイプ | メソッドと説明 |
---|---|
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.
|
public InteractiveProcessorI(ome.system.Principal p, ome.services.sessions.SessionManager mgr, ome.services.util.Executor ex, omero.grid.ProcessorPrx prx, omero.model.Job job, long timeout, Glacier2.SessionControlPrx control, ParamsHelper paramsHelper, ome.services.scripts.ScriptRepoHelper scriptRepoHelper, Ice.Current current) throws omero.ServerError
p
- mgr
- prx
- job
- Unloaded Job
instance, which will be used by
Processor
to reload the Job
timeout
- omero.ServerError
public omero.grid.JobParams params(Ice.Current __current) throws omero.ServerError
params
インタフェース内 omero.grid._InteractiveProcessorOperations
omero.ServerError
public omero.grid.ProcessPrx execute(omero.RMap inputs, Ice.Current __current) throws omero.ServerError
execute
インタフェース内 omero.grid._InteractiveProcessorOperations
omero.ServerError
public omero.RMap getResults(omero.grid.ProcessPrx proc, Ice.Current __current) throws omero.ServerError
getResults
インタフェース内 omero.grid._InteractiveProcessorOperations
omero.ServerError
public long expires(Ice.Current __current)
expires
インタフェース内 omero.grid._InteractiveProcessorOperations
public omero.model.Job getJob(Ice.Current __current)
getJob
インタフェース内 omero.grid._InteractiveProcessorOperations
public boolean setDetach(boolean detach, Ice.Current __current)
setDetach
インタフェース内 omero.grid._InteractiveProcessorOperations
public void stop(Ice.Current __current) throws omero.ServerError
stop
インタフェース内 omero.grid._InteractiveProcessorOperations
omero.ServerError
protected void doStop() throws omero.ServerError
omero.ServerError
public void close(Ice.Current current) throws java.lang.Exception
close
インタフェース内 CloseableServant
java.lang.Exception