net.sf.joafip.store.service

Class AbstractDelegatingToStoreManagers

java.lang.Object

net.sf.joafip.store.service.AbstractStoreDelegatingToDataManager

net.sf.joafip.store.service.AbstractDelegatingToStoreManagers

All Implemented Interfaces:

IDeepCopyServiceDelegate, IStore, IStoreForGarbage

Direct Known Subclasses:

Store

@NotStorableClass
public abstract class AbstractDelegatingToStoreManagers
extends AbstractStoreDelegatingToDataManager

Author:

luc peuvrier

Field Summary

Fields

Modifier and Type	Field and Description
protected boolean	autoSaveEnabled
protected ClassInfoFactory	classInfoFactory
protected IClassNameManager	classNameManager
protected int	currentDataModelIdentifier data model identifier
protected boolean	garbageManagement true if garbage management activated
protected GarbageManager	garbageManager manager of to garbage record identifier storing and link storing
protected HelperBinaryConversion	helperBinaryConversion
protected HelperReflect	helperReflect
protected Object	mutex file access synchronization mutex
protected ObjectIOManager	objectIOManager object reading and writing on data file manager
protected ProxyManager2	proxyManager2
protected boolean	proxyMode
protected IFilePersistenceAutoSaver	saver
protected StoreGarbager	storeGarbager manage garbage of data record
protected StoreHeader	storeHeader store header, data record #0
protected StoreSaver3	storeSaver manage saving of object
protected StoreSynchro	storeSynchro group of synchronization object for file access, share between Store and ProxyCallBack

Fields inherited from class net.sf.joafip.store.service.AbstractStoreDelegatingToDataManager

dataManager, logger, STORE_DATA, TRACE_FILE

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractDelegatingToStoreManagers(StoreProperties storeProperties)

Method Summary

Methods

