com.db4o.cs.internal

Class ClientObjectContainer

java.lang.Object

com.db4o.internal.ObjectContainerBase

com.db4o.internal.ExternalObjectContainer

com.db4o.cs.internal.ClientObjectContainer

All Implemented Interfaces:

BlobTransport, ClientMessageDispatcher, MessageDispatcher, ExtClient, ExtObjectContainer, InternalObjectContainer, ObjectContainerSpec, Internal4, ObjectContainer, TransientClass

public class ClientObjectContainer
extends ExternalObjectContainer
implements ExtClient, BlobTransport, ClientMessageDispatcher

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	ClientObjectContainer.MessageListener

Field Summary

Fields

Modifier and Type	Field and Description
protected boolean	_doFinalize

Fields inherited from class com.db4o.internal.ObjectContainerBase

_blockConverter, _classCollection, _config, _handlers, _lock, _timeStampIdGenerator, _transaction

Constructor Summary

Constructors

Constructor and Description
ClientObjectContainer(ClientConfigurationImpl config, Socket4Adapter socket, java.lang.String user, java.lang.String password, boolean login)
ClientObjectContainer(ClientConfiguration config, Socket4Adapter socket, java.lang.String user, java.lang.String password, boolean login)

Method Summary

Methods

Modifier and Type	Method and Description
void	addToBatch(Msg msg)
protected boolean	applyRenames(Config4Impl config)
void	backup(Storage targetStorage, java.lang.String path)
byte	blockSize()
void	blockSize(int size)
ClassMetadata	classMetadataForID(int clazzId)
ClassMetadata	classMetadataForReflectClass(ReflectClass claxx)
int	classMetadataIdForName(java.lang.String name)
QueryResult	classOnlyQuery(QQueryBase query, ClassMetadata clazz)
protected void	close2()
protected void	closeIdSystem()
void	closeTransaction(Transaction transaction, boolean isSystemTransaction, boolean rollbackOnClose)
void	commit1(Transaction trans)
void	commitReplication(long replicationRecordId, long timestamp)
int	converterVersion()
boolean	createClassMetadata(ClassMetadata clazz, ReflectClass claxx, ClassMetadata superClazz)
long	currentVersion()
protected java.lang.String	defaultToString()
boolean	delete4(Transaction ta, ObjectReference yo, java.lang.Object obj, int a_cascade, boolean userCall)
void	deleteBlobFile(Transaction trans, BlobImpl blob)
boolean	detectSchemaChanges()
protected boolean	doFinalize()
QueryResult	executeQuery(QQuery query)
Msg	expectedResponse(Msg expectedMessage)
protected void	fatalStorageShutdown()
<T> QLin<T>	from(java.lang.Class<T> clazz)
HardObjectReference	getHardReferenceBySignature(Transaction trans, long uuid, byte[] signature)
long[]	getIDsForClass(Transaction trans, ClassMetadata clazz)
Msg	getResponse() may return null, if no message is returned.
protected boolean	hasShutDownHook()
Db4oDatabase	identity()
int	idForNewUserObject(Transaction trans)
FixedSizeIntIterator4	idIteratorFor(Transaction trans, ByteArrayBuffer reader)
int	instanceCount(ClassMetadata clazz, Transaction trans)
boolean	isAlive()
boolean	isClient()
boolean	isDeleted(Transaction trans, int id)
boolean	isMessageDispatcherAlive()
boolean	maintainsIndices()
ClientMessageDispatcher	messageDispatcher()
void	messageListener(ClientObjectContainer.MessageListener listener)
boolean	needsLockFileThread()
EventRegistryImpl	newEventRegistry()
AbstractQueryResult	newQueryResult(Transaction trans, QueryEvaluationMode mode)
Transaction	newTransaction(Transaction parentTransaction, ReferenceSystem referenceSystem, boolean isSystemTransaction)
void	onCommittedListenerAdded()
protected void	openImpl()
ObjectContainer	openSession()
java.lang.Object	peekPersisted(Transaction trans, java.lang.Object obj, ActivationDepth depth, boolean committed)
AbstractQueryResult	queryAllObjects(Transaction trans)
void	raiseCommitTimestamp(long a_minimumVersion)
void	readBlobFrom(Transaction trans, BlobImpl blob)
ByteArrayBuffer	readBufferById(Transaction a_ta, int a_id)
ByteArrayBuffer	readBufferById(Transaction transaction, int id, boolean lastCommitted)
void	readBytes(byte[] a_bytes, int a_address, int a_length)
void	readBytes(byte[] bytes, int address, int addressOffset, int length)
ByteArrayBuffer[]	readObjectSlots(Transaction transaction, int[] ids)
ByteArrayBuffer[]	readSlotBuffers(Transaction transaction, int[] ids)
StatefulBuffer	readStatefulBufferById(Transaction a_ta, int a_id)
StatefulBuffer	readStatefulBufferById(Transaction a_ta, int a_id, boolean lastCommitted)
protected void	refreshInternal(Transaction trans, java.lang.Object obj, int depth)
void	releaseSemaphore(java.lang.String name)
void	releaseSemaphore(Transaction trans, java.lang.String name)
void	releaseSemaphores(Transaction ta)
void	reserve(int byteCount)
void	rollback1(Transaction trans)
void	send(java.lang.Object obj)
int	serverSideID()
void	setDirtyInSystemTransaction(PersistentBase a_object)
void	setDispatcherName(java.lang.String name)
boolean	setSemaphore(java.lang.String name, int timeout)
boolean	setSemaphore(Transaction trans, java.lang.String name, int timeout)
void	shutdown()
protected void	shutdownDataStorage()
Socket4Adapter	socket()
void	storeAll(Transaction transaction, Iterator4 objects)
SystemInfo	systemInfo()
java.lang.String	userName()
boolean	write(Msg msg)
void	writeBatchedMessage(Msg msg)
void	writeBatchedMessages()
void	writeBlobTo(Transaction trans, BlobImpl blob)
void	writeDirtyClassMetadata()
boolean	writeMessageToSocket(Msg msg)
void	writeMsg(Msg msg, boolean flush)
void	writeNew(Transaction trans, Pointer4 pointer, ClassMetadata classMetadata, ByteArrayBuffer buffer)
void	writeUpdate(Transaction trans, Pointer4 pointer, ClassMetadata classMetadata, ArrayType arrayType, ByteArrayBuffer buffer)

