ome.services.blitz.impl

Class MetadataStoreI

java.lang.Object

ome.services.blitz.impl.AbstractAmdServant

ome.services.blitz.impl.AbstractCloseableAmdServant

ome.services.blitz.impl.MetadataStoreI

All Implemented Interfaces:

BlitzOnly, ServiceFactoryAware, omero.api._MetadataStoreOperations, omero.api._ServiceInterfaceOperations, omero.api._StatefulServiceInterfaceOperations, CloseableServant, org.springframework.context.ApplicationContextAware

public class MetadataStoreI
extends AbstractCloseableAmdServant
implements omero.api._MetadataStoreOperations, ServiceFactoryAware, BlitzOnly

Field Summary

Fields

Modifier and Type	Field and Description
protected OriginalFilesService	filesService
protected String	omeroDataDir
protected PopulateRoiJob	popRoi
protected Set<Long>	savedImagesNotInPlates
protected Set<Long>	savedPlates
protected ServiceFactoryI	sf
protected SqlAction	sql
protected OMEROMetadataStore	store

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

be, ctx, holder, invoker, service

Constructor Summary

Constructors

Constructor and Description
MetadataStoreI(BlitzExecutor be, PopulateRoiJob popRoi, SqlAction sql, OriginalFilesService filesService, String omeroDataDir)

Method Summary

Modifier and Type	Method and Description
void	createRoot_async(omero.api.AMD_MetadataStore_createRoot __cb, Ice.Current __current)
void	onSetOmeroContext(OmeroContext ctx) To be overridden by subclasses.
void	populateMinMax_async(omero.api.AMD_MetadataStore_populateMinMax __cb, double[][][] imageChannelGlobalMinMax, 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.
void	postProcess_async(omero.api.AMD_MetadataStore_postProcess __cb, Ice.Current __current) Called after some number of Passes the savedPlates to a background processor for further work.
protected void	preClose(Ice.Current current)
void	saveToDB_async(omero.api.AMD_MetadataStore_saveToDB __cb, omero.model.FilesetJobLink link, Ice.Current __current)
void	setPixelsFile_async(omero.api.AMD_MetadataStore_setPixelsFile __cb, long pixelsId, String file, String repo, Ice.Current __current)
void	setServiceFactory(ServiceFactoryI sf)
Boolean	toJavaType(omero.RBool x) Transforms an OMERO RType into the corresponding Java type.
Double	toJavaType(omero.RDouble x) Transforms an OMERO RType into the corresponding Java type.
Float	toJavaType(omero.RFloat x) Transforms an OMERO RType into the corresponding Java type.
Integer	toJavaType(omero.RInt x) Transforms an OMERO RType into the corresponding Java type.
Long	toJavaType(omero.RLong x) Transforms an OMERO RType into the corresponding Java type.
String	toJavaType(omero.RString x) Transforms an OMERO RType into the corresponding Java type.
void	updateObjects_async(omero.api.AMD_MetadataStore_updateObjects __cb, omero.metadatastore.IObjectContainer[] objects, Ice.Current __current)
void	updateReferences_async(omero.api.AMD_MetadataStore_updateReferences __cb, Map<String,String[]> references, 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, 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

Field Detail

savedPlates

protected final Set<Long> savedPlates

savedImagesNotInPlates

protected final Set<Long> savedImagesNotInPlates

store

protected OMEROMetadataStore store

sf

protected ServiceFactoryI sf

popRoi

protected PopulateRoiJob popRoi

sql

protected final SqlAction sql

filesService

protected final OriginalFilesService filesService

omeroDataDir

protected final String omeroDataDir

Constructor Detail

MetadataStoreI

public MetadataStoreI(BlitzExecutor be,
                      PopulateRoiJob popRoi,
                      SqlAction sql,
                      OriginalFilesService filesService,
                      String omeroDataDir)
               throws Exception

Throws:

Exception

Method Detail

setServiceFactory

public void setServiceFactory(ServiceFactoryI sf)
                       throws omero.ServerError

Specified by:

setServiceFactory in interface ServiceFactoryAware

Throws:

omero.ServerError

onSetOmeroContext

public void onSetOmeroContext(OmeroContext ctx)
                       throws Exception

Description copied from class: AbstractAmdServant

To be overridden by subclasses.

Overrides:

onSetOmeroContext in class AbstractAmdServant

Throws:

Exception

createRoot_async

public void createRoot_async(omero.api.AMD_MetadataStore_createRoot __cb,
                             Ice.Current __current)
                      throws omero.ServerError

Specified by:

createRoot_async in interface omero.api._MetadataStoreOperations

Throws:

omero.ServerError

populateMinMax_async

public void populateMinMax_async(omero.api.AMD_MetadataStore_populateMinMax __cb,
                                 double[][][] imageChannelGlobalMinMax,
                                 Ice.Current __current)
                          throws omero.ServerError

Specified by:

populateMinMax_async in interface omero.api._MetadataStoreOperations

Throws:

omero.ServerError

saveToDB_async

public void saveToDB_async(omero.api.AMD_MetadataStore_saveToDB __cb,
                           omero.model.FilesetJobLink link,
                           Ice.Current __current)
                    throws omero.ServerError

Specified by:

saveToDB_async in interface omero.api._MetadataStoreOperations

Throws:

omero.ServerError

updateObjects_async

public void updateObjects_async(omero.api.AMD_MetadataStore_updateObjects __cb,
                                omero.metadatastore.IObjectContainer[] objects,
                                Ice.Current __current)
                         throws omero.ServerError

Specified by:

updateObjects_async in interface omero.api._MetadataStoreOperations

Throws:

omero.ServerError

updateReferences_async

public void updateReferences_async(omero.api.AMD_MetadataStore_updateReferences __cb,
                                   Map<String,String[]> references,
                                   Ice.Current __current)
                            throws omero.ServerError

Specified by:

updateReferences_async in interface omero.api._MetadataStoreOperations

Throws:

omero.ServerError

postProcess_async

public void postProcess_async(omero.api.AMD_MetadataStore_postProcess __cb,
                              Ice.Current __current)
                       throws omero.ServerError

Called after some number of Passes the savedPlates to a background processor for further work. This happens on AbstractCloseableAmdServant.close_async(AMD_StatefulServiceInterface_close, Current) since no further pixels can be created, but also on createRoot_async(AMD_MetadataStore_createRoot, Current) which is used by the client to reset the status of this instance. To prevent any possible

Specified by:

postProcess_async in interface omero.api._MetadataStoreOperations

Throws:

omero.ServerError

setPixelsFile_async

public void setPixelsFile_async(omero.api.AMD_MetadataStore_setPixelsFile __cb,
                                long pixelsId,
                                String file,
                                String repo,
                                Ice.Current __current)
                         throws omero.ServerError

Specified by:

setPixelsFile_async in interface omero.api._MetadataStoreOperations

Throws:

omero.ServerError

toJavaType

public Integer toJavaType(omero.RInt x)

Transforms an OMERO RType into the corresponding Java type.

Parameters:

x - OMERO RType value.

Returns:

Java type or null if x is null.

toJavaType

public Long toJavaType(omero.RLong x)

Transforms an OMERO RType into the corresponding Java type.

Parameters:

x - OMERO RType value.

Returns:

Java type or null if x is null.

toJavaType

public Boolean toJavaType(omero.RBool x)

Transforms an OMERO RType into the corresponding Java type.

Parameters:

x - OMERO RType value.

Returns:

Java type or null if x is null.

toJavaType

public Float toJavaType(omero.RFloat x)

Transforms an OMERO RType into the corresponding Java type.

Parameters:

x - OMERO RType value.

Returns:

Java type or null if x is null.

toJavaType

public Double toJavaType(omero.RDouble x)

Transforms an OMERO RType into the corresponding Java type.

Parameters:

x - OMERO RType value.

Returns:

Java type or null if x is null.

toJavaType

public String toJavaType(omero.RString x)

Transforms an OMERO RType into the corresponding Java type.

Parameters:

x - OMERO RType value.

Returns:

Java type or null if x is null.

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