Modifier and Type	Method and Description
Collection<ClassInfo>	allClassInformation()
protected DataRecordIdentifier	attachHeapRecordable(IHeapRecordable heapRecordable)
void	autoSaveSetup(int maxInMemoryThreshold)
ClassInfo	classInfoOfObject(Object object)
Class<?>	classOfObject(Object object)
Object	deepCopy(Object sourceObject, boolean forceLoad)
int	getClassIdentifier(Class<?> clazz)
ClassInfoFactory	getClassInfoFactory()
ClassInfo	getClassInfoInDataRecord(DataRecordIdentifier dataRecordIdentifier)
ClassLoaderProvider	getClassLoaderProvider()
IClassNameManager	getClassNameManager()
ConversionManager	getConversionManager()
int	getCurrentDataModelIdentifier()
long	getCurrentFileAccessSessionIdentifier()
GarbageCandidateRecordManager	getGarbageCandidateRecordManager() for test purpose
GarbageManager	getGarbageManager()
HeapRecordableManager	getHeapRecordableManager()
HelperBinaryConversion	getHelperBinaryConversion()
LinkRecordManager	getLinkRecordManager() for test purpose
JoafipMutex	getMutex()
int	getNumberOfObjectExported()
List<ObjectAndPersistInfo>	getObjectAndPersistInfoOfObjectFromQueue()
ObjectAndPersistInfo	getObjectAndPersistInfoOfObjectFromQueue(Object object)
ObjectIOManager	getObjectIOManager()
int	getPersistenceId()
ProxyManager2	getProxyManager2()
StoreSaver3	getStoreSaver()
StoreSynchro	getStoreSynchro()
ToGarbageRecordManager	getToGarbageRecordManager() for test purpose
ToVisitRecordManager	getToVisitRecordManager()
Set<String>	getVisitedObjectSet()
VisitedRecordManager	getVisitedRecordManager()
List<String>	getWroteArrays()
Map<String,MutableInteger>	getWroteObjectSet()
protected void	heapRecordableManagerDoNotSave(boolean clear)
protected void	heapRecordableManagerSave()
boolean	isAutoSaveEnabled()
boolean	isGarbageManagement()
boolean	isKeptInMemory(Object object)
boolean	isProxyMode()
void	keptInMemory(String key, Object object)
String	keyOfObjectKeptInMemory(Object object)
ClassInfo	knownAsNotExisting(String className)
void	listenStateMapClean(IObjectStateMapCLeanListener listener)
protected void	loadClassName()
void	maintainInMemorySetup(int maintainedInMemoryQuota)
Object	newInstance(Class<?> objectClass)
Object	newInstance(Class<?> objectClass, Class<?>[] parameterTypes, Object[] initargs)
protected Object	newInstance(ClassInfo objectClassInfo, Class<?>[] parameterTypes, Object[] initargs)
Object	newInstanceNoConstruction(ClassInfo objectClassInfo)
Object	newProxyInstance(Class<?> objectClass)
Object	newProxyInstance(Class<?> objectClass, Class<?>[] parameterTypes, Object[] initargs)
Object	newProxyInstance(Object sourceObject)
protected boolean	readAndSetHeapRecordableState(IHeapRecordable heapRecordable)
void	referencedByPesistedStaticField(Class<?> classHavingStaticFieldReferenced)
void	setAutoSaveEnabled(boolean enabled)
void	setClassLoaderProvider(ClassLoaderProvider classLoaderProvider)
void	setDeprecatedInStore(NavigableMap<String,Boolean> deprecatedinStoreMap)
void	setExportListener(IExporterListener listener)
void	setImportListener(IImportListener listener)
void	setMaintainedInMemoryEnabled(boolean enabled)
void	setNotStorable(NavigableMap<String,Boolean> notStorableMap)
void	setPersistenceId(int persistenceId)
void	setRecordSaveActions(boolean recordActions)
void	setRecordSaveActions(boolean recordActions, ISaveRecordActionListener saveRecordActionListener)
void	setSaveInDataAccessSessionEnabled(boolean enabled)
void	setSaver(IFilePersistenceAutoSaver saver)
void	setSaveRecordActionListener(ISaveRecordActionListener saveRecordActionListener)
void	setStoreMode(NavigableMap<String,EnumStoreMode> storeModeMap)
void	setStoreOnlyMarkedStorable(boolean storeOnlyMarkedStorable)
void	setZipCompressionLevel(int zipCompressionLevel)
void	stop()
void	storedImmutableEnum(Class<? extends Enum<?>> enumClass) declare immutable enum class to persist
void	usedForClassNameManagement(Set<DataRecordIdentifier> setToUpdate)
void	xmlExport(String directoryName, String temporaryDirectoryName, boolean exportPersistedClassByteCode) export persisted data in file export.xml put in directoryName directory also export byte code of class of persisted object
void	xmlImport(String directoryName, boolean validating) import from exported data in directoryName directory

Methods inherited from class net.sf.joafip.store.service.AbstractStoreDelegatingToDataManager

clearDataManager, dataManagerBackup, dataManagerFreeSize, dataManagerGetNumberOfDataRecord, dataManagerGetNumberOfFreeRecord, dataManagerHeapSize, dataManagerUsedSize, flushDataManager, getDataManager, getNewDataRecordIdentifier, getStorageFileName, startDataManagerService, stopDataManagerService

Methods inherited from class java.lang.Object

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

Methods inherited from interface net.sf.joafip.store.service.IStore

addProhibitedPackage, addToNotCheckMethod, addToNotCheckMethod, addToNotCheckMethod, addToNotCheckMethod, clear, close, createObjectReadingInStoreOrGetExisting, disableBackgroundGarbageSweep, doNotSave, enableBackgroundGarbageSweep, endAccessSession, freeSize, garbageSweep, getAllReferenceLink, getCandidate, getDataRecordIdentifierAssociatedToObject, getNumberOfDataRecord, getNumberOfFreeRecord, getNumberOfGarbageCandidate, getNumberOfModified, getNumberOfObjectState, getNumberOfReferenced, getNumberOfToGarbage, getNumberOfVisitedForSave, getNumberOfWeakReference, getObjectHavingStateSet, getRoot, getStoredEnumMap, getStoreRoot, getToGarbage, isBackgroundGarbageSweepWorking, isChangeLogEnabled, newAccessSession, open, readRoot, removeWriteSubstitution, removeWriteSubstitution, save, setAutoSaveEventListener, setChangeLogEnabled, setDeprecatedInStore, setDeprecatedInStore, setEnumState, setForceEnhance, setForceEnhance, setGarbageListener, setInstanceFactory, setNoLazyLoad, setNoLazyLoad, setNoLazyLoad, setNoLazyLoad, setNotPersistedField, setNotPersistedField, setNotStorable, setNotStorable, setObjectIOForClass, setObjectIOForClass, setRoot, setStorable, setStorable, setStoredEnumMap, setStoreNotUseStandardSerialization, setStoreNotUseStandardSerialization, setStoreSerializeAndGZippedInOneRecord, setStoreSerializeAndGZippedInOneRecord, setStoreSerializeAndZippedInOneRecord, setStoreSerializeAndZippedInOneRecord, setStoreSerializeInOneRecord, setStoreSerializeInOneRecord, setSubstituteObjectManager, setSubstituteObjectManager, setSubstitutionOfJavaUtilCollection, setWriteSubstitution, setWriteSubstitution, totalSize, usedForGarbageManagement, usedSize

