omero.grid

Class _ProcessorTie

java.lang.Object

Ice.ObjectImpl

omero.grid._ProcessorDisp

omero.grid._ProcessorTie

All Implemented Interfaces:

Ice.Object, Ice.TieBase, java.io.Serializable, java.lang.Cloneable, _ProcessorOperations, _ProcessorOperationsNC, Processor

public class _ProcessorTie
extends _ProcessorDisp
implements Ice.TieBase

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
static long	serialVersionUID

Fields inherited from class omero.grid._ProcessorDisp

__ids

Fields inherited from interface omero.grid.Processor

ice_staticId

Constructor Summary

Constructors

Constructor and Description
_ProcessorTie(_ProcessorOperations delegate)
_ProcessorTie()

Method Summary

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.

Methods inherited from class omero.grid._ProcessorDisp

___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

Methods inherited from class Ice.ObjectImpl

___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

Methods inherited from class java.lang.Object

finalize, getClass, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface Ice.Object

__read, __read, __write, __write, clone, ice_dispatch, ice_dispatch, ice_operationAttributes, ice_ping, ice_ping, ice_postUnmarshal, ice_preMarshal

Field Detail

serialVersionUID

public static final long serialVersionUID

See Also:

Constant Field Values

Constructor Detail

_ProcessorTie

public _ProcessorTie()

_ProcessorTie

public _ProcessorTie(_ProcessorOperations delegate)

Method Detail

ice_delegate

public java.lang.Object ice_delegate()

Specified by:

ice_delegate in interface Ice.TieBase

ice_delegate

public void ice_delegate(java.lang.Object delegate)

Specified by:

ice_delegate in interface Ice.TieBase

equals

public boolean equals(java.lang.Object rhs)

Overrides:

equals in class java.lang.Object

hashCode

public int hashCode()

Overrides:

hashCode in class java.lang.Object

parseJob

public JobParams parseJob(java.lang.String session,
                          Job jobObject,
                          Ice.Current __current)
                   throws ServerError

Description copied from interface: _ProcessorOperations

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

Specified by:

parseJob in interface _ProcessorOperations

__current - The Current object for the invocation.

Throws:

ServerError

processJob

public ProcessPrx processJob(java.lang.String session,
                             JobParams params,
                             Job jobObject,
                             Ice.Current __current)
                      throws ServerError

Description copied from interface: _ProcessorOperations

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.

Specified by:

processJob in interface _ProcessorOperations

__current - The Current object for the invocation.

Throws:

ServerError

requestRunning

public void requestRunning(ProcessorCallbackPrx cb,
                           Ice.Current __current)

Description copied from interface: _ProcessorOperations

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

Specified by:

requestRunning in interface _ProcessorOperations

__current - The Current object for the invocation.

willAccept

public void willAccept(Experimenter userContext,
                       ExperimenterGroup groupContext,
                       Job scriptContext,
                       ProcessorCallbackPrx cb,
                       Ice.Current __current)

Description copied from interface: _ProcessorOperations

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.

Specified by:

willAccept in interface _ProcessorOperations

__current - The Current object for the invocation.