public class _ProcessorTie extends _ProcessorDisp implements Ice.TieBase
Modifier and Type | Field and Description |
---|---|
static long |
serialVersionUID |
__ids
ice_staticId
Constructor and Description |
---|
_ProcessorTie(_ProcessorOperations delegate) |
_ProcessorTie() |
Modifier and Type | Method and Description |
---|---|
boolean |
equals(java.lang.Object rhs) |
int |
hashCode() |
java.lang.Object |
ice_delegate() |
void |
ice_delegate(java.lang.Object delegate) |
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 . |
___parseJob, ___processJob, ___requestRunning, ___willAccept, __dispatch, __readImpl, __writeImpl, ice_copyStateFrom, ice_id, ice_id, ice_ids, ice_ids, ice_isA, ice_isA, ice_staticId, parseJob, processJob, requestRunning, willAccept
___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
public static final long serialVersionUID
public _ProcessorTie()
public _ProcessorTie(_ProcessorOperations delegate)
public java.lang.Object ice_delegate()
ice_delegate
in interface Ice.TieBase
public void ice_delegate(java.lang.Object delegate)
ice_delegate
in interface Ice.TieBase
public boolean equals(java.lang.Object rhs)
equals
in class java.lang.Object
public int hashCode()
hashCode
in class java.lang.Object
public JobParams parseJob(java.lang.String session, Job jobObject, Ice.Current __current) throws ServerError
_ProcessorOperations
processJob
parseJob
in interface _ProcessorOperations
__current
- The Current object for the invocation.ServerError
public ProcessPrx processJob(java.lang.String session, JobParams params, Job jobObject, Ice.Current __current) throws ServerError
_ProcessorOperations
params
argument
was created by a previously call to parseJob
.processJob
in interface _ProcessorOperations
__current
- The Current object for the invocation.ServerError
public void requestRunning(ProcessorCallbackPrx cb, Ice.Current __current)
_ProcessorOperations
ProcessorCallback.responseRunning
requestRunning
in interface _ProcessorOperations
__current
- The Current object for the invocation.public void willAccept(Experimenter userContext, ExperimenterGroup groupContext, Job scriptContext, ProcessorCallbackPrx cb, Ice.Current __current)
_ProcessorOperations
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 _ProcessorOperations
__current
- The Current object for the invocation.