Methods inherited from interface net.sf.joafip.store.service.IStoreForGarbage

setBackgroundException

Field Detail

helperReflect

protected final HelperReflect helperReflect

proxyMode

protected final boolean proxyMode

garbageManagement

protected final boolean garbageManagement

true if garbage management activated

classNameManager

protected IClassNameManager classNameManager

objectIOManager

protected ObjectIOManager objectIOManager

object reading and writing on data file manager

storeSaver

protected StoreSaver3 storeSaver

manage saving of object

storeGarbager

protected StoreGarbager storeGarbager

manage garbage of data record

garbageManager

protected GarbageManager garbageManager

manager of to garbage record identifier storing and link storing

storeHeader

protected StoreHeader storeHeader

store header, data record #0

storeSynchro

protected final StoreSynchro storeSynchro

group of synchronization object for file access, share between Store and ProxyCallBack

mutex

protected final Object mutex

file access synchronization mutex

classInfoFactory

protected ClassInfoFactory classInfoFactory

helperBinaryConversion

protected HelperBinaryConversion helperBinaryConversion

currentDataModelIdentifier

protected int currentDataModelIdentifier

data model identifier

proxyManager2

protected ProxyManager2 proxyManager2

autoSaveEnabled

protected boolean autoSaveEnabled

saver

protected IFilePersistenceAutoSaver saver

Constructor Detail

AbstractDelegatingToStoreManagers

protected AbstractDelegatingToStoreManagers(StoreProperties storeProperties)
                                     throws StoreException

Throws:

StoreException

Method Detail

isProxyMode

public boolean isProxyMode()

getMutex

public JoafipMutex getMutex()

getClassLoaderProvider

public ClassLoaderProvider getClassLoaderProvider()

setClassLoaderProvider

public void setClassLoaderProvider(ClassLoaderProvider classLoaderProvider)

getProxyManager2

public ProxyManager2 getProxyManager2()

getStoreSynchro

public StoreSynchro getStoreSynchro()

getHelperBinaryConversion

public HelperBinaryConversion getHelperBinaryConversion()

stop

public void stop()
          throws StoreException

Throws:

StoreException

getClassInfoFactory

public ClassInfoFactory getClassInfoFactory()

isGarbageManagement

public boolean isGarbageManagement()
                            throws StoreException

Throws:

StoreException

getHeapRecordableManager

public HeapRecordableManager getHeapRecordableManager()
                                               throws StoreException

Throws:

StoreException

readAndSetHeapRecordableState

protected boolean readAndSetHeapRecordableState(IHeapRecordable heapRecordable)
                                         throws HeapRecordableException

Throws:

HeapRecordableException

attachHeapRecordable

protected DataRecordIdentifier attachHeapRecordable(IHeapRecordable heapRecordable)
                                             throws HeapRecordableException

Throws:

HeapRecordableException

heapRecordableManagerSave

protected void heapRecordableManagerSave()
                                  throws HeapRecordableException

Throws:

HeapRecordableException

heapRecordableManagerDoNotSave

protected void heapRecordableManagerDoNotSave(boolean clear)

getObjectIOManager

public ObjectIOManager getObjectIOManager()
                                   throws StoreException

Throws:

StoreException

getStoreSaver

public StoreSaver3 getStoreSaver()

setZipCompressionLevel

