omero.grid

Class _ImportProcessTie

java.lang.Object

Ice.ObjectImpl

omero.grid._ImportProcessDisp

omero.grid._ImportProcessTie

All Implemented Interfaces:

Ice.Object, Ice.TieBase, java.io.Serializable, java.lang.Cloneable, _ServiceInterfaceOperations, _ServiceInterfaceOperationsNC, _StatefulServiceInterfaceOperations, _StatefulServiceInterfaceOperationsNC, ServiceInterface, StatefulServiceInterface, _ImportProcessOperations, _ImportProcessOperationsNC, ImportProcess

public class _ImportProcessTie
extends _ImportProcessDisp
implements Ice.TieBase

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
static long	serialVersionUID

Fields inherited from class omero.grid._ImportProcessDisp

__ids

Fields inherited from interface omero.grid.ImportProcess

ice_staticId

Constructor Summary

Constructors

Constructor and Description
_ImportProcessTie(_ImportProcessOperations delegate)
_ImportProcessTie()

Method Summary

Modifier and Type	Method and Description
void	activate_async(AMD_StatefulServiceInterface_activate __cb, Ice.Current __current) Load a service implementation from disk if it was previously passivated.
void	close_async(AMD_StatefulServiceInterface_close __cb, Ice.Current __current) Frees all resources -- passivated or active -- for the given stateful service and removes its name from the object adapter.
boolean	equals(java.lang.Object rhs)
void	getCurrentEventContext_async(AMD_StatefulServiceInterface_getCurrentEventContext __cb, Ice.Current __current) To free clients from tracking the mapping from session to stateful service, each stateful service can returns its own context information.
HandlePrx	getHandle(Ice.Current __current) Reacquire the handle which was returned by verifyUpload.
ImportSettings	getImportSettings(Ice.Current __current)
RawFileStorePrx	getUploader(int i, Ice.Current __current) Step 1: Returns a RawFileStore that can be used to upload one of the used files.
long	getUploadOffset(int i, Ice.Current __current) In case an upload must be resumed, this provides the location of the last successful upload.
int	hashCode()
java.lang.Object	ice_delegate()
void	ice_delegate(java.lang.Object delegate)
void	passivate_async(AMD_StatefulServiceInterface_passivate __cb, Ice.Current __current) Causes the blitz server to store the service implementation to disk to free memory.
HandlePrx	verifyUpload(java.util.List<java.lang.String> hash, Ice.Current __current) Step 2: Passes a set of client-side calculated hashes to the server for verifying that all of the files were correctly uploaded.

Methods inherited from class omero.grid._ImportProcessDisp

___getHandle, ___getImportSettings, ___getUploader, ___getUploadOffset, ___verifyUpload, __dispatch, __readImpl, __writeImpl, activate_async, close_async, getCurrentEventContext_async, getHandle, getImportSettings, getUploader, getUploadOffset, ice_copyStateFrom, ice_id, ice_id, ice_ids, ice_ids, ice_isA, ice_isA, ice_staticId, passivate_async, verifyUpload

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

_ImportProcessTie

public _ImportProcessTie()

_ImportProcessTie

public _ImportProcessTie(_ImportProcessOperations 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

activate_async

public void activate_async(AMD_StatefulServiceInterface_activate __cb,
                           Ice.Current __current)
                    throws ServerError

Description copied from interface: _StatefulServiceInterfaceOperations

Load a service implementation from disk if it was previously passivated. It is unnecessary to call this method since activation happens automatically, but calling this may prevent a short lapse when the service is first accessed after passivation. It is safe to call this method at any time, even when the service is not passivated.

Specified by:

activate_async in interface _StatefulServiceInterfaceOperations

Parameters:

__cb - The callback object for the operation.

__current - The Current object for the invocation.

Throws:

ServerError

close_async

public void close_async(AMD_StatefulServiceInterface_close __cb,
                        Ice.Current __current)
                 throws ServerError

Description copied from interface: _StatefulServiceInterfaceOperations

Frees all resources -- passivated or active -- for the given stateful service and removes its name from the object adapter. Any further method calls will fail with a Ice::NoSuchObjectException. Note: with JavaEE, the close method was called publicly, and internally this called destroy(). As of the OmeroBlitz migration, this functionality has been combined.

Specified by:

close_async in interface _StatefulServiceInterfaceOperations

Parameters:

__cb - The callback object for the operation.

__current - The Current object for the invocation.

Throws:

ServerError

getCurrentEventContext_async

public void getCurrentEventContext_async(AMD_StatefulServiceInterface_getCurrentEventContext __cb,
                                         Ice.Current __current)
                                  throws ServerError

Description copied from interface: _StatefulServiceInterfaceOperations

To free clients from tracking the mapping from session to stateful service, each stateful service can returns its own context information.

Specified by:

getCurrentEventContext_async in interface _StatefulServiceInterfaceOperations

Parameters:

__cb - The callback object for the operation.

__current - The Current object for the invocation.

Throws:

ServerError

passivate_async

public void passivate_async(AMD_StatefulServiceInterface_passivate __cb,
                            Ice.Current __current)
                     throws ServerError

Description copied from interface: _StatefulServiceInterfaceOperations

Causes the blitz server to store the service implementation to disk to free memory. This is typically done automatically by the server when a pre-defined memory limit is reached, but can be used by the client if it clear that a stateful service will not be used for some time. Activation will happen automatically whether passivation was done manually or automatically.

Specified by:

passivate_async in interface _StatefulServiceInterfaceOperations

Parameters:

__cb - The callback object for the operation.

__current - The Current object for the invocation.

Throws:

ServerError

getHandle

public HandlePrx getHandle(Ice.Current __current)
                    throws ServerError

Description copied from interface: _ImportProcessOperations

Reacquire the handle which was returned by verifyUpload. This is useful in case a new client is re-attaching to a running import. From the Handle instance, the original ImportRequest can also be found.

Specified by:

getHandle in interface _ImportProcessOperations

Parameters:

__current - The Current object for the invocation.

Throws:

ServerError

getImportSettings

public ImportSettings getImportSettings(Ice.Current __current)

Specified by:

getImportSettings in interface _ImportProcessOperations

getUploadOffset

public long getUploadOffset(int i,
                            Ice.Current __current)
                     throws ServerError

Description copied from interface: _ImportProcessOperations

In case an upload must be resumed, this provides the location of the last successful upload.

Specified by:

getUploadOffset in interface _ImportProcessOperations

__current - The Current object for the invocation.

Throws:

ServerError

getUploader

public RawFileStorePrx getUploader(int i,
                                   Ice.Current __current)
                            throws ServerError

Description copied from interface: _ImportProcessOperations

Step 1: Returns a RawFileStore that can be used to upload one of the used files. The index is the same as the used file listed in ImportLocation. omero.api.RawFileStore.close should be called once all data has been transferred. If the file must be re-written, call getUploader with the same index again. Once all uploads have been completed, verifyUpload should be called to initiate background processing

Specified by:

getUploader in interface _ImportProcessOperations

__current - The Current object for the invocation.

Throws:

ServerError

verifyUpload

public HandlePrx verifyUpload(java.util.List<java.lang.String> hash,
                              Ice.Current __current)
                       throws ServerError

Description copied from interface: _ImportProcessOperations

Step 2: Passes a set of client-side calculated hashes to the server for verifying that all of the files were correctly uploaded. If this passes then a Handle proxy is returned, which completes all the necessary import steps. A successful import will return an ImportResponse. Otherwise, some ERR will be returned.

Specified by:

verifyUpload in interface _ImportProcessOperations

__current - The Current object for the invocation.

Throws:

ServerError