public abstract class LocalObjectContainer extends ExternalObjectContainer implements InternalObjectContainer, EmbeddedObjectContainer
| Modifier and Type | Field and Description |
|---|---|
protected FileHeader |
_fileHeader |
protected ByteArrayBuffer |
_pointerIo |
_blockConverter, _classCollection, _config, _handlers, _lock, _timeStampIdGenerator, _transactionactivate, activate, backup, bind, commit, deactivate, deactivate, delete, descend, ext, getByID, getByUUID, getID, getObjectInfo, isActive, isCached, isStored, peekPersisted, purge, query, query, query, query, queryByExample, refresh, rollback, store, store, storedClass, storedClassesactivate, activate, activationContextFor, activationDepthProvider, applyRenames, asTopLevelCall, backup, bind, bind2, blockConverter, blockSize, blockSize, callbacks, callbacks, checkClosed, checkReadOnly, checkStillToSet, checkTransaction, checkTransaction, classCollection, classMetadataForID, classMetadataForName, classMetadataForObject, classMetadataForReflectClass, classMetadataIdForName, close, closeSystemTransaction, closeTransaction, closeUserTransaction, commit, commitTimestampIndex, config, configImpl, configure, container, createBlockConverter, createClassMetadata, createReferenceSystem, createStatefulBuffer, createStringIO, db4oTypeStored, deactivate, deactivate, decryptedBufferByAddress, defaultActivationDepth, delete, delete1, delete2, deleteByID, detectSchemaChanges, dispatchsEvents, environment, fatalShutdown, fatalStorageShutdown, finalize, flagAsHandled, generateTimeStampId, generateTransactionTimestamp, getActivatedObjectFromCache, getByID, getByID2, getByUUID, getHardObjectReferenceById, getHardReferenceBySignature, getID, getNativeQueryHandler, getObjectInfo, handledInCurrentTopLevelCall, handleExceptionOnClose, handlers, hasShutDownHook, initalizeWeakReferenceSupport, initialize1, initializeClassMetadataRepository, initializePostOpenExcludingTransportObjectContainer, initializeTransactions, isCached, isClient, isClosed, isStored, knownClasses, lock, logMsg, maintainsIndices, needsLockFileThread, needsUpdate, newSystemTransaction, newUserTransaction, newWeakReference, open, openImpl, peekPersisted, peekPersisted, peekReference, produceClassMetadata, purge, purge, query, query, query, query, query, queryByExample, rawBufferByAddress, readActivatedObjectNotInCache, readBytes, readBytes, readWriterByAddress, referenceSystemRegistry, reflector, refresh, refreshInternal, replaceClassMetadataRepository, replicationCallState, reserve, rollback, send, showInternalClasses, shutdownDataStorage, shutdownObjectContainer, stackDepth, stackDepth, stillToActivate, stillToDeactivate, stopSession, store, store, store2, storeAfterReplication, storeAll, storeAll, storeByNewReplication, storedClass, storedClasses, storeInternal, storeInternal, stringIO, syncExec, systemTransaction, threadPool, topLevelCallId, topLevelCallId, toString, transaction, tryGetByID, typeHandlerForClass, typeHandlerForClassMetadataID, updateDepthProvider, useDefaultTransactionTimestamp, uUIDIndex, version, versionIndex, withEnvironment, withTransactionclone, equals, getClass, hashCode, notify, notifyAll, wait, wait, waitcallbacks, callbacks, classMetadataForID, classMetadataForName, classMetadataForReflectClass, configImpl, container, getNativeQueryHandler, handlers, isClient, storeAll, syncExec, transaction, updateDepthProvideractivate, backup, backup, bind, configure, deactivate, descend, getByID, getByUUID, getID, getObjectInfo, isActive, isCached, isClosed, isStored, knownClasses, lock, peekPersisted, purge, purge, reflector, refresh, store, storedClass, storedClasses, versionactivate, close, commit, deactivate, delete, ext, query, query, query, query, query, queryByExample, rollback, storebackupprotected FileHeader _fileHeader
protected final ByteArrayBuffer _pointerIo
public Transaction newTransaction(Transaction parentTransaction, ReferenceSystem referenceSystem, boolean isSystemTransaction)
newTransaction in class ObjectContainerBasepublic TransactionalIdSystem newTransactionalIdSystem(TransactionalIdSystem systemIdSystem, Closure4<IdSystem> idSystem)
public FreespaceManager freespaceManager()
public void blockSizeReadFromFile(int size)
public void setRegularEndAddress(long address)
protected final void close2()
close2 in class ObjectContainerBasepublic void commit1(Transaction trans)
commit1 in class ObjectContainerBasepublic int converterVersion()
converterVersion in class ObjectContainerBasepublic long currentVersion()
currentVersion in class ObjectContainerBasepublic final BTree createBTreeClassIndex(int id)
public final AbstractQueryResult newQueryResult(Transaction trans)
public final AbstractQueryResult newQueryResult(Transaction trans, QueryEvaluationMode mode)
newQueryResult in class ObjectContainerBasepublic final boolean delete4(Transaction transaction, ObjectReference ref, java.lang.Object obj, int cascade, boolean userCall)
delete4 in class ObjectContainerBasepublic abstract long fileLength()
public abstract java.lang.String fileName()
public void free(Slot slot)
public void free(int address,
int a_length)
public void generateNewIdentity()
public AbstractQueryResult queryAllObjects(Transaction trans)
queryAllObjects in class ObjectContainerBasepublic AbstractQueryResult getAll(Transaction trans, QueryEvaluationMode mode)
public int allocatePointerSlot()
protected boolean isValidPointer(int id)
public Slot allocateSlot(int length)
public final Slot appendBytes(long bytes)
public Db4oDatabase identity()
ExtObjectContaineridentity in interface ExtObjectContaineridentity in class ExternalObjectContainerpublic void setIdentity(Db4oDatabase identity)
public final int idForNewUserObject(Transaction trans)
idForNewUserObject in class ObjectContainerBasepublic void raiseCommitTimestamp(long minimumVersion)
raiseCommitTimestamp in class ObjectContainerBasepublic StatefulBuffer readStatefulBufferById(Transaction a_ta, int a_id)
readStatefulBufferById in class ObjectContainerBasepublic ByteArrayBuffer[] readSlotBuffers(Transaction transaction, int[] ids)
readSlotBuffers in class ObjectContainerBasepublic ByteArrayBuffer readBufferById(Transaction trans, int id)
readBufferById in class ObjectContainerBasepublic final ByteArrayBuffer readBufferById(Transaction trans, int id, boolean lastCommitted)
readBufferById in class ObjectContainerBasepublic StatefulBuffer readStatefulBufferById(Transaction trans, int id, boolean lastCommitted)
readStatefulBufferById in class ObjectContainerBasepublic ByteArrayBuffer readBufferBySlot(Slot slot)
public StatefulBuffer readStatefulBufferBySlot(Transaction trans, int id, Slot slot)
protected boolean doFinalize()
doFinalize in class ObjectContainerBaseprotected void createIdSystem()
public final void releaseSemaphore(java.lang.String name)
ExtObjectContainerreleaseSemaphore in interface ExtObjectContainerreleaseSemaphore in class ObjectContainerBasename - the name of the semaphore to be released.public final void releaseSemaphore(Transaction trans, java.lang.String name)
releaseSemaphore in class ObjectContainerBasepublic void releaseSemaphores(Transaction trans)
releaseSemaphores in class ObjectContainerBasepublic final void rollback1(Transaction trans)
rollback1 in class ObjectContainerBasepublic final void setDirtyInSystemTransaction(PersistentBase a_object)
setDirtyInSystemTransaction in class ObjectContainerBasepublic final boolean setSemaphore(java.lang.String name,
int timeout)
ExtObjectContainerObjectContainers.
ExtObjectContainer.releaseSemaphore(java.lang.String)ObjectContainer.close()ObjectServer is
closed.ObjectContainer looses the connection and is timed
out.ObjectContainer.commit() or ObjectContainer.rollback().getID(Object)setSemaphore in interface ExtObjectContainersetSemaphore in class ObjectContainerBasename - the name of the semaphore to be settimeout - the time in milliseconds to wait for other
transactions to release the semaphore. The parameter may be zero, if
the method is to return immediately.true, if the semaphore could be set or if the
calling transaction already owned the semaphore.
false, if the semaphore is owned by another
transaction.public final boolean setSemaphore(Transaction trans, java.lang.String name, int timeout)
setSemaphore in class ObjectContainerBasepublic void setServer(boolean flag)
public abstract void syncFiles()
public abstract void syncFiles(java.lang.Runnable runnable)
protected java.lang.String defaultToString()
defaultToString in class ObjectContainerBasepublic void shutdown()
shutdown in class ObjectContainerBasepublic final void commitTransaction()
public abstract void writeBytes(ByteArrayBuffer buffer, int blockedAddress, int addressOffset)
public final void writeDirtyClassMetadata()
writeDirtyClassMetadata in class ObjectContainerBasepublic final void writeEncrypt(ByteArrayBuffer buffer, int address, int addressOffset)
public void writeHeader(boolean startFileLockingThread,
boolean shuttingDown)
public final void writeNew(Transaction trans, Pointer4 pointer, ClassMetadata classMetadata, ByteArrayBuffer buffer)
writeNew in class ObjectContainerBasepublic abstract void overwriteDeletedBytes(int address,
int length)
public void overwriteDeletedBlockedSlot(Slot slot)
public final void writeTransactionPointer(int pointer)
public final Slot allocateSlotForUserObjectUpdate(Transaction trans, int id, int length)
public final Slot allocateSlotForNewUserObject(Transaction trans, int id, int length)
public final void writeUpdate(Transaction trans, Pointer4 pointer, ClassMetadata classMetadata, ArrayType arrayType, ByteArrayBuffer buffer)
writeUpdate in class ObjectContainerBasepublic void setNextTimeStampId(long val)
public SystemInfo systemInfo()
ExtObjectContainerSystemInfo for this ObjectContainer.
SystemInfo supplies methods that provide
information about system state and system settings of this
ObjectContainer.systemInfo in interface ExtObjectContainersystemInfo in class ObjectContainerBaseSystemInfo for this ObjectContainer.public FileHeader getFileHeader()
public void installDebugFreespaceManager(FreespaceManager manager)
public SystemData systemData()
public long[] getIDsForClass(Transaction trans, ClassMetadata clazz)
getIDsForClass in class ObjectContainerBasepublic QueryResult classOnlyQuery(QQueryBase query, ClassMetadata clazz)
classOnlyQuery in class ObjectContainerBasepublic QueryResult executeQuery(QQuery query)
executeQuery in class ObjectContainerBasepublic LocalTransaction localSystemTransaction()
public int instanceCount(ClassMetadata clazz, Transaction trans)
instanceCount in interface InternalObjectContainerpublic ObjectContainer openSession()
ExtObjectContaineropenSession in interface ExtObjectContainerpublic boolean isDeleted(Transaction trans, int id)
isDeleted in class ObjectContainerBasepublic void writePointer(int id,
Slot slot)
public Slot debugReadPointerSlot(int id)
public final Slot readPointerSlot(int id)
protected void closeIdSystem()
closeIdSystem in class ObjectContainerBasepublic IdSystem idSystem()
public java.lang.Runnable commitHook()
public final Slot allocateSafeSlot(int length)
public EventRegistryImpl newEventRegistry()
newEventRegistry in interface InternalObjectContainerpublic <T> QLin<T> from(java.lang.Class<T> clazz)