omero.grid

Class _ProcessorDisp

java.lang.Object

Ice.ObjectImpl

omero.grid._ProcessorDisp

All Implemented Interfaces:

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

Direct Known Subclasses:

_ProcessorTie

public abstract class _ProcessorDisp
extends Ice.ObjectImpl
implements Processor

Simple controller for Processes. Uses the session id given to create an Ice.Config file which is used as the sole argument to an execution of the given job. Jobs are responsible for loading arguments from the environment via the session id.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String[]	__ids
static long	serialVersionUID

Fields inherited from interface omero.grid.Processor

ice_staticId

Constructor Summary

Constructors

Constructor and Description
_ProcessorDisp()

Method Summary

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.

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

equals, finalize, getClass, hashCode, 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

Methods inherited from interface omero.grid._ProcessorOperations

parseJob, processJob, requestRunning, willAccept

Field Detail

__ids

public static final java.lang.String[] __ids

serialVersionUID

public static final long serialVersionUID

See Also:

Constant Field Values

Constructor Detail

_ProcessorDisp

public _ProcessorDisp()

Method Detail

ice_copyStateFrom

protected void ice_copyStateFrom(Ice.Object __obj)
                          throws java.lang.CloneNotSupportedException

Throws:

java.lang.CloneNotSupportedException

ice_isA

public boolean ice_isA(java.lang.String s)

Specified by:

ice_isA in interface Ice.Object

Overrides:

ice_isA in class Ice.ObjectImpl

ice_isA

public boolean ice_isA(java.lang.String s,
                       Ice.Current __current)

Specified by:

ice_isA in interface Ice.Object

Overrides:

ice_isA in class Ice.ObjectImpl

ice_ids

public java.lang.String[] ice_ids()

Specified by:

ice_ids in interface Ice.Object

Overrides:

ice_ids in class Ice.ObjectImpl

ice_ids

public java.lang.String[] ice_ids(Ice.Current __current)

Specified by:

ice_ids in interface Ice.Object

Overrides:

ice_ids in class Ice.ObjectImpl

ice_id

public java.lang.String ice_id()

Specified by:

ice_id in interface Ice.Object

Overrides:

ice_id in class Ice.ObjectImpl

ice_id

public java.lang.String ice_id(Ice.Current __current)

Specified by:

ice_id in interface Ice.Object

Overrides:

ice_id in class Ice.ObjectImpl

ice_staticId

public static java.lang.String ice_staticId()

parseJob

public final JobParams parseJob(java.lang.String session,
                                Job jobObject)
                         throws ServerError

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 _ProcessorOperationsNC

Throws:

ServerError

processJob

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

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 _ProcessorOperationsNC

Throws:

ServerError

requestRunning

public final void requestRunning(ProcessorCallbackPrx cb)

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

Specified by:

requestRunning in interface _ProcessorOperationsNC

willAccept

public final void willAccept(Experimenter userContext,
                             ExperimenterGroup groupContext,
                             Job scriptContext,
                             ProcessorCallbackPrx cb)

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 _ProcessorOperationsNC

___willAccept

public static Ice.DispatchStatus ___willAccept(Processor __obj,
                                               IceInternal.Incoming __inS,
                                               Ice.Current __current)

___requestRunning

public static Ice.DispatchStatus ___requestRunning(Processor __obj,
                                                   IceInternal.Incoming __inS,
                                                   Ice.Current __current)

___parseJob

public static Ice.DispatchStatus ___parseJob(Processor __obj,
                                             IceInternal.Incoming __inS,
                                             Ice.Current __current)

___processJob

public static Ice.DispatchStatus ___processJob(Processor __obj,
                                               IceInternal.Incoming __inS,
                                               Ice.Current __current)

__dispatch

public Ice.DispatchStatus __dispatch(IceInternal.Incoming in,
                                     Ice.Current __current)

Specified by:

__dispatch in interface Ice.Object

Overrides:

__dispatch in class Ice.ObjectImpl

__writeImpl

protected void __writeImpl(IceInternal.BasicStream __os)

Overrides:

__writeImpl in class Ice.ObjectImpl

__readImpl

protected void __readImpl(IceInternal.BasicStream __is)

Overrides:

__readImpl in class Ice.ObjectImpl