Package omero.grid

Class _SharedResourcesDisp

java.lang.Object

Ice.ObjectImpl

omero.grid._SharedResourcesDisp

All Implemented Interfaces:

Ice.Object, java.io.Serializable, java.lang.Cloneable, _SharedResourcesOperations, _SharedResourcesOperationsNC, SharedResources

Direct Known Subclasses:

_SharedResourcesTie

public abstract class _SharedResourcesDisp
extends Ice.ObjectImpl
implements SharedResources

Resource manager provided by each Blitz session for acquiring shared resources in the OmeroGrid. Unlike the other services provided by ServiceFactory instances, it is not guaranteed that a service instance returned from this interface will be returned if that resource happens to be busy. In that case, a null will be returned.

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

Fields inherited from interface omero.grid.SharedResources

ice_staticId

Constructor Summary

Constructors

Constructor	Description
_SharedResourcesDisp()

Method Summary

Modifier and Type	Method	Description
static Ice.DispatchStatus	___acquireProcessor(SharedResources __obj, IceInternal.Incoming __inS, Ice.Current __current)
static Ice.DispatchStatus	___addProcessor(SharedResources __obj, IceInternal.Incoming __inS, Ice.Current __current)
static Ice.DispatchStatus	___areTablesEnabled(SharedResources __obj, IceInternal.Incoming __inS, Ice.Current __current)
static Ice.DispatchStatus	___getScriptRepository(SharedResources __obj, IceInternal.Incoming __inS, Ice.Current __current)
static Ice.DispatchStatus	___newTable(SharedResources __obj, IceInternal.Incoming __inS, Ice.Current __current)
static Ice.DispatchStatus	___openTable(SharedResources __obj, IceInternal.Incoming __inS, Ice.Current __current)
static Ice.DispatchStatus	___removeProcessor(SharedResources __obj, IceInternal.Incoming __inS, Ice.Current __current)
static Ice.DispatchStatus	___repositories(SharedResources __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)
InteractiveProcessorPrx	acquireProcessor(Job job, int seconds)	Waits up to seconds to acquire a slot in a processor which can handle the given job.
void	addProcessor(ProcessorPrx proc)	Registers a Processor for Storm notifications so that other sessions can query whether or not a given processor would accept a given task.
boolean	areTablesEnabled()	Returns true if a Tables service is active in the grid.
RepositoryPrx	getScriptRepository()	Returns the single (possibly mirrored) script repository which makes all official scripts available.
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()
TablePrx	newTable(long repoId, java.lang.String path)	Creates a new Format(""OMERO.tables"") file at the given path on the given repository.
TablePrx	openTable(OriginalFile file)	Returns a Table instance or null.
void	removeProcessor(ProcessorPrx proc)	Unregisters a Processor from Storm notifications.
RepositoryMap	repositories()	Returns a map between Repository descriptions (omero::model::OriginalFile instances) and RepositoryPrx instances (possibly null).

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 omero.grid._SharedResourcesOperations

acquireProcessor, addProcessor, areTablesEnabled, getScriptRepository, newTable, openTable, removeProcessor, repositories

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

serialVersionUID

public static final long serialVersionUID

See Also:

Constant Field Values

Constructor Detail

_SharedResourcesDisp

public _SharedResourcesDisp()

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()

acquireProcessor

public final InteractiveProcessorPrx acquireProcessor(Job job,
                                                      int seconds)
                                               throws ServerError

Waits up to seconds to acquire a slot in a processor which can handle the given job.

Specified by:

acquireProcessor in interface _SharedResourcesOperationsNC

Throws:

ServerError

addProcessor

public final void addProcessor(ProcessorPrx proc)
                        throws ServerError

Registers a Processor for Storm notifications so that other sessions can query whether or not a given processor would accept a given task.

Specified by:

addProcessor in interface _SharedResourcesOperationsNC

Throws:

ServerError

areTablesEnabled

public final boolean areTablesEnabled()
                               throws ServerError

Returns true if a Tables service is active in the grid. If this value is false, then all calls to #ewTable or openTable will either fail or return null (possibly blocking while waiting for a service to startup)

Specified by:

areTablesEnabled in interface _SharedResourcesOperationsNC

Throws:

ServerError

getScriptRepository

public final RepositoryPrx getScriptRepository()
                                        throws ServerError

Returns the single (possibly mirrored) script repository which makes all official scripts available.

Specified by:

getScriptRepository in interface _SharedResourcesOperationsNC

Throws:

ServerError

newTable

public final TablePrx newTable(long repoId,
                               java.lang.String path)
                        throws ServerError

Creates a new Format(""OMERO.tables"") file at the given path on the given repository. The returned Table proxy follows the same semantics as the openTable method.

Specified by:

newTable in interface _SharedResourcesOperationsNC

Throws:

ServerError

openTable

public final TablePrx openTable(OriginalFile file)
                         throws ServerError

Returns a Table instance or null. Table instances are not exclusively owned by the client and may throw an OptimisticLockException if background modifications take place. The file instance must be managed (i.e. have a non-null id) and be of the format ""OMERO.tables"". Use newTable() to create a new instance.

Specified by:

openTable in interface _SharedResourcesOperationsNC

Throws:

ServerError

removeProcessor

public final void removeProcessor(ProcessorPrx proc)
                           throws ServerError

Unregisters a Processor from Storm notifications. If the processor was not already registered via addProcessor this is a no-op.

Specified by:

removeProcessor in interface _SharedResourcesOperationsNC

Throws:

ServerError

repositories

public final RepositoryMap repositories()
                                 throws ServerError

Returns a map between Repository descriptions (omero::model::OriginalFile instances) and RepositoryPrx instances (possibly null).

Specified by:

repositories in interface _SharedResourcesOperationsNC

Throws:

ServerError

___acquireProcessor

public static Ice.DispatchStatus ___acquireProcessor(SharedResources __obj,
                                                     IceInternal.Incoming __inS,
                                                     Ice.Current __current)

___addProcessor

public static Ice.DispatchStatus ___addProcessor(SharedResources __obj,
                                                 IceInternal.Incoming __inS,
                                                 Ice.Current __current)

___removeProcessor

public static Ice.DispatchStatus ___removeProcessor(SharedResources __obj,
                                                    IceInternal.Incoming __inS,
                                                    Ice.Current __current)

___repositories

public static Ice.DispatchStatus ___repositories(SharedResources __obj,
                                                 IceInternal.Incoming __inS,
                                                 Ice.Current __current)

___getScriptRepository

public static Ice.DispatchStatus ___getScriptRepository(SharedResources __obj,
                                                        IceInternal.Incoming __inS,
                                                        Ice.Current __current)

___areTablesEnabled

public static Ice.DispatchStatus ___areTablesEnabled(SharedResources __obj,
                                                     IceInternal.Incoming __inS,
                                                     Ice.Current __current)

___newTable

public static Ice.DispatchStatus ___newTable(SharedResources __obj,
                                             IceInternal.Incoming __inS,
                                             Ice.Current __current)

___openTable

public static Ice.DispatchStatus ___openTable(SharedResources __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