public abstract class _ProcessorDisp extends Ice.ObjectImpl implements Processor
Modifier and Type | Field and Description |
---|---|
static java.lang.String[] |
__ids |
static long |
serialVersionUID |
ice_staticId
Constructor and Description |
---|
_ProcessorDisp() |
Modifier and Type | Method and Description |
---|---|
static Ice.DispatchStatus |
___parseJob(Processor __obj,
IceInternal.Incoming __inS,
Ice.Current __current) |
static Ice.DispatchStatus |
___processJob(Processor __obj,
IceInternal.Incoming __inS,
Ice.Current __current) |
static Ice.DispatchStatus |
___requestRunning(Processor __obj,
IceInternal.Incoming __inS,
Ice.Current __current) |
static Ice.DispatchStatus |
___willAccept(Processor __obj,
IceInternal.Incoming __inS,
Ice.Current __current) |
Ice.DispatchStatus |
__dispatch(IceInternal.Incoming in,
Ice.Current __current) |
protected void |
__readImpl(IceInternal.BasicStream __is) |
protected void |
__writeImpl(IceInternal.BasicStream __os) |
protected void |
ice_copyStateFrom(Ice.Object __obj) |
java.lang.String |
ice_id() |
java.lang.String |
ice_id(Ice.Current __current) |
java.lang.String[] |
ice_ids() |
java.lang.String[] |
ice_ids(Ice.Current __current) |
boolean |
ice_isA(java.lang.String s) |
boolean |
ice_isA(java.lang.String s,
Ice.Current __current) |
static java.lang.String |
ice_staticId() |
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 . |
___ice_id, ___ice_ids, ___ice_isA, ___ice_ping, __checkMode, __read, __read, __readImpl, __write, __write, __writeImpl, clone, ice_dispatch, ice_dispatch, ice_operationAttributes, ice_ping, ice_ping, ice_postUnmarshal, ice_preMarshal
equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
__read, __read, __write, __write, clone, ice_dispatch, ice_dispatch, ice_operationAttributes, ice_ping, ice_ping, ice_postUnmarshal, ice_preMarshal
parseJob, processJob, requestRunning, willAccept
public static final java.lang.String[] __ids
public static final long serialVersionUID
protected void ice_copyStateFrom(Ice.Object __obj) throws java.lang.CloneNotSupportedException
java.lang.CloneNotSupportedException
public boolean ice_isA(java.lang.String s)
ice_isA
in interface Ice.Object
ice_isA
in class Ice.ObjectImpl
public boolean ice_isA(java.lang.String s, Ice.Current __current)
ice_isA
in interface Ice.Object
ice_isA
in class Ice.ObjectImpl
public java.lang.String[] ice_ids()
ice_ids
in interface Ice.Object
ice_ids
in class Ice.ObjectImpl
public java.lang.String[] ice_ids(Ice.Current __current)
ice_ids
in interface Ice.Object
ice_ids
in class Ice.ObjectImpl
public java.lang.String ice_id()
ice_id
in interface Ice.Object
ice_id
in class Ice.ObjectImpl
public java.lang.String ice_id(Ice.Current __current)
ice_id
in interface Ice.Object
ice_id
in class Ice.ObjectImpl
public static java.lang.String ice_staticId()
public final JobParams parseJob(java.lang.String session, Job jobObject) throws ServerError
processJob
parseJob
in interface _ProcessorOperationsNC
ServerError
public final ProcessPrx processJob(java.lang.String session, JobParams params, Job jobObject) throws ServerError
params
argument
was created by a previously call to parseJob
.processJob
in interface _ProcessorOperationsNC
ServerError
public final void requestRunning(ProcessorCallbackPrx cb)
ProcessorCallback.responseRunning
requestRunning
in interface _ProcessorOperationsNC
public final void willAccept(Experimenter userContext, ExperimenterGroup groupContext, Job scriptContext, ProcessorCallbackPrx cb)
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.willAccept
in interface _ProcessorOperationsNC
public static Ice.DispatchStatus ___willAccept(Processor __obj, IceInternal.Incoming __inS, Ice.Current __current)
public static Ice.DispatchStatus ___requestRunning(Processor __obj, IceInternal.Incoming __inS, Ice.Current __current)
public static Ice.DispatchStatus ___parseJob(Processor __obj, IceInternal.Incoming __inS, Ice.Current __current)
public static Ice.DispatchStatus ___processJob(Processor __obj, IceInternal.Incoming __inS, Ice.Current __current)
public Ice.DispatchStatus __dispatch(IceInternal.Incoming in, Ice.Current __current)
__dispatch
in interface Ice.Object
__dispatch
in class Ice.ObjectImpl
protected void __writeImpl(IceInternal.BasicStream __os)
__writeImpl
in class Ice.ObjectImpl
protected void __readImpl(IceInternal.BasicStream __is)
__readImpl
in class Ice.ObjectImpl