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

Class SerializerObjectIOManager

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.SerializerObjectIOManager

All Implemented Interfaces:

IDeepCopyServiceDelegate, IObjectIoManagerForGarbage, IObjectIOManagerForObjectIO, IObjectIOManagerForProxyObjectIO, IObjectIOManagerForSave

@NotStorableClass
public class SerializerObjectIOManager
extends AbstractObjectIOManagerIOForObject

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
SerializerObjectIOManager(int currentDataModelIdentifier, IClassNameManager classNameManager, ClassInfoFactory classInfoFactory, HelperBinaryConversion helperBinaryConversion, IProxyManagerForObjectIO proxyManager)

Method Summary

Methods

Modifier and Type	Method and Description
protected DataRecordIdentifier	associateNewDataRecordIdentifierToObject(ObjectAndPersistInfo objectAndPersistInfo)
protected void	checkForAutoSave()
protected void	clearObjectAndPersistInfoByDataRecordIdentifier(DataRecordIdentifier identifier)
protected ObjectAndPersistInfo	createObjectAndPersistInfoOfObjectImpl(Object object, boolean proxyInstance, ClassInfo objectClassInfo)
ObjectAndPersistInfo	createObjectReadingInStoreOrGetExisting(DataRecordIdentifier dataRecordIdentifier, boolean notLazy) override to force not lazy mode
protected ObjectAndPersistInfo	createSubstitutedObjectAndPersistInfoOfObjectImpl(Object object, ClassInfo objectClassInfo, ObjectAndPersistInfo substituteObjectAndPersistInfo)
void	dataRecordIdentifierAssociatedToObjectSetted(ObjectAndPersistInfo objectAndItsClassInfo) action after set the data record identifier of an object
long	getCurrentFileAccessSessionIdentifier()
protected byte[]	getDataOfDataRecord(DataRecordIdentifier dataRecordIdentifier) get data of data record for an identifier
ObjectAndPersistInfo	getObjectAndPersistInfoOfObject(Object object)
ObjectAndPersistInfo	getObjectByIdentifier(DataRecordIdentifier identifier) to obtains object and persist information for data record by data record identifier public for tests
JoafipMutex	getStoreMutex() get the mutex for storage file access
boolean	isAutoSaveEnabled()
boolean	isExclusiveAccessSession() not exclusive data access session for joafip serialization in one data record
boolean	isMaintainInMemoryEnabled() not maintain in memory for joafip serialization in one data record
boolean	isRunAutosaveEnableAndDisable()
boolean	isValueChanged(ObjectAndPersistInfo objectAndItsClassInfo) always write
byte[]	marshal(Object object)
Set<ObjectAndPersistInfo>	mostAccessedObject()
protected void	notToGarbage(DataRecordIdentifier dataRecordIdentifier, ObjectAndPersistInfo objectAndPersistInfo) no garbage management for serialization in one data record
boolean	objectHasPersistenceState(ObjectAndPersistInfo objectAndPersistInfo)
void	objectIsAccessed(ObjectAndPersistInfo proxyObjectAndPersistInfo) call when object is accessed
void	setRunAutosaveEnable(boolean runAutosaveEnable)
void	setStoreOnlyMarkedStorable(boolean storeOnlyMarkedStorable)
Object	unmarshal(byte[] data)
void	unsetProxyObjectState(ObjectAndPersistInfo objectAndItsClassInfo)
ObjectClassInfoAndDeclared[]	willNotBeWrote(ObjectAndPersistInfo objectAndItsClassInfo) always write
protected void	writeDataRecord(DataRecordIdentifier dataRecordIdentifier, byte[] data)

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

assertNotSubstituted, createObjectPersistInfoOfObject, createObjectPersistInfoOfObject, createObjectReadingInStore, 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

SerializerObjectIOManager

public SerializerObjectIOManager(int currentDataModelIdentifier,
                         IClassNameManager classNameManager,
                         ClassInfoFactory classInfoFactory,
                         HelperBinaryConversion helperBinaryConversion,
                         IProxyManagerForObjectIO proxyManager)
                          throws ObjectIOException

Throws:

