Package omero.grid

Class _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 Description
      static java.lang.String[] __ids  
      static long serialVersionUID  

      • Fields inherited from interface Ice.Object

        ice_staticId

    • Constructor Summary

      Constructors 
      Constructor Description
      _ProcessorDisp()  

    • Method Summary

      All Methods Static Methods Instance Methods Concrete Methods 
      Modifier and Type Method 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

    • Field Detail

      • __ids

        public static final java.lang.String[] __ids

    • 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

      • 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