Methods inherited from class com.db4o.internal.ExternalObjectContainer

activate, activate, 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, storedClasses

Methods inherited from class com.db4o.internal.ObjectContainerBase

activate, activate, activationContextFor, activationDepthProvider, asTopLevelCall, backup, bind, bind2, blockConverter, callbacks, callbacks, checkClosed, checkReadOnly, checkStillToSet, checkTransaction, checkTransaction, classCollection, classMetadataForName, classMetadataForObject, close, closeSystemTransaction, closeUserTransaction, commit, commitTimestampIndex, config, configImpl, configure, container, createBlockConverter, createReferenceSystem, createStatefulBuffer, createStringIO, db4oTypeStored, deactivate, deactivate, decryptedBufferByAddress, defaultActivationDepth, delete, delete1, delete2, deleteByID, dispatchsEvents, environment, fatalShutdown, finalize, flagAsHandled, generateTimeStampId, generateTransactionTimestamp, getActivatedObjectFromCache, getByID, getByID2, getByUUID, getHardObjectReferenceById, getID, getNativeQueryHandler, getObjectInfo, handledInCurrentTopLevelCall, handleExceptionOnClose, handlers, initalizeWeakReferenceSupport, initialize1, initializeClassMetadataRepository, initializePostOpenExcludingTransportObjectContainer, initializeTransactions, isCached, isClosed, isStored, knownClasses, lock, logMsg, needsUpdate, newSystemTransaction, newUserTransaction, newWeakReference, open, peekPersisted, peekReference, produceClassMetadata, purge, purge, query, query, query, query, query, queryByExample, rawBufferByAddress, readActivatedObjectNotInCache, readWriterByAddress, referenceSystemRegistry, reflector, refresh, replaceClassMetadataRepository, replicationCallState, rollback, showInternalClasses, shutdownObjectContainer, stackDepth, stackDepth, stillToActivate, stillToDeactivate, stopSession, store, store, store2, storeAfterReplication, storeAll, storeByNewReplication, storedClass, storedClasses, storeInternal, storeInternal, stringIO, syncExec, systemTransaction, threadPool, topLevelCallId, topLevelCallId, toString, transaction, tryGetByID, typeHandlerForClass, typeHandlerForClassMetadataID, updateDepthProvider, useDefaultTransactionTimestamp, uUIDIndex, version, versionIndex, withEnvironment, withTransaction

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.db4o.ext.ExtObjectContainer

