ome.services.blitz.impl

Class SharedResourcesI

java.lang.Object

ome.services.blitz.impl.AbstractAmdServant

ome.services.blitz.impl.AbstractCloseableAmdServant

ome.services.blitz.impl.SharedResourcesI

All Implemented Interfaces:

BlitzOnly, ServiceFactoryAware, omero.grid._SharedResourcesOperations, ParamsHelper.Acquirer, CloseableServant, ApplicationContextAware

public class SharedResourcesI
extends AbstractCloseableAmdServant
implements omero.grid._SharedResourcesOperations, BlitzOnly, ServiceFactoryAware, ParamsHelper.Acquirer

Implementation of the SharedResources interface.

Since:

Beta4.1

Author:

Josh Moore, josh at glencoesoftware.com

See Also:

SharedResources

Field Summary

Fields

Modifier and Type	Field and Description
static long	DEFAULT_TIMEOUT If no value is passed to this instance, this is the time (1 hour) which will be used for a script session.

Fields inherited from class ome.services.blitz.impl.AbstractAmdServant

be, ctx, holder, invoker, service

Constructor Summary

Constructors

Constructor and Description
SharedResourcesI(BlitzExecutor be, TopicManager topicManager, Registry registry, ScriptRepoHelper helper, ParamsCache cache)
SharedResourcesI(BlitzExecutor be, TopicManager topicManager, Registry registry, ScriptRepoHelper helper, ParamsCache cache, long waitMillis)
SharedResourcesI(BlitzExecutor be, TopicManager topicManager, Registry registry, ScriptRepoHelper helper, ParamsCache cache, long waitMillis, long timeout)

Method Summary

Modifier and Type	Method and Description
omero.grid.InteractiveProcessorPrx	acquireProcessor(omero.model.Job submittedJob, int seconds, Ice.Current current)
void	addProcessor(omero.grid.ProcessorPrx proc, Ice.Current __current)
boolean	areTablesEnabled(Ice.Current __current)
omero.grid.RepositoryPrx	getScriptRepository(Ice.Current __current)
omero.grid.TablePrx	newTable(long repo, String path, Ice.Current __current)
omero.grid.TablePrx	openTable(omero.model.OriginalFile file, Ice.Current __current)
protected void	postClose(Ice.Current current) Should not throw any exceptions which should be detected by clients since it is called in a finally block after the client thread has been released.
protected void	preClose(Ice.Current current)
void	removeProcessor(omero.grid.ProcessorPrx proc, Ice.Current __current)
omero.grid.RepositoryMap	repositories(Ice.Current current)
void	setServiceFactory(ServiceFactoryI sf)

Methods inherited from class ome.services.blitz.impl.AbstractCloseableAmdServant

close_async, close

Methods inherited from class ome.services.blitz.impl.AbstractAmdServant

activate_async, applyHardWiredInterceptors, callInvokerOnMappedArgs, callInvokerOnRawArgs, executorWorkCall, getCurrentEventContext_async, onSetOmeroContext, passivate_async, runnableCall, safeRunnableCall, setApplicationContext, setHolder

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

DEFAULT_TIMEOUT

public static final long DEFAULT_TIMEOUT

If no value is passed to this instance, this is the time (1 hour) which will be used for a script session.

See Also:

Constant Field Values

Constructor Detail

SharedResourcesI

public SharedResourcesI(BlitzExecutor be,
                        TopicManager topicManager,
                        Registry registry,
                        ScriptRepoHelper helper,
                        ParamsCache cache)

SharedResourcesI

public SharedResourcesI(BlitzExecutor be,
                        TopicManager topicManager,
                        Registry registry,
                        ScriptRepoHelper helper,
                        ParamsCache cache,
                        long waitMillis)

SharedResourcesI

public SharedResourcesI(BlitzExecutor be,
                        TopicManager topicManager,
                        Registry registry,
                        ScriptRepoHelper helper,
                        ParamsCache cache,
                        long waitMillis,
                        long timeout)

Method Detail

setServiceFactory

public void setServiceFactory(ServiceFactoryI sf)
                       throws omero.ServerError

Specified by:

setServiceFactory in interface ServiceFactoryAware

Throws:

omero.ServerError

preClose

protected void preClose(Ice.Current current)

Specified by:

preClose in class AbstractCloseableAmdServant

postClose

protected void postClose(Ice.Current current)

Description copied from class: AbstractCloseableAmdServant

Should not throw any exceptions which should be detected by clients since it is called in a finally block after the client thread has been released.

Specified by:

postClose in class AbstractCloseableAmdServant

getScriptRepository

public omero.grid.RepositoryPrx getScriptRepository(Ice.Current __current)
                                             throws omero.ServerError

Specified by:

getScriptRepository in interface omero.grid._SharedResourcesOperations

Throws:

omero.ServerError

repositories

public omero.grid.RepositoryMap repositories(Ice.Current current)
                                      throws omero.ServerError

Specified by:

repositories in interface omero.grid._SharedResourcesOperations

Throws:

omero.ServerError

areTablesEnabled

public boolean areTablesEnabled(Ice.Current __current)
                         throws omero.ServerError

Specified by:

areTablesEnabled in interface omero.grid._SharedResourcesOperations

Throws:

omero.ServerError

newTable

public omero.grid.TablePrx newTable(long repo,
                                    String path,
                                    Ice.Current __current)
                             throws omero.ServerError

Specified by:

newTable in interface omero.grid._SharedResourcesOperations

Throws:

omero.ServerError

openTable

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

Specified by:

openTable in interface omero.grid._SharedResourcesOperations

Throws:

omero.ServerError

acquireProcessor

public omero.grid.InteractiveProcessorPrx acquireProcessor(omero.model.Job submittedJob,
                                                           int seconds,
                                                           Ice.Current current)
                                                    throws omero.ServerError

Specified by:

acquireProcessor in interface omero.grid._SharedResourcesOperations

Specified by:

acquireProcessor in interface ParamsHelper.Acquirer

Throws:

omero.ServerError

addProcessor

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

Specified by:

addProcessor in interface omero.grid._SharedResourcesOperations

Throws:

omero.ServerError

removeProcessor

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

Specified by:

removeProcessor in interface omero.grid._SharedResourcesOperations

Throws:

omero.ServerError