net.sf.joafip.store.service.objectio.manager

Class ObjectIOManager

java.lang.Object

net.sf.joafip.store.service.objectio.manager.AbstractObjectIOManagerKeptInMemory

net.sf.joafip.store.service.objectio.manager.AbstractObjectIOManagerIOForObject

net.sf.joafip.store.service.objectio.manager.AbstractObjectIOManagerDelegatingToStateMap

net.sf.joafip.store.service.objectio.manager.ObjectIOManager

All Implemented Interfaces:

IDeepCopyServiceDelegate, IObjectIoManagerForGarbage, IObjectIOManagerForObjectIO, IObjectIOManagerForProxyObjectIO, IObjectIOManagerForSave

@NotStorableClass
public class ObjectIOManager
extends AbstractObjectIOManagerDelegatingToStateMap

Generics and Basics types are special case for object persistence
Basics types are primitive types ( an reference to object ) and the corresponding class:

• byte
• short
• int
• long
• float
• double
• boolean
• char
• Byte
• Short
• Integer
• Long
• Float
• Double
• Boolean
• Char

Generics type are type that can be persist by reflection net.sf.joafip.store.service.objectio.serialize.ObjectIOLazyGeneric
The not generic types are declared here and have a specific persistence strategy
For object reading and writing on data file
Maintains original object's field value for each read and write

Author:

luc peuvrier

Field Summary

Fields inherited from class net.sf.joafip.store.service.objectio.manager.AbstractObjectIOManagerIOForObject

classNameManager, currentDataModelIdentifier, HEADER_DATA_SIZE, helperBinaryConversion, helperReflect, logger, OBJECT_MUST_HAVE_DATA_RECORD_IDENTIFIER_SET, objectInputEnum, objectOutputs

Fields inherited from class net.sf.joafip.store.service.objectio.manager.AbstractObjectIOManagerKeptInMemory

classInfoFactory

Constructor Summary

Constructors

Constructor and Description
ObjectIOManager(int currentDataModelIdentifier, IHeapDataManager dataManager, boolean proxyMode, IClassNameManager classNameManager, StoreSynchro storeSynchro, ClassInfoFactory classInfoFactory, HelperBinaryConversion helperBinaryConversion, ProxyManager2 proxyManager2)

Method Summary

Methods

Modifier and Type	Method and Description
protected DataRecordIdentifier	associateNewDataRecordIdentifierToObject(ObjectAndPersistInfo objectAndPersistInfo)
protected void	autoSave()
protected void	checkForAutoSave()
void	closeChangeLog() close change log file
ObjectAndPersistInfo	createReadingInStoreGenericObjectNotLazy(DataRecordIdentifier dataRecordIdentifier) near as #createObjectReadingInStoreOrGetExisting(Long, Class) but force direct loading.
long	getCurrentFileAccessSessionIdentifier()
byte[]	getDataOfDataRecord(DataRecordIdentifier dataRecordIdentifier) get data of data record for an identifier
IGarbageManagerForLinkUpdate	getGarbageManager()
JoafipMutex	getStoreMutex() get the mutex for storage file access
boolean	isAutoSaveEnabled()
boolean	isGarbageManagement()
boolean	isMaintainInMemoryEnabled()
boolean	isRunAutosaveEnableAndDisable()
boolean	isValueChanged(ObjectAndPersistInfo objectAndPersistInfo)
Map<DataRecordIdentifier,byte[]>	loadChangeLog(String fileName) load change log in memory from a change log file
protected void	notToGarbage(DataRecordIdentifier dataRecordIdentifier, ObjectAndPersistInfo objectAndPersistInfo)
void	objectIsAccessed(ObjectAndPersistInfo objectAndPersistInfo) call when object is accessed
void	openChangeLog(String changeFileName) open change log must be called before storeInChangeLog(ObjectAndPersistInfo)
void	setAutoSaveEnabled(boolean enabled, int maxInMemoryThreshold)
void	setAutoSaveEventListener(IAutoSaveEventListener saveEventListener)
void	setExclusiveAccessSession(boolean exclusiveAccessSession)
void	setGarbageManagement(boolean garbageManagement, IGarbageManagerForLinkUpdate garbageManager)
void	setMaintainedInMemoryQuota(int maintainedInMemoryQuota)
void	setMaintenedInMemoryEnabled(boolean maintainInMemoryEnabled, int maintainedInMemoryQuota)
void	setMaxInMemoryThreshold(int maxInMemoryThreshold)
void	setRunAutosaveEnable(boolean runAutosaveEnable)
void	setSaver(IFilePersistenceAutoSaver saver)
void	storeInChangeLog(ObjectAndPersistInfo objectAndPersistInfo) write object in serialized form to change log
void	unsetProxyObjectState(ObjectAndPersistInfo objectAndPersistInfo)
ObjectClassInfoAndDeclared[]	willNotBeWrote(ObjectAndPersistInfo objectAndPersistInfo) notify that object will not be wrote
protected void	writeDataRecord(DataRecordIdentifier dataRecordIdentifier, byte[] data)

