Package omero.grid

Class _ImportProcessDisp

java.lang.Object

Ice.ObjectImpl

omero.grid._ImportProcessDisp

All Implemented Interfaces:

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

Direct Known Subclasses:

_ImportProcessTie

public abstract class _ImportProcessDisp
extends Ice.ObjectImpl
implements ImportProcess

User configuration options. These are likely set in the UI before the import is initiated.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field	Description
static java.lang.String[]	__ids
static long	serialVersionUID

Fields inherited from interface omero.grid.ImportProcess

ice_staticId

Fields inherited from interface Ice.Object

ice_staticId

Constructor Summary

Constructors

Constructor	Description
_ImportProcessDisp()

Method Summary

Modifier and Type	Method	Description
static Ice.DispatchStatus	___getHandle(ImportProcess __obj, IceInternal.Incoming __inS, Ice.Current __current)
static Ice.DispatchStatus	___getImportSettings(ImportProcess __obj, IceInternal.Incoming __inS, Ice.Current __current)
static Ice.DispatchStatus	___getUploader(ImportProcess __obj, IceInternal.Incoming __inS, Ice.Current __current)
static Ice.DispatchStatus	___getUploadOffset(ImportProcess __obj, IceInternal.Incoming __inS, Ice.Current __current)
static Ice.DispatchStatus	___verifyUpload(ImportProcess __obj, IceInternal.Incoming __inS, Ice.Current __current)
Ice.DispatchStatus	__dispatch(IceInternal.Incoming in, Ice.Current __current)
protected void	__readImpl(IceInternal.BasicStream __is)
protected void	__writeImpl(IceInternal.BasicStream __os)
void	activate_async(AMD_StatefulServiceInterface_activate __cb)	Load a service implementation from disk if it was previously passivated.
void	close_async(AMD_StatefulServiceInterface_close __cb)	Frees all resources -- passivated or active -- for the given stateful service and removes its name from the object adapter.
void	getCurrentEventContext_async(AMD_StatefulServiceInterface_getCurrentEventContext __cb)	To free clients from tracking the mapping from session to stateful service, each stateful service can returns its own context information.
HandlePrx	getHandle()	Reacquire the handle which was returned by verifyUpload.
ImportSettings	getImportSettings()
RawFileStorePrx	getUploader(int i)	Step 1: Returns a RawFileStore that can be used to upload one of the used files.
long	getUploadOffset(int i)	In case an upload must be resumed, this provides the location of the last successful upload.
protected void	ice_copyStateFrom(Ice.Object __obj)
java.lang.String	ice_id()
java.lang.String	ice_id(Ice.Current __current)
java.lang.String[]	ice_ids()
java.lang.String[]	ice_ids(Ice.Current __current)
boolean	ice_isA(java.lang.String s)
boolean	ice_isA(java.lang.String s, Ice.Current __current)
static java.lang.String	ice_staticId()
void	passivate_async(AMD_StatefulServiceInterface_passivate __cb)	Causes the blitz server to store the service implementation to disk to free memory.
HandlePrx	verifyUpload(java.util.List<java.lang.String> hash)	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 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

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

Methods inherited from interface omero.grid._ImportProcessOperations

getHandle, getImportSettings, getUploader, getUploadOffset, verifyUpload

Methods inherited from interface omero.api._StatefulServiceInterfaceOperations

activate_async, close_async, getCurrentEventContext_async, passivate_async

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

__ids

public static final java.lang.String[] __ids

serialVersionUID

public static final long serialVersionUID

See Also:

Constant Field Values

Constructor Detail

_ImportProcessDisp

public _ImportProcessDisp()

Method Detail

ice_copyStateFrom

protected void ice_copyStateFrom(Ice.Object __obj)
                          throws java.lang.CloneNotSupportedException

Throws:

java.lang.CloneNotSupportedException

ice_isA

public boolean ice_isA(java.lang.String s)

Specified by:

ice_isA in interface Ice.Object

Overrides:

ice_isA in class Ice.ObjectImpl

ice_isA

public boolean ice_isA(java.lang.String s,
                       Ice.Current __current)

Specified by:

ice_isA in interface Ice.Object

Overrides:

ice_isA in class Ice.ObjectImpl

ice_ids

public java.lang.String[] ice_ids()

Specified by:

ice_ids in interface Ice.Object

Overrides:

ice_ids in class Ice.ObjectImpl

ice_ids

public java.lang.String[] ice_ids(Ice.Current __current)

Specified by:

ice_ids in interface Ice.Object

Overrides:

ice_ids in class Ice.ObjectImpl

ice_id

public java.lang.String ice_id()

Specified by:

ice_id in interface Ice.Object

Overrides:

ice_id in class Ice.ObjectImpl

ice_id

public java.lang.String ice_id(Ice.Current __current)

Specified by:

ice_id in interface Ice.Object

Overrides:

ice_id in class Ice.ObjectImpl

ice_staticId

public static java.lang.String ice_staticId()

activate_async

public final void activate_async(AMD_StatefulServiceInterface_activate __cb)
                          throws ServerError

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 _StatefulServiceInterfaceOperationsNC

Parameters:

__cb - The callback object for the operation.

Throws:

ServerError

close_async

public final void close_async(AMD_StatefulServiceInterface_close __cb)
                       throws ServerError

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 _StatefulServiceInterfaceOperationsNC

Parameters:

__cb - The callback object for the operation.

Throws:

ServerError

getCurrentEventContext_async

public final void getCurrentEventContext_async(AMD_StatefulServiceInterface_getCurrentEventContext __cb)
                                        throws ServerError

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 _StatefulServiceInterfaceOperationsNC

Parameters:

__cb - The callback object for the operation.

Throws:

ServerError

passivate_async

public final void passivate_async(AMD_StatefulServiceInterface_passivate __cb)
                           throws ServerError

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 _StatefulServiceInterfaceOperationsNC

Parameters:

__cb - The callback object for the operation.

Throws:

ServerError

getHandle

public final HandlePrx getHandle()
                          throws ServerError

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 _ImportProcessOperationsNC

Throws:

ServerError

getImportSettings

public final ImportSettings getImportSettings()

Specified by:

getImportSettings in interface _ImportProcessOperationsNC

getUploadOffset

public final long getUploadOffset(int i)
                           throws ServerError

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

Specified by:

getUploadOffset in interface _ImportProcessOperationsNC

Throws:

ServerError

getUploader

public final RawFileStorePrx getUploader(int i)
                                  throws ServerError

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 _ImportProcessOperationsNC

Throws:

ServerError

verifyUpload

public final HandlePrx verifyUpload(java.util.List<java.lang.String> hash)
                             throws ServerError

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 _ImportProcessOperationsNC

Throws:

ServerError

___getUploader

public static Ice.DispatchStatus ___getUploader(ImportProcess __obj,
                                                IceInternal.Incoming __inS,
                                                Ice.Current __current)

___verifyUpload

public static Ice.DispatchStatus ___verifyUpload(ImportProcess __obj,
                                                 IceInternal.Incoming __inS,
                                                 Ice.Current __current)

___getUploadOffset

public static Ice.DispatchStatus ___getUploadOffset(ImportProcess __obj,
                                                    IceInternal.Incoming __inS,
                                                    Ice.Current __current)

___getHandle

public static Ice.DispatchStatus ___getHandle(ImportProcess __obj,
                                              IceInternal.Incoming __inS,
                                              Ice.Current __current)

___getImportSettings

public static Ice.DispatchStatus ___getImportSettings(ImportProcess __obj,
                                                      IceInternal.Incoming __inS,
                                                      Ice.Current __current)

__dispatch

public Ice.DispatchStatus __dispatch(IceInternal.Incoming in,
                                     Ice.Current __current)

Specified by:

__dispatch in interface Ice.Object

Overrides:

__dispatch in class Ice.ObjectImpl

__writeImpl

protected void __writeImpl(IceInternal.BasicStream __os)

Overrides:

__writeImpl in class Ice.ObjectImpl

__readImpl

protected void __readImpl(IceInternal.BasicStream __is)

Overrides:

__readImpl in class Ice.ObjectImpl