Package omero.grid

Class _SharedResourcesTie

java.lang.Object

Ice.ObjectImpl

omero.grid._SharedResourcesDisp

omero.grid._SharedResourcesTie

All Implemented Interfaces:

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

public class _SharedResourcesTie
extends _SharedResourcesDisp
implements Ice.TieBase

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field	Description
static long	serialVersionUID

Fields inherited from class omero.grid._SharedResourcesDisp

__ids

Fields inherited from interface Ice.Object

ice_staticId

Fields inherited from interface omero.grid.SharedResources

ice_staticId

Constructor Summary

Constructors

Constructor	Description
_SharedResourcesTie()
_SharedResourcesTie(_SharedResourcesOperations delegate)

Method Summary

Modifier and Type	Method	Description
InteractiveProcessorPrx	acquireProcessor(Job job, int seconds, Ice.Current __current)	Waits up to seconds to acquire a slot in a processor which can handle the given job.
void	addProcessor(ProcessorPrx proc, Ice.Current __current)	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(Ice.Current __current)	Returns true if a Tables service is active in the grid.
boolean	equals(java.lang.Object rhs)
RepositoryPrx	getScriptRepository(Ice.Current __current)	Returns the single (possibly mirrored) script repository which makes all official scripts available.
int	hashCode()
java.lang.Object	ice_delegate()
void	ice_delegate(java.lang.Object delegate)
TablePrx	newTable(long repoId, java.lang.String path, Ice.Current __current)	Creates a new Format(""OMERO.tables"") file at the given path on the given repository.
TablePrx	openTable(OriginalFile file, Ice.Current __current)	Returns a Table instance or null.
void	removeProcessor(ProcessorPrx proc, Ice.Current __current)	Unregisters a Processor from Storm notifications.
RepositoryMap	repositories(Ice.Current __current)	Returns a map between Repository descriptions (omero::model::OriginalFile instances) and RepositoryPrx instances (possibly null).

Methods inherited from class omero.grid._SharedResourcesDisp

___acquireProcessor, ___addProcessor, ___areTablesEnabled, ___getScriptRepository, ___newTable, ___openTable, ___removeProcessor, ___repositories, __dispatch, __readImpl, __writeImpl, acquireProcessor, addProcessor, areTablesEnabled, getScriptRepository, ice_copyStateFrom, ice_id, ice_id, ice_ids, ice_ids, ice_isA, ice_isA, ice_staticId, newTable, openTable, removeProcessor, repositories

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

_SharedResourcesTie

public _SharedResourcesTie()

_SharedResourcesTie

public _SharedResourcesTie(_SharedResourcesOperations 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

acquireProcessor

public InteractiveProcessorPrx acquireProcessor(Job job,
                                                int seconds,
                                                Ice.Current __current)
                                         throws ServerError

Description copied from interface: _SharedResourcesOperations

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

Specified by:

acquireProcessor in interface _SharedResourcesOperations

__current - The Current object for the invocation.

Throws:

ServerError

addProcessor

public void addProcessor(ProcessorPrx proc,
                         Ice.Current __current)
                  throws ServerError

Description copied from interface: _SharedResourcesOperations

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 _SharedResourcesOperations

__current - The Current object for the invocation.

Throws:

ServerError

areTablesEnabled

public boolean areTablesEnabled(Ice.Current __current)
                         throws ServerError

Description copied from interface: _SharedResourcesOperations

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 _SharedResourcesOperations

Parameters:

__current - The Current object for the invocation.

Throws:

ServerError

getScriptRepository

public RepositoryPrx getScriptRepository(Ice.Current __current)
                                  throws ServerError

Description copied from interface: _SharedResourcesOperations

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

Specified by:

getScriptRepository in interface _SharedResourcesOperations

Parameters:

__current - The Current object for the invocation.

Throws:

ServerError

newTable

public TablePrx newTable(long repoId,
                         java.lang.String path,
                         Ice.Current __current)
                  throws ServerError

Description copied from interface: _SharedResourcesOperations

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 _SharedResourcesOperations

__current - The Current object for the invocation.

Throws:

ServerError

openTable

public TablePrx openTable(OriginalFile file,
                          Ice.Current __current)
                   throws ServerError

Description copied from interface: _SharedResourcesOperations

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 _SharedResourcesOperations

__current - The Current object for the invocation.

Throws:

ServerError

removeProcessor

public void removeProcessor(ProcessorPrx proc,
                            Ice.Current __current)
                     throws ServerError

Description copied from interface: _SharedResourcesOperations

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 _SharedResourcesOperations

__current - The Current object for the invocation.

Throws:

ServerError

repositories

public RepositoryMap repositories(Ice.Current __current)
                           throws ServerError

Description copied from interface: _SharedResourcesOperations

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

Specified by:

repositories in interface _SharedResourcesOperations

Parameters:

__current - The Current object for the invocation.

Throws:

ServerError