activate, backup, bind, configure, deactivate, descend, getByID, getByUUID, getID, getObjectInfo, isActive, isCached, isClosed, isStored, knownClasses, lock, peekPersisted, purge, purge, reflector, refresh, store, storedClass, storedClasses, version

Methods inherited from interface com.db4o.ObjectContainer

activate, close, commit, deactivate, delete, ext, query, query, query, query, query, queryByExample, rollback, store

Methods inherited from interface com.db4o.cs.internal.messages.MessageDispatcher

close

Field Detail

_doFinalize

protected boolean _doFinalize

Constructor Detail

ClientObjectContainer

public ClientObjectContainer(ClientConfiguration config,
                     Socket4Adapter socket,
                     java.lang.String user,
                     java.lang.String password,
                     boolean login)

ClientObjectContainer

public ClientObjectContainer(ClientConfigurationImpl config,
                     Socket4Adapter socket,
                     java.lang.String user,
                     java.lang.String password,
                     boolean login)

Method Detail

openImpl

protected final void openImpl()

Specified by:

openImpl in class ObjectContainerBase

backup

public void backup(Storage targetStorage,
          java.lang.String path)
            throws NotSupportedException

Specified by:

backup in interface ExtObjectContainer

Specified by:

backup in class ExternalObjectContainer

Throws:

NotSupportedException

closeTransaction

public void closeTransaction(Transaction transaction,
                    boolean isSystemTransaction,
                    boolean rollbackOnClose)

Specified by:

closeTransaction in class ObjectContainerBase

reserve

public void reserve(int byteCount)

Specified by:

reserve in class ObjectContainerBase

blockSize

public byte blockSize()

Specified by:

blockSize in class ObjectContainerBase

close2

protected void close2()

Specified by:

close2 in class ObjectContainerBase

commit1

public final void commit1(Transaction trans)

Specified by:

commit1 in class ObjectContainerBase

converterVersion

public int converterVersion()

Specified by:

converterVersion in class ObjectContainerBase

newQueryResult

public AbstractQueryResult newQueryResult(Transaction trans,
                                 QueryEvaluationMode mode)

Specified by:

newQueryResult in class ObjectContainerBase

newTransaction

public final Transaction newTransaction(Transaction parentTransaction,
                         ReferenceSystem referenceSystem,
                         boolean isSystemTransaction)

Specified by:

newTransaction in class ObjectContainerBase

createClassMetadata

public boolean createClassMetadata(ClassMetadata clazz,
                          ReflectClass claxx,
                          ClassMetadata superClazz)

Overrides:

createClassMetadata in class ObjectContainerBase

currentVersion

public long currentVersion()

Specified by:

currentVersion in class ObjectContainerBase

delete4

public final boolean delete4(Transaction ta,
              ObjectReference yo,
              java.lang.Object obj,
              int a_cascade,
              boolean userCall)

Specified by:

delete4 in class ObjectContainerBase

detectSchemaChanges

public boolean detectSchemaChanges()

Overrides:

detectSchemaChanges in class ObjectContainerBase

doFinalize

protected boolean doFinalize()

Overrides:

doFinalize in class ObjectContainerBase

expectedResponse

public final Msg expectedResponse(Msg expectedMessage)

queryAllObjects

public AbstractQueryResult queryAllObjects(Transaction trans)

Specified by:

queryAllObjects in class ObjectContainerBase

getHardReferenceBySignature

public final HardObjectReference getHardReferenceBySignature(Transaction trans,
                                              long uuid,
                                              byte[] signature)

Overrides:

getHardReferenceBySignature in class ObjectContainerBase

getResponse

public Msg getResponse()

may return null, if no message is returned. Error handling is weak and should ideally be able to trigger some sort of state listener (connection dead) on the client.

isMessageDispatcherAlive

public boolean isMessageDispatcherAlive()

Specified by:

isMessageDispatcherAlive in interface MessageDispatcher

classMetadataForID

public ClassMetadata classMetadataForID(int clazzId)

Specified by:

classMetadataForID in interface InternalObjectContainer

Overrides:

classMetadataForID in class ObjectContainerBase

needsLockFileThread

public boolean needsLockFileThread()

Overrides:

needsLockFileThread in class ObjectContainerBase

hasShutDownHook

protected boolean hasShutDownHook()

Overrides:

hasShutDownHook in class ObjectContainerBase