Methods inherited from class net.sf.joafip.store.service.objectio.manager.AbstractObjectIOManagerDelegatingToStateMap

clearObjectAndPersistInfoByDataRecordIdentifier, clearObjectState, closeObjectState, createObjectAndPersistInfoOfObjectImpl, createSubstitutedObjectAndPersistInfoOfObjectImpl, dataRecordIdentifierAssociatedToObjectSetted, getDataRecordIdentifierAssociatedToObject, getNumberOfObjectState, getNumberOfReferenced, getNumberOfWeakReference, getObjectAndPersistInfoOfObject, getObjectAndPersistInfoOfObjectFromQueue, getObjectAndPersistInfoOfObjectFromQueue, getObjectByIdentifier, getObjectHavingStateSet, getObjectStateMap, isExclusiveAccessSession, listenStateMapClean, mostAccessedObject, objectHasPersistenceState, objectIsAccessedDelegate, setExclusiveAccessSessionDelegate, setMaintainedInMemoryQuotaDelegate, setTrackingOfAccessedObjectEnabledDelegate, weakReferenceOnObject

Methods inherited from class net.sf.joafip.store.service.objectio.manager.AbstractObjectIOManagerIOForObject

assertNotSubstituted, createObjectPersistInfoOfObject, createObjectPersistInfoOfObject, createObjectReadingInStore, createObjectReadingInStoreOrGetExisting, createSubstituteObjectPersistInfoOfObject, deepCopy, getBodyDataFromRecord, getClassInfoFactory, getClassInfoInDataRecord, getCurrentDataModelIdentifier, getObjectInput, getObjectIOInputStream, getObjectIOOutputStream, getObjectLinkTreeNode, getObjectOutput, getOrCreateDataRecordIdentifierAssociatedToObject, getOrCreateObjectPersistInfoOfObject, getOrCreateObjectPersistInfoOfObject, getOrCreateObjectPersistInfoOfObject, getProxyManager2, getZipCompressionLevel, isProxyMode, newInstance, newInstance, newInstanceNoConstruction, newObjectLoaded, originalObjectAndPersistInfo, prepareWrite, reCreateObjectReadingInStore, reInitializeEnum, setInstanceFactory, setProxyMode, setProxyObjectState, setSpecificObjectIO, setZipCompressionLevel, substituteForWrite, substituteObject, write

Methods inherited from class net.sf.joafip.store.service.objectio.manager.AbstractObjectIOManagerKeptInMemory

addObject, getKeptInMemorySubstituteObjectManager, isKeptInMemory, keptInMemoryoriginalObject, keptInMemorysubstituteObject, keyOfObject

Methods inherited from class java.lang.Object

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

Constructor Detail

ObjectIOManager