public void setZipCompressionLevel(int zipCompressionLevel)
                            throws StoreException

Parameters:

zipCompressionLevel - the zip the compression level for object storing using zipped serialization

Throws:

StoreException

loadClassName

protected void loadClassName()
                      throws StoreException,
                             StoreClassNotFoundException

Throws:

StoreException

StoreClassNotFoundException

getClassNameManager

public IClassNameManager getClassNameManager()

Returns:

the class name manager

getClassIdentifier

public int getClassIdentifier(Class<?> clazz)
                       throws StoreException,
                              StoreClassNotFoundException

Throws:

StoreException

StoreClassNotFoundException

getGarbageManager

public GarbageManager getGarbageManager()

Returns:

the garbage manager

Throws:

StoreException

setStoreMode

public void setStoreMode(NavigableMap<String,EnumStoreMode> storeModeMap)

setDeprecatedInStore

public void setDeprecatedInStore(NavigableMap<String,Boolean> deprecatedinStoreMap)

setNotStorable

public void setNotStorable(NavigableMap<String,Boolean> notStorableMap)

deepCopy

public Object deepCopy(Object sourceObject,
              boolean forceLoad)
                throws CopierException

Throws:

CopierException

setPersistenceId

public void setPersistenceId(int persistenceId)

getPersistenceId

public int getPersistenceId()

getCurrentFileAccessSessionIdentifier

public long getCurrentFileAccessSessionIdentifier()

xmlExport

public void xmlExport(String directoryName,
             String temporaryDirectoryName,
             boolean exportPersistedClassByteCode)
               throws StoreException,
                      StoreClassNotFoundException,
                      StoreInvalidClassException,
                      StoreDataCorruptedException,
                      StoreNotSerializableException,
                      StoreTooBigForSerializationException

Description copied from interface: IStore

export persisted data in file export.xml put in directoryName directory
also export byte code of class of persisted object


Parameters:

directoryName - directory name where store export

temporaryDirectoryName - temporary directory name used to store temporary files while exporting

exportPersistedClassByteCode - true if export persisted class byte code

Throws:

StoreException

StoreClassNotFoundException

StoreInvalidClassException

StoreDataCorruptedException

StoreNotSerializableException

StoreTooBigForSerializationException

setExportListener

public void setExportListener(IExporterListener listener)

getNumberOfObjectExported

public int getNumberOfObjectExported()

xmlImport

public void xmlImport(String directoryName,
             boolean validating)
               throws StoreException,
                      StoreClassNotFoundException,
                      StoreInvalidClassException,
                      StoreDataCorruptedException,
                      StoreNotSerializableException

Description copied from interface: IStore

import from exported data in directoryName directory


Parameters:

directoryName - directory name where are stored exported data to import

Throws:

StoreException

StoreClassNotFoundException

StoreInvalidClassException

StoreDataCorruptedException

StoreNotSerializableException

setImportListener

public void setImportListener(IImportListener listener)

getCurrentDataModelIdentifier

public int getCurrentDataModelIdentifier()

getConversionManager

public ConversionManager getConversionManager()

newProxyInstance

public Object newProxyInstance(Object sourceObject)
                        throws StoreException

Throws:

StoreException

newProxyInstance

public Object newProxyInstance(Class<?> objectClass,
                      Class<?>[] parameterTypes,
                      Object[] initargs)
                        throws StoreException

Throws:

StoreException

newProxyInstance

public Object newProxyInstance(Class<?> objectClass)
                        throws StoreException

Throws:

StoreException

setStoreOnlyMarkedStorable

public void setStoreOnlyMarkedStorable(boolean storeOnlyMarkedStorable)

allClassInformation

public Collection<ClassInfo> allClassInformation()

keptInMemory

public void keptInMemory(String key,
                Object object)
                  throws StoreException

Throws:

StoreException

isKeptInMemory

public boolean isKeptInMemory(Object object)

referencedByPesistedStaticField

public void referencedByPesistedStaticField(Class<?> classHavingStaticFieldReferenced)
                                     throws StoreException

Throws:

StoreException

storedImmutableEnum

public void storedImmutableEnum(Class<? extends Enum<?>> enumClass)
                         throws StoreException

Description copied from interface: IStore