identity

public Db4oDatabase identity()

Specified by:

identity in interface ExtObjectContainer

Specified by:

identity in class ExternalObjectContainer

isClient

public boolean isClient()

Specified by:

isClient in interface InternalObjectContainer

Overrides:

isClient in class ObjectContainerBase

maintainsIndices

public boolean maintainsIndices()

Overrides:

maintainsIndices in class ObjectContainerBase

idForNewUserObject

public final int idForNewUserObject(Transaction trans)

Specified by:

idForNewUserObject in class ObjectContainerBase

raiseCommitTimestamp

public void raiseCommitTimestamp(long a_minimumVersion)

Specified by:

raiseCommitTimestamp in class ObjectContainerBase

readBytes

public void readBytes(byte[] bytes,
             int address,
             int addressOffset,
             int length)

Specified by:

readBytes in class ObjectContainerBase

readBytes

public void readBytes(byte[] a_bytes,
             int a_address,
             int a_length)

Specified by:

readBytes in class ObjectContainerBase

applyRenames

protected boolean applyRenames(Config4Impl config)

Overrides:

applyRenames in class ObjectContainerBase

readStatefulBufferById

public final StatefulBuffer readStatefulBufferById(Transaction a_ta,
                                    int a_id)

Specified by:

readStatefulBufferById in class ObjectContainerBase

readStatefulBufferById

public final StatefulBuffer readStatefulBufferById(Transaction a_ta,
                                    int a_id,
                                    boolean lastCommitted)

Specified by:

readStatefulBufferById in class ObjectContainerBase

peekPersisted

public java.lang.Object peekPersisted(Transaction trans,
                             java.lang.Object obj,
                             ActivationDepth depth,
                             boolean committed)
                               throws DatabaseClosedException

Overrides:

peekPersisted in class ObjectContainerBase

Throws:

DatabaseClosedException

refreshInternal

protected void refreshInternal(Transaction trans,
                   java.lang.Object obj,
                   int depth)

Overrides:

refreshInternal in class ObjectContainerBase

readSlotBuffers

public final ByteArrayBuffer[] readSlotBuffers(Transaction transaction,
                                int[] ids)

Specified by:

readSlotBuffers in class ObjectContainerBase

readObjectSlots

public final ByteArrayBuffer[] readObjectSlots(Transaction transaction,
                                int[] ids)

readBufferById

public final ByteArrayBuffer readBufferById(Transaction transaction,
                             int id,
                             boolean lastCommitted)

Specified by:

readBufferById in class ObjectContainerBase

readBufferById

public final ByteArrayBuffer readBufferById(Transaction a_ta,
                             int a_id)

Specified by:

readBufferById in class ObjectContainerBase

idIteratorFor

public FixedSizeIntIterator4 idIteratorFor(Transaction trans,
                                  ByteArrayBuffer reader)

releaseSemaphore

public void releaseSemaphore(Transaction trans,
                    java.lang.String name)

Specified by:

releaseSemaphore in class ObjectContainerBase

releaseSemaphore

public void releaseSemaphore(java.lang.String name)

Specified by:

releaseSemaphore in interface ExtObjectContainer

Specified by:

releaseSemaphore in class ObjectContainerBase

releaseSemaphores

public void releaseSemaphores(Transaction ta)

Specified by:

releaseSemaphores in class ObjectContainerBase

rollback1

public final void rollback1(Transaction trans)

Specified by:

rollback1 in class ObjectContainerBase

send

public void send(java.lang.Object obj)

Overrides:

send in class ObjectContainerBase

setDirtyInSystemTransaction

public final void setDirtyInSystemTransaction(PersistentBase a_object)

Specified by:

setDirtyInSystemTransaction in class ObjectContainerBase

setSemaphore

public boolean setSemaphore(Transaction trans,
                   java.lang.String name,
                   int timeout)

Specified by:

setSemaphore in class ObjectContainerBase

setSemaphore

public boolean setSemaphore(java.lang.String name,
                   int timeout)

Specified by:

setSemaphore in interface ExtObjectContainer

Specified by:

setSemaphore in class ObjectContainerBase

defaultToString

protected java.lang.String defaultToString()

Specified by:

defaultToString in class ObjectContainerBase

shutdown

public void shutdown()

Specified by:

shutdown in class ObjectContainerBase

writeDirtyClassMetadata

public final void writeDirtyClassMetadata()

Specified by:

writeDirtyClassMetadata in class ObjectContainerBase

write

public final boolean write(Msg msg)

Specified by:

write in interface MessageDispatcher

writeBatchedMessage

public final void writeBatchedMessage(Msg msg)

writeMsg

public final void writeMsg(Msg msg,
            boolean flush)

writeMessageToSocket

public boolean writeMessageToSocket(Msg msg)

writeNew

public final void writeNew(Transaction trans,
            Pointer4 pointer,
            ClassMetadata classMetadata,
            ByteArrayBuffer buffer)

Specified by:

writeNew in class ObjectContainerBase

writeUpdate

public final void writeUpdate(Transaction trans,
               Pointer4 pointer,
               ClassMetadata classMetadata,
               ArrayType arrayType,
               ByteArrayBuffer buffer)

Specified by:

writeUpdate in class ObjectContainerBase

isAlive

public boolean isAlive()

Specified by:

isAlive in interface ExtClient

socket

public Socket4Adapter socket()

systemInfo

public SystemInfo systemInfo()

Specified by:

systemInfo in interface ExtObjectContainer

Specified by:

systemInfo in class ObjectContainerBase

writeBlobTo

public void writeBlobTo(Transaction trans,
               BlobImpl blob)
                 throws java.io.IOException

Specified by:

writeBlobTo in interface BlobTransport

Throws:

java.io.IOException

readBlobFrom

public void readBlobFrom(Transaction trans,
                BlobImpl blob)
                  throws java.io.IOException

Specified by:

readBlobFrom in interface BlobTransport

Throws:

java.io.IOException

deleteBlobFile

public void deleteBlobFile(Transaction trans,
                  BlobImpl blob)

Specified by:

deleteBlobFile in interface BlobTransport

getIDsForClass

public long[] getIDsForClass(Transaction trans,
                    ClassMetadata clazz)

Specified by:

getIDsForClass in class ObjectContainerBase

classOnlyQuery

public QueryResult classOnlyQuery(QQueryBase query,
                         ClassMetadata clazz)

Specified by:

classOnlyQuery in class ObjectContainerBase

executeQuery

public QueryResult executeQuery(QQuery query)

Specified by:

executeQuery in class ObjectContainerBase

writeBatchedMessages

public final void writeBatchedMessages()

addToBatch

public final void addToBatch(Msg msg)

shutdownDataStorage

protected void shutdownDataStorage()

Specified by:

shutdownDataStorage in class ObjectContainerBase

setDispatcherName

public void setDispatcherName(java.lang.String name)

messageDispatcher

public ClientMessageDispatcher messageDispatcher()

onCommittedListenerAdded

public void onCommittedListenerAdded()

classMetadataForReflectClass

public ClassMetadata classMetadataForReflectClass(ReflectClass claxx)

Specified by:

classMetadataForReflectClass in interface InternalObjectContainer

Overrides:

classMetadataForReflectClass in class ObjectContainerBase

classMetadataIdForName

public int classMetadataIdForName(java.lang.String name)

Overrides:

classMetadataIdForName in class ObjectContainerBase

instanceCount

public int instanceCount(ClassMetadata clazz,
                Transaction trans)

Specified by:

instanceCount in interface InternalObjectContainer

messageListener

public void messageListener(ClientObjectContainer.MessageListener listener)

storeAll

public void storeAll(Transaction transaction,
            Iterator4 objects)

Specified by:

storeAll in interface InternalObjectContainer

Overrides:

storeAll in class ObjectContainerBase

fatalStorageShutdown

protected void fatalStorageShutdown()

Specified by:

fatalStorageShutdown in class ObjectContainerBase

userName

public java.lang.String userName()

isDeleted

public boolean isDeleted(Transaction trans,
                int id)

Specified by:

isDeleted in class ObjectContainerBase

blockSize

public void blockSize(int size)

Specified by:

blockSize in class ObjectContainerBase

closeIdSystem

protected void closeIdSystem()

Specified by:

closeIdSystem in class ObjectContainerBase

openSession

public ObjectContainer openSession()

Specified by:

openSession in interface ExtObjectContainer

serverSideID

public int serverSideID()

newEventRegistry

public EventRegistryImpl newEventRegistry()

Specified by:

newEventRegistry in interface InternalObjectContainer

from

public <T> QLin<T> from(java.lang.Class<T> clazz)

commitReplication

public void commitReplication(long replicationRecordId,
                     long timestamp)