ObjectIOException

Method Detail

setStoreOnlyMarkedStorable

public void setStoreOnlyMarkedStorable(boolean storeOnlyMarkedStorable)

marshal

public byte[] marshal(Object object)
               throws ObjectIOException,
                      ObjectIODataCorruptedException,
                      ObjectIOInvalidClassException,
                      ObjectIONotSerializableException,
                      ObjectIODataRecordNotFoundException,
                      ObjectIOClassNotFoundException,
                      ObjectIOTooBigForSerializationException

Throws:

ObjectIOException

ObjectIODataCorruptedException

ObjectIOInvalidClassException

ObjectIONotSerializableException

ObjectIODataRecordNotFoundException

ObjectIOClassNotFoundException

ObjectIOTooBigForSerializationException

unmarshal

public Object unmarshal(byte[] data)
                 throws ObjectIOException,
                        ObjectIODataRecordNotFoundException,
                        ObjectIOClassNotFoundException,
                        ObjectIOInvalidClassException,
                        ObjectIODataCorruptedException,
                        ObjectIONotSerializableException

Throws:

ObjectIOException

ObjectIODataRecordNotFoundException

ObjectIOClassNotFoundException

ObjectIOInvalidClassException

ObjectIODataCorruptedException

ObjectIONotSerializableException

createObjectReadingInStoreOrGetExisting

public ObjectAndPersistInfo createObjectReadingInStoreOrGetExisting(DataRecordIdentifier dataRecordIdentifier,
                                                           boolean notLazy)
                                                             throws ObjectIOException,
                                                                    ObjectIODataRecordNotFoundException,
                                                                    ObjectIOClassNotFoundException,
                                                                    ObjectIOInvalidClassException,
                                                                    ObjectIODataCorruptedException,
                                                                    ObjectIONotSerializableException

override to force not lazy mode

Specified by:

createObjectReadingInStoreOrGetExisting in interface IObjectIOManagerForObjectIO

Overrides:

createObjectReadingInStoreOrGetExisting in class AbstractObjectIOManagerIOForObject

Parameters:

dataRecordIdentifier - identifier of data record associated to object

notLazy - true if force not lazy mode

Returns:

object created or existing. Can return null object and persistence information

Throws:

ObjectIOException - create object error

ObjectIODataRecordNotFoundException - data record for object not found

ObjectIOClassNotFoundException

ObjectIOInvalidClassException

ObjectIODataCorruptedException

ObjectIONotSerializableException

getObjectByIdentifier

public ObjectAndPersistInfo getObjectByIdentifier(DataRecordIdentifier identifier)

Description copied from class: AbstractObjectIOManagerIOForObject

to obtains object and persist information for data record by data record identifier
public for tests

Specified by:

getObjectByIdentifier in interface IObjectIoManagerForGarbage

Specified by:

getObjectByIdentifier in class AbstractObjectIOManagerIOForObject

Parameters:

identifier - data record identifier

Returns:

object for data record identifier, null if not defined or not exist any more

clearObjectAndPersistInfoByDataRecordIdentifier

protected void clearObjectAndPersistInfoByDataRecordIdentifier(DataRecordIdentifier identifier)

Specified by:

clearObjectAndPersistInfoByDataRecordIdentifier in class AbstractObjectIOManagerIOForObject

createObjectAndPersistInfoOfObjectImpl

protected ObjectAndPersistInfo createObjectAndPersistInfoOfObjectImpl(Object object,
                                                          boolean proxyInstance,
                                                          ClassInfo objectClassInfo)
                                                               throws ObjectIOException

Specified by:

createObjectAndPersistInfoOfObjectImpl in class AbstractObjectIOManagerIOForObject

Throws:

ObjectIOException

createSubstitutedObjectAndPersistInfoOfObjectImpl

protected ObjectAndPersistInfo createSubstitutedObjectAndPersistInfoOfObjectImpl(Object object,
                                                                     ClassInfo objectClassInfo,
                                                                     ObjectAndPersistInfo substituteObjectAndPersistInfo)
                                                                          throws ObjectIOException

Specified by:

createSubstitutedObjectAndPersistInfoOfObjectImpl in class AbstractObjectIOManagerIOForObject

Throws:

ObjectIOException

getObjectAndPersistInfoOfObject

public ObjectAndPersistInfo getObjectAndPersistInfoOfObject(Object object)
                                                     throws ObjectIOException

Returns:

object and persist info of object, null if none

Throws:

ObjectIOException

associateNewDataRecordIdentifierToObject

protected DataRecordIdentifier associateNewDataRecordIdentifierToObject(ObjectAndPersistInfo objectAndPersistInfo)
                                                                 throws ObjectIODataCorruptedException,
                                                                        ObjectIOException

Specified by:

associateNewDataRecordIdentifierToObject in class AbstractObjectIOManagerIOForObject

Throws:

ObjectIODataCorruptedException

ObjectIOException

dataRecordIdentifierAssociatedToObjectSetted

public void dataRecordIdentifierAssociatedToObjectSetted(ObjectAndPersistInfo objectAndItsClassInfo)
                                                  throws ObjectIOException

Description copied from class: AbstractObjectIOManagerIOForObject

action after set the data record identifier of an object

Specified by:

dataRecordIdentifierAssociatedToObjectSetted in interface IObjectIOManagerForProxyObjectIO

Specified by:

dataRecordIdentifierAssociatedToObjectSetted in class AbstractObjectIOManagerIOForObject

Throws:

ObjectIOException

objectHasPersistenceState

public boolean objectHasPersistenceState(ObjectAndPersistInfo objectAndPersistInfo)

getDataOfDataRecord

protected 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

writeDataRecord

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

Specified by:

writeDataRecord in class AbstractObjectIOManagerIOForObject

Throws:

ObjectIOException

notToGarbage

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

no garbage management for serialization in one data record

Specified by:

notToGarbage in class AbstractObjectIOManagerIOForObject

Throws:

ObjectIOException

mostAccessedObject

public Set<ObjectAndPersistInfo> mostAccessedObject()

isValueChanged

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

always write

Returns:

true if mutable and value change

Throws:

ObjectIOException

ObjectIOInvalidClassException

ObjectIONotSerializableException

ObjectIODataCorruptedException

ObjectIODataRecordNotFoundException

ObjectIOClassNotFoundException

willNotBeWrote

public ObjectClassInfoAndDeclared[] willNotBeWrote(ObjectAndPersistInfo objectAndItsClassInfo)
                                            throws ObjectIOException

always write

Returns:

son object not wrote but referenced by record

Throws:

ObjectIOException

getCurrentFileAccessSessionIdentifier

public long getCurrentFileAccessSessionIdentifier()

Returns:

current file access session identifier

getStoreMutex

public JoafipMutex getStoreMutex()

Description copied from interface: IObjectIOManagerForProxyObjectIO

get the mutex for storage file access

Returns:

mutex for storage file access

objectIsAccessed

public void objectIsAccessed(ObjectAndPersistInfo proxyObjectAndPersistInfo)

Description copied from interface: IObjectIOManagerForProxyObjectIO

call when object is accessed

unsetProxyObjectState

public void unsetProxyObjectState(ObjectAndPersistInfo objectAndItsClassInfo)
                           throws ObjectIOException,
                                  ObjectIOInvalidClassException

Throws:

ObjectIOException

ObjectIOInvalidClassException

isMaintainInMemoryEnabled

public boolean isMaintainInMemoryEnabled()

not maintain in memory for joafip serialization in one data record

Returns:

true if maintain object in memory

isExclusiveAccessSession

public boolean isExclusiveAccessSession()

not exclusive data access session for joafip serialization in one data record

isRunAutosaveEnableAndDisable

public boolean isRunAutosaveEnableAndDisable()

setRunAutosaveEnable

public void setRunAutosaveEnable(boolean runAutosaveEnable)

checkForAutoSave

protected void checkForAutoSave()
                         throws ObjectIOException

Specified by:

checkForAutoSave in class AbstractObjectIOManagerIOForObject

Throws:

ObjectIOException

isAutoSaveEnabled

public boolean isAutoSaveEnabled()