public class SharedResourcesI extends AbstractCloseableAmdServant implements omero.grid._SharedResourcesOperations, BlitzOnly, ServiceFactoryAware, ParamsHelper.Acquirer
SharedResources
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.
|
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) |
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) |
close_async, close
activate_async, applyHardWiredInterceptors, callInvokerOnMappedArgs, callInvokerOnRawArgs, executorWorkCall, getCurrentEventContext_async, onSetOmeroContext, passivate_async, runnableCall, safeRunnableCall, setApplicationContext, setHolder
public static final long DEFAULT_TIMEOUT
public SharedResourcesI(BlitzExecutor be, TopicManager topicManager, Registry registry, ScriptRepoHelper helper, ParamsCache cache)
public SharedResourcesI(BlitzExecutor be, TopicManager topicManager, Registry registry, ScriptRepoHelper helper, ParamsCache cache, long waitMillis)
public SharedResourcesI(BlitzExecutor be, TopicManager topicManager, Registry registry, ScriptRepoHelper helper, ParamsCache cache, long waitMillis, long timeout)
public void setServiceFactory(ServiceFactoryI sf) throws omero.ServerError
setServiceFactory
in interface ServiceFactoryAware
omero.ServerError
protected void preClose(Ice.Current current)
preClose
in class AbstractCloseableAmdServant
protected void postClose(Ice.Current current)
AbstractCloseableAmdServant
postClose
in class AbstractCloseableAmdServant
public omero.grid.RepositoryPrx getScriptRepository(Ice.Current __current) throws omero.ServerError
getScriptRepository
in interface omero.grid._SharedResourcesOperations
omero.ServerError
public omero.grid.RepositoryMap repositories(Ice.Current current) throws omero.ServerError
repositories
in interface omero.grid._SharedResourcesOperations
omero.ServerError
public boolean areTablesEnabled(Ice.Current __current) throws omero.ServerError
areTablesEnabled
in interface omero.grid._SharedResourcesOperations
omero.ServerError
public omero.grid.TablePrx newTable(long repo, String path, Ice.Current __current) throws omero.ServerError
newTable
in interface omero.grid._SharedResourcesOperations
omero.ServerError
public omero.grid.TablePrx openTable(omero.model.OriginalFile file, Ice.Current __current) throws omero.ServerError
openTable
in interface omero.grid._SharedResourcesOperations
omero.ServerError
public omero.grid.InteractiveProcessorPrx acquireProcessor(omero.model.Job submittedJob, int seconds, Ice.Current current) throws omero.ServerError
acquireProcessor
in interface omero.grid._SharedResourcesOperations
acquireProcessor
in interface ParamsHelper.Acquirer
omero.ServerError
public void addProcessor(omero.grid.ProcessorPrx proc, Ice.Current __current) throws omero.ServerError
addProcessor
in interface omero.grid._SharedResourcesOperations
omero.ServerError
public void removeProcessor(omero.grid.ProcessorPrx proc, Ice.Current __current) throws omero.ServerError
removeProcessor
in interface omero.grid._SharedResourcesOperations
omero.ServerError
Version: 5.3.5-ice35-b73
Copyright © 2017 The University of Dundee & Open Microscopy Environment. All Rights Reserved.