public ObjectIOManager(int currentDataModelIdentifier,
               IHeapDataManager dataManager,
               boolean proxyMode,
               IClassNameManager classNameManager,
               StoreSynchro storeSynchro,
               ClassInfoFactory classInfoFactory,
               HelperBinaryConversion helperBinaryConversion,
               ProxyManager2 proxyManager2)
                throws ObjectIOException

Throws:

ObjectIOException

Method Detail

isGarbageManagement

@Fortest
public boolean isGarbageManagement()

getGarbageManager

@Fortest
public IGarbageManagerForLinkUpdate getGarbageManager()

setGarbageManagement

public void setGarbageManagement(boolean garbageManagement,
                        IGarbageManagerForLinkUpdate garbageManager)
                          throws ObjectIOException

Throws:

ObjectIOException

notToGarbage

protected void notToGarbage(DataRecordIdentifier dataRecordIdentifier,
                ObjectAndPersistInfo objectAndPersistInfo)
                     throws ObjectIOException

Specified by:

notToGarbage in class AbstractObjectIOManagerIOForObject

Throws:

ObjectIOException

willNotBeWrote

public ObjectClassInfoAndDeclared[] willNotBeWrote(ObjectAndPersistInfo objectAndPersistInfo)
                                            throws ObjectIOException

Description copied from interface: IObjectIOManagerForSave

notify that object will not be wrote

Returns:

son object not wrote but referenced by record

Throws:

ObjectIOException

createReadingInStoreGenericObjectNotLazy

public ObjectAndPersistInfo createReadingInStoreGenericObjectNotLazy(DataRecordIdentifier dataRecordIdentifier)
                                                              throws ObjectIOException,
                                                                     ObjectIODataRecordNotFoundException,
                                                                     ObjectIOClassNotFoundException,
                                                                     ObjectIOInvalidClassException,
                                                                     ObjectIODataCorruptedException,
                                                                     ObjectIONotSerializableException

near as #createObjectReadingInStoreOrGetExisting(Long, Class) but force direct loading.

Parameters:

dataRecordIdentifier - identifier of data record associated to object

Returns:

object created or existing

Throws:

ObjectIODataRecordNotFoundException - no data record for object found

ObjectIOException - object creation error

ObjectIODataCorruptedException

ObjectIOInvalidClassException

ObjectIOClassNotFoundException

ObjectIONotSerializableException

isValueChanged

public boolean isValueChanged(ObjectAndPersistInfo objectAndPersistInfo)
                       throws ObjectIOException,
                              ObjectIOInvalidClassException,
                              ObjectIONotSerializableException,
                              ObjectIODataCorruptedException,
                              ObjectIODataRecordNotFoundException,
                              ObjectIOClassNotFoundException

Returns:

true if mutable and value change

Throws:

ObjectIOException

ObjectIOInvalidClassException

ObjectIONotSerializableException

ObjectIODataCorruptedException

ObjectIODataRecordNotFoundException

ObjectIOClassNotFoundException

writeDataRecord

protected void writeDataRecord(DataRecordIdentifier dataRecordIdentifier,
                   byte[] data)
                        throws ObjectIOException

Specified by:

writeDataRecord in class AbstractObjectIOManagerIOForObject

Throws:

ObjectIOException

getDataOfDataRecord

public byte[] getDataOfDataRecord(DataRecordIdentifier dataRecordIdentifier)
                           throws ObjectIOException,
                                  ObjectIODataCorruptedException,
                                  ObjectIODataRecordNotFoundException

Description copied from class: AbstractObjectIOManagerIOForObject

get data of data record for an identifier

Specified by:

getDataOfDataRecord in class AbstractObjectIOManagerIOForObject

Parameters:

dataRecordIdentifier - data record identifier

Returns:

the data for data record identifier

Throws:

ObjectIOException - reading error

ObjectIODataCorruptedException

ObjectIODataRecordNotFoundException

unsetProxyObjectState

public void unsetProxyObjectState(ObjectAndPersistInfo objectAndPersistInfo)
                           throws ObjectIOException,
                                  ObjectIOInvalidClassException

Throws:

ObjectIOException

ObjectIOInvalidClassException

associateNewDataRecordIdentifierToObject

protected DataRecordIdentifier associateNewDataRecordIdentifierToObject(ObjectAndPersistInfo objectAndPersistInfo)
                                                                 throws ObjectIODataCorruptedException,
                                                                        ObjectIOException

Specified by:

associateNewDataRecordIdentifierToObject in class AbstractObjectIOManagerIOForObject

Throws:

ObjectIODataCorruptedException

ObjectIOException

getStoreMutex

public JoafipMutex getStoreMutex()

Description copied from interface: IObjectIOManagerForProxyObjectIO

get the mutex for storage file access

Returns:

mutex for storage file access

getCurrentFileAccessSessionIdentifier

public long getCurrentFileAccessSessionIdentifier()

Returns:

current file access session identifier

openChangeLog

public void openChangeLog(String changeFileName)
                   throws ObjectIOException

open change log
must be called before storeInChangeLog(ObjectAndPersistInfo)

Parameters:

changeFileName - file name for file use to store change log

Throws:

ObjectIOException

closeChangeLog

public void closeChangeLog()
                    throws ObjectIOException

close change log file

Throws:

ObjectIOException

storeInChangeLog

public void storeInChangeLog(ObjectAndPersistInfo objectAndPersistInfo)
                      throws ObjectIOException,
                             ObjectIOInvalidClassException,
                             ObjectIONotSerializableException,
                             ObjectIOClassNotFoundException,
                             ObjectIODataRecordNotFoundException,
                             ObjectIODataCorruptedException,
                             ObjectIOTooBigForSerializationException

write object in serialized form to change log

Parameters:

object - the object to write

Throws:

ObjectIOException

ObjectIONotSerializableException

ObjectIOInvalidClassException

ObjectIOClassNotFoundException

ObjectIODataCorruptedException

ObjectIODataRecordNotFoundException

ObjectIOTooBigForSerializationException

loadChangeLog

public Map<DataRecordIdentifier,byte[]> loadChangeLog(String fileName)
                                               throws ObjectIOException

load change log in memory from a change log file

Parameters:

fileName - the change log file name

Returns:

data by data record identifier map

Throws:

ObjectIOException

setExclusiveAccessSession

public void setExclusiveAccessSession(boolean exclusiveAccessSession)

setMaintenedInMemoryEnabled

public void setMaintenedInMemoryEnabled(boolean maintainInMemoryEnabled,
                               int maintainedInMemoryQuota)

setMaintainedInMemoryQuota

public void setMaintainedInMemoryQuota(int maintainedInMemoryQuota)

isMaintainInMemoryEnabled

public boolean isMaintainInMemoryEnabled()

Returns:

true if maintain object in memory

objectIsAccessed

public void objectIsAccessed(ObjectAndPersistInfo objectAndPersistInfo)

Description copied from interface: IObjectIOManagerForProxyObjectIO

call when object is accessed

setAutoSaveEnabled

public void setAutoSaveEnabled(boolean enabled,
                      int maxInMemoryThreshold)

setMaxInMemoryThreshold

public void setMaxInMemoryThreshold(int maxInMemoryThreshold)

setAutoSaveEventListener

public void setAutoSaveEventListener(IAutoSaveEventListener saveEventListener)

isAutoSaveEnabled

public boolean isAutoSaveEnabled()

isRunAutosaveEnableAndDisable

public boolean isRunAutosaveEnableAndDisable()

setRunAutosaveEnable

public void setRunAutosaveEnable(boolean runAutosaveEnable)

checkForAutoSave

protected void checkForAutoSave()
                         throws ObjectIOException

Specified by:

checkForAutoSave in class AbstractObjectIOManagerIOForObject

Throws:

ObjectIOException

autoSave

protected void autoSave()
                 throws ObjectIOException

Throws:

ObjectIOException

setSaver

public void setSaver(IFilePersistenceAutoSaver saver)