ome.services.blitz.repo

Class ManagedImportProcessI

java.lang.Object

ome.services.blitz.impl.AbstractAmdServant

ome.services.blitz.impl.AbstractCloseableAmdServant

ome.services.blitz.repo.ManagedImportProcessI

All Implemented Interfaces:

ProcessContainer.Process, ServiceFactoryAware, omero.api._ServiceInterfaceOperations, omero.api._StatefulServiceInterfaceOperations, omero.grid._ImportProcessOperations, CloseableServant, org.springframework.context.ApplicationContextAware

public class ManagedImportProcessI
extends AbstractCloseableAmdServant
implements omero.grid._ImportProcessOperations, ServiceFactoryAware, ProcessContainer.Process

Represents a single import within a defined-session all running server-side.

Since:

5.0.0

Author:

Josh Moore, josh at glencoesoftware.com

Field Summary

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

be, ctx, holder, invoker, service

Constructor Summary

Constructors

Constructor and Description
ManagedImportProcessI(ManagedRepositoryI repo, omero.model.Fileset fs, omero.grid.ImportLocation location, omero.grid.ImportSettings settings, Ice.Current __current) Create and register a servant for servicing the import process within a managed repository.

Method Summary

Modifier and Type	Method and Description
void	closeCalled(int idx)
omero.model.Fileset	getFileset()
long	getGroup()
omero.cmd.HandlePrx	getHandle(Ice.Current ignore)
omero.grid.ImportSettings	getImportSettings(Ice.Current __current)
omero.grid.ImportProcessPrx	getProxy()
omero.api.RawFileStorePrx	getUploader(int i, Ice.Current current)
long	getUploadOffset(int idx, Ice.Current ignore)
void	ping()
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)
protected void	registerCallback(omero.api.RawFileStorePrx prx, int idx)
protected omero.grid.ImportProcessPrx	registerProxy(Ice.Current ignore) Adds this instance to the current session so that clients can communicate with it.
void	setOffset(int idx, long offset)
void	setServiceFactory(ServiceFactoryI sf)
void	shutdown()
omero.cmd.HandlePrx	verifyUpload(List<String> hashes, Ice.Current __current)

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

Methods inherited from interface omero.api._StatefulServiceInterfaceOperations

activate_async, close_async, getCurrentEventContext_async, passivate_async

Constructor Detail

ManagedImportProcessI

public ManagedImportProcessI(ManagedRepositoryI repo,
                             omero.model.Fileset fs,
                             omero.grid.ImportLocation location,
                             omero.grid.ImportSettings settings,
                             Ice.Current __current)
                      throws omero.ServerError

Create and register a servant for servicing the import process within a managed repository.

Throws:

omero.ServerError

Method Detail

setServiceFactory

public void setServiceFactory(ServiceFactoryI sf)
                       throws omero.ServerError

Specified by:

setServiceFactory in interface ServiceFactoryAware

Throws:

omero.ServerError

registerProxy

protected omero.grid.ImportProcessPrx registerProxy(Ice.Current ignore)
                                             throws omero.ServerError

Adds this instance to the current session so that clients can communicate with it. Once we move to opening a new session for this import, care must be taken to guarantee that these instances don't leak: i.e. who's responsible for closing them and removing them from the adapter.

Throws:

omero.ServerError

getProxy

public omero.grid.ImportProcessPrx getProxy()

Specified by:

getProxy in interface ProcessContainer.Process

getFileset

public omero.model.Fileset getFileset()

Specified by:

getFileset in interface ProcessContainer.Process

getImportSettings

public omero.grid.ImportSettings getImportSettings(Ice.Current __current)

Specified by:

getImportSettings in interface omero.grid._ImportProcessOperations

getGroup

public long getGroup()

Specified by:

getGroup in interface ProcessContainer.Process

ping

public void ping()

Specified by:

ping in interface ProcessContainer.Process

shutdown

public void shutdown()

Specified by:

shutdown in interface ProcessContainer.Process

getUploader

public omero.api.RawFileStorePrx getUploader(int i,
                                             Ice.Current current)
                                      throws omero.ServerError

Specified by:

getUploader in interface omero.grid._ImportProcessOperations

Throws:

omero.ServerError

registerCallback

protected void registerCallback(omero.api.RawFileStorePrx prx,
                                int idx)

verifyUpload

public omero.cmd.HandlePrx verifyUpload(List<String> hashes,
                                        Ice.Current __current)
                                 throws omero.ServerError

Specified by:

verifyUpload in interface omero.grid._ImportProcessOperations

Throws:

omero.ServerError

getUploadOffset

public long getUploadOffset(int idx,
                            Ice.Current ignore)
                     throws omero.ServerError

Specified by:

getUploadOffset in interface omero.grid._ImportProcessOperations

Throws:

omero.ServerError

getHandle

public omero.cmd.HandlePrx getHandle(Ice.Current ignore)

Specified by:

getHandle in interface omero.grid._ImportProcessOperations

setOffset

public void setOffset(int idx,
                      long offset)

closeCalled

public void closeCalled(int idx)

preClose

protected void preClose(Ice.Current current)
                 throws Throwable

Specified by:

preClose in class AbstractCloseableAmdServant

Throws:

Throwable

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