declare immutable enum class to persist

Throws:

StoreException

keyOfObjectKeptInMemory

public String keyOfObjectKeptInMemory(Object object)

getWroteObjectSet

public Map<String,MutableInteger> getWroteObjectSet()

getVisitedObjectSet

public Set<String> getVisitedObjectSet()

getWroteArrays

public List<String> getWroteArrays()

setRecordSaveActions

public void setRecordSaveActions(boolean recordActions)

setRecordSaveActions

public void setRecordSaveActions(boolean recordActions,
                        ISaveRecordActionListener saveRecordActionListener)

setSaveRecordActionListener

public void setSaveRecordActionListener(ISaveRecordActionListener saveRecordActionListener)

setSaveInDataAccessSessionEnabled

public void setSaveInDataAccessSessionEnabled(boolean enabled)

setMaintainedInMemoryEnabled

public void setMaintainedInMemoryEnabled(boolean enabled)

setAutoSaveEnabled

public void setAutoSaveEnabled(boolean enabled)

isAutoSaveEnabled

public boolean isAutoSaveEnabled()

autoSaveSetup

public void autoSaveSetup(int maxInMemoryThreshold)

setSaver

public void setSaver(IFilePersistenceAutoSaver saver)

maintainInMemorySetup

public void maintainInMemorySetup(int maintainedInMemoryQuota)

newInstance

public Object newInstance(Class<?> objectClass,
                 Class<?>[] parameterTypes,
                 Object[] initargs)

Parameters:

objectClass - the class of the object to create

parameterTypes - parameters type, see Class.getConstructor(Class...)

initargs - the construction parameters, see Constructor.newInstance(Object...)

Returns:

the created instance according to proxy mode

newInstance

protected Object newInstance(ClassInfo objectClassInfo,
                 Class<?>[] parameterTypes,
                 Object[] initargs)
                      throws ProxyException,
                             ReflectException,
                             ClassInfoException,
                             ObjectIOException

Throws:

ProxyException

ReflectException

ClassInfoException

ObjectIOException

newInstance

public Object newInstance(Class<?> objectClass)

newInstanceNoConstruction

public Object newInstanceNoConstruction(ClassInfo objectClassInfo)

knownAsNotExisting

public ClassInfo knownAsNotExisting(String className)
                             throws StoreClassNotFoundException,
                                    StoreException

Throws:

StoreClassNotFoundException

StoreException

getClassInfoInDataRecord

public ClassInfo getClassInfoInDataRecord(DataRecordIdentifier dataRecordIdentifier)
                                   throws StoreException

Throws:

StoreException

classOfObject

public Class<?> classOfObject(Object object)
                       throws StoreException

Returns:

class of object, proxied class in case of proxy object

Throws:

StoreException

classInfoOfObject

public ClassInfo classInfoOfObject(Object object)
                            throws StoreException

Throws:

StoreException

getGarbageCandidateRecordManager

@Fortest
public GarbageCandidateRecordManager getGarbageCandidateRecordManager()

for test purpose

Returns:

manager of garbage candidate record in file

getToVisitRecordManager

@Fortest
public ToVisitRecordManager getToVisitRecordManager()

getVisitedRecordManager

@Fortest
public VisitedRecordManager getVisitedRecordManager()

getToGarbageRecordManager

@Fortest
public ToGarbageRecordManager getToGarbageRecordManager()

for test purpose

Returns:

manager of to garbage record in file

getLinkRecordManager

@Fortest
public LinkRecordManager getLinkRecordManager()

Description copied from interface: IStore

for test purpose

Returns:

the link record manager

usedForClassNameManagement

public void usedForClassNameManagement(Set<DataRecordIdentifier> setToUpdate)
                                throws StoreException

Throws:

StoreException

getObjectAndPersistInfoOfObjectFromQueue

@Fortest
public ObjectAndPersistInfo getObjectAndPersistInfoOfObjectFromQueue(Object object)

getObjectAndPersistInfoOfObjectFromQueue

@Fortest
public List<ObjectAndPersistInfo> getObjectAndPersistInfoOfObjectFromQueue()

listenStateMapClean

@Fortest
public void listenStateMapClean(IObjectStateMapCLeanListener listener)