com.db4o.cs.internal.messages

Class Msg

java.lang.Object

com.db4o.cs.internal.messages.Msg

All Implemented Interfaces:

Message, java.lang.Cloneable

Direct Known Subclasses:

MClose, MCloseSocket, MCommitSystemTransaction, MCommittedCallBackRegistry, MError, MFailed, MGetThreadID, MIdentity, MIsAlive, MNull, MOK, MPing, MPong, MProcessDeletes, MRollback, MsgD, MSuccess, MSwitchToMainFile, MUseDefaultTransactionTimestamp, MVersion

public abstract class Msg
extends java.lang.Object
implements java.lang.Cloneable, Message

Messages for Client/Server Communication

Field Summary

Fields

Modifier and Type	Field and Description
static MClassID	CLASS_ID
static MClassMeta	CLASS_META
static MClassMetadataIdForName	CLASS_METADATA_ID_FOR_NAME
static MClassNameForID	CLASS_NAME_FOR_ID
static MClose	CLOSE
static MCloseSocket	CLOSE_SOCKET
static MCommit	COMMIT
static MCommitReplication	COMMIT_REPLICATION
static MCommitSystemTransaction	COMMIT_SYSTEMTRANS
static MCommittedCallBackRegistry	COMMITTED_CALLBACK_REGISTER
static MCommittedInfo	COMMITTED_INFO
static MCreateClass	CREATE_CLASS
static MVersion	CURRENT_VERSION
static MDelete	DELETE
static MsgBlob	DELETE_BLOB_FILE
static MError	ERROR
static MFailed	FAILED
static MGenerateTransactionTimestamp	GENERATE_TRANSACTION_TIMESTAMP
static MGetAll	GET_ALL
static MGetClasses	GET_CLASSES
static MGetInternalIDs	GET_INTERNAL_IDS
static MGetThreadID	GET_THREAD_ID
static MIDList	ID_LIST
static MIdentity	IDENTITY
static MInstanceCount	INSTANCE_COUNT
static MIsAlive	IS_ALIVE
static MLength	LENGTH
static MLogin	LOGIN
static MLoginOK	LOGIN_OK
static MNull	NULL
static MObjectByUuid	OBJECT_BY_UUID
static MsgObject	OBJECT_TO_CLIENT
static MObjectSetFetch	OBJECTSET_FETCH
static MObjectSetFinalized	OBJECTSET_FINALIZED
static MObjectSetGetId	OBJECTSET_GET_ID
static MObjectSetIndexOf	OBJECTSET_INDEXOF
static MObjectSetReset	OBJECTSET_RESET
static MObjectSetSize	OBJECTSET_SIZE
static MOK	OK
static MPing	PING
static MPong	PONG
static MPrefetchIDs	PREFETCH_IDS
static MProcessDeletes	PROCESS_DELETES
static MQueryExecute	QUERY_EXECUTE
static MQueryResult	QUERY_RESULT
static MRaiseCommitTimestamp	RAISE_COMMIT_TIMESTAMP
static MReadBlob	READ_BLOB
static MReadBytes	READ_BYTES
static MReadMultipleObjects	READ_MULTIPLE_OBJECTS
static MReadObject	READ_OBJECT
static MReadReaderById	READ_READER_BY_ID
static MReadSlot	READ_SLOT
static MReleaseSemaphore	RELEASE_SEMAPHORE
static MRequestExceptionWithResponse	REQUEST_EXCEPTION_WITH_RESPONSE
static MRequestExceptionWithoutResponse	REQUEST_EXCEPTION_WITHOUT_RESPONSE
static MRollback	ROLLBACK
static MRuntimeException	RUNTIME_EXCEPTION
static MSetSemaphore	SET_SEMAPHORE
static MSuccess	SUCCESS
static MSwitchToFile	SWITCH_TO_FILE
static MSwitchToMainFile	SWITCH_TO_MAIN_FILE
static MTaDelete	TA_DELETE
static MTaIsDeleted	TA_IS_DELETED
static MUseDefaultTransactionTimestamp	USE_DEFAULT_TRANSACTION_TIMESTAMP
static MUseTransaction	USE_TRANSACTION
static MUserMessage	USER_MESSAGE
static MVersionForId	VERSION_FOR_ID
static MWriteBatchedMessages	WRITE_BATCHED_MESSAGES
static MWriteBlob	WRITE_BLOB
static MWriteNew	WRITE_NEW
static MWriteUpdate	WRITE_UPDATE

Method Summary

Methods

Modifier and Type	Method and Description
protected Transaction	checkParentTransaction(Transaction a_trans, ByteArrayBuffer reader)
ClientMessageDispatcher	clientMessageDispatcher()
protected Config4Impl	config()
protected ObjectContainerBase	container()
protected java.lang.Object	containerLock()
boolean	equals(java.lang.Object obj)
ByteArrayBuffer	getByteLoad() dummy method to allow clean override handling without casting
static Msg	getMessage(int id)
int	hashCode()
protected LocalObjectContainer	localContainer()
void	logMsg(int msgCode, java.lang.String msg)
MessageDispatcher	messageDispatcher()
StatefulBuffer	payLoad()
void	postProcessAtServer() to be overridden by implementors of MessageWithResponse
Msg	publicClone()
static Msg	readMessage(MessageDispatcher messageDispatcher, Transaction trans, Socket4Adapter socket)
protected static StatefulBuffer	readMessageBuffer(Transaction trans, Socket4Adapter socket)
protected static StatefulBuffer	readMessageBuffer(Transaction trans, Socket4Adapter socket, int length)
Msg	respondInt(int response)
ServerMessageDispatcher	serverMessageDispatcher()
protected LocalTransaction	serverTransaction()
void	setMessageDispatcher(MessageDispatcher messageDispatcher)
void	setTransaction(Transaction aTrans)
protected Transaction	systemTransaction()
java.lang.String	toString()
protected Transaction	transaction()
void	write(Msg msg)
boolean	write(Socket4Adapter sock)
void	writeException(java.lang.RuntimeException e)

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Field Detail

RUNTIME_EXCEPTION

public static final MRuntimeException RUNTIME_EXCEPTION

CLASS_ID

public static final MClassID CLASS_ID

CLASS_METADATA_ID_FOR_NAME

public static final MClassMetadataIdForName CLASS_METADATA_ID_FOR_NAME

CLASS_NAME_FOR_ID

public static final MClassNameForID CLASS_NAME_FOR_ID

CLOSE

public static final MClose CLOSE

CLOSE_SOCKET

public static final MCloseSocket CLOSE_SOCKET

COMMIT

public static final MCommit COMMIT

COMMITTED_CALLBACK_REGISTER

public static final MCommittedCallBackRegistry COMMITTED_CALLBACK_REGISTER

COMMITTED_INFO

public static final MCommittedInfo COMMITTED_INFO

COMMIT_SYSTEMTRANS

public static final MCommitSystemTransaction COMMIT_SYSTEMTRANS

CREATE_CLASS

public static final MCreateClass CREATE_CLASS

CLASS_META

public static final MClassMeta CLASS_META

CURRENT_VERSION

public static final MVersion CURRENT_VERSION

DELETE

public static final MDelete DELETE

ERROR

public static final MError ERROR

FAILED

public static final MFailed FAILED

GET_ALL

public static final MGetAll GET_ALL

GET_CLASSES

public static final MGetClasses GET_CLASSES

GET_INTERNAL_IDS

public static final MGetInternalIDs GET_INTERNAL_IDS

GET_THREAD_ID

public static final MGetThreadID GET_THREAD_ID

ID_LIST

public static final MIDList ID_LIST

IDENTITY

public static final MIdentity IDENTITY

IS_ALIVE

public static final MIsAlive IS_ALIVE

LENGTH

public static final MLength LENGTH

LOGIN

public static final MLogin LOGIN

LOGIN_OK

public static final MLoginOK LOGIN_OK

NULL

public static final MNull NULL

OBJECT_BY_UUID

public static final MObjectByUuid OBJECT_BY_UUID

OBJECT_TO_CLIENT

public static final MsgObject OBJECT_TO_CLIENT

OBJECTSET_FETCH

public static final MObjectSetFetch OBJECTSET_FETCH

OBJECTSET_FINALIZED

public static final MObjectSetFinalized OBJECTSET_FINALIZED

OBJECTSET_GET_ID

public static final MObjectSetGetId OBJECTSET_GET_ID

OBJECTSET_INDEXOF

public static final MObjectSetIndexOf OBJECTSET_INDEXOF

OBJECTSET_RESET

public static final MObjectSetReset OBJECTSET_RESET

OBJECTSET_SIZE

public static final MObjectSetSize OBJECTSET_SIZE

OK

public static final MOK OK

PING

public static final MPing PING

PONG

public static final MPong PONG

PREFETCH_IDS

public static final MPrefetchIDs PREFETCH_IDS

PROCESS_DELETES

public static final MProcessDeletes PROCESS_DELETES

QUERY_EXECUTE

public static final MQueryExecute QUERY_EXECUTE

QUERY_RESULT

public static final MQueryResult QUERY_RESULT

RAISE_COMMIT_TIMESTAMP

public static final MRaiseCommitTimestamp RAISE_COMMIT_TIMESTAMP

READ_BLOB

public static final MReadBlob READ_BLOB

READ_BYTES

public static final MReadBytes READ_BYTES

READ_SLOT

public static final MReadSlot READ_SLOT

READ_MULTIPLE_OBJECTS

public static final MReadMultipleObjects READ_MULTIPLE_OBJECTS

READ_OBJECT

public static final MReadObject READ_OBJECT

READ_READER_BY_ID

public static final MReadReaderById READ_READER_BY_ID

RELEASE_SEMAPHORE

public static final MReleaseSemaphore RELEASE_SEMAPHORE

ROLLBACK

public static final MRollback ROLLBACK

SET_SEMAPHORE

public static final MSetSemaphore SET_SEMAPHORE

SUCCESS

public static final MSuccess SUCCESS

SWITCH_TO_FILE

public static final MSwitchToFile SWITCH_TO_FILE

SWITCH_TO_MAIN_FILE

public static final MSwitchToMainFile SWITCH_TO_MAIN_FILE

TA_DELETE

public static final MTaDelete TA_DELETE

TA_IS_DELETED

public static final MTaIsDeleted TA_IS_DELETED

USER_MESSAGE

public static final MUserMessage USER_MESSAGE

USE_TRANSACTION

public static final MUseTransaction USE_TRANSACTION

WRITE_BLOB

public static final MWriteBlob WRITE_BLOB

WRITE_NEW

public static final MWriteNew WRITE_NEW

WRITE_UPDATE

public static final MWriteUpdate WRITE_UPDATE

WRITE_BATCHED_MESSAGES

public static final MWriteBatchedMessages WRITE_BATCHED_MESSAGES

DELETE_BLOB_FILE

public static final MsgBlob DELETE_BLOB_FILE

INSTANCE_COUNT

public static final MInstanceCount INSTANCE_COUNT

REQUEST_EXCEPTION_WITH_RESPONSE

public static final MRequestExceptionWithResponse REQUEST_EXCEPTION_WITH_RESPONSE

REQUEST_EXCEPTION_WITHOUT_RESPONSE

public static final MRequestExceptionWithoutResponse REQUEST_EXCEPTION_WITHOUT_RESPONSE

COMMIT_REPLICATION

public static final MCommitReplication COMMIT_REPLICATION

GENERATE_TRANSACTION_TIMESTAMP

public static final MGenerateTransactionTimestamp GENERATE_TRANSACTION_TIMESTAMP

VERSION_FOR_ID

public static final MVersionForId VERSION_FOR_ID

USE_DEFAULT_TRANSACTION_TIMESTAMP

public static final MUseDefaultTransactionTimestamp USE_DEFAULT_TRANSACTION_TIMESTAMP

Method Detail

getMessage

public static Msg getMessage(int id)

publicClone

public final Msg publicClone()

equals

public final boolean equals(java.lang.Object obj)

Overrides:

equals in class java.lang.Object

hashCode

public int hashCode()

Overrides:

hashCode in class java.lang.Object

getByteLoad

public ByteArrayBuffer getByteLoad()

dummy method to allow clean override handling without casting

serverTransaction

protected LocalTransaction serverTransaction()

transaction

protected Transaction transaction()

localContainer

protected LocalObjectContainer localContainer()

container

protected ObjectContainerBase container()

containerLock

protected java.lang.Object containerLock()

config

protected Config4Impl config()

readMessageBuffer

protected static StatefulBuffer readMessageBuffer(Transaction trans,
                               Socket4Adapter socket)
                                           throws Db4oIOException

Throws:

Db4oIOException

readMessageBuffer

protected static StatefulBuffer readMessageBuffer(Transaction trans,
                               Socket4Adapter socket,
                               int length)
                                           throws Db4oIOException

Throws:

Db4oIOException

readMessage

public static final Msg readMessage(MessageDispatcher messageDispatcher,
              Transaction trans,
              Socket4Adapter socket)
                             throws Db4oIOException

Throws:

Db4oIOException

checkParentTransaction

protected final Transaction checkParentTransaction(Transaction a_trans,
                                 ByteArrayBuffer reader)

setTransaction

public final void setTransaction(Transaction aTrans)

toString

public final java.lang.String toString()

Overrides:

toString in class java.lang.Object

write

public void write(Msg msg)

writeException

public void writeException(java.lang.RuntimeException e)

respondInt

public Msg respondInt(int response)

write

public boolean write(Socket4Adapter sock)

payLoad

public StatefulBuffer payLoad()

messageDispatcher

public MessageDispatcher messageDispatcher()

serverMessageDispatcher

public ServerMessageDispatcher serverMessageDispatcher()

clientMessageDispatcher

public ClientMessageDispatcher clientMessageDispatcher()

setMessageDispatcher

public void setMessageDispatcher(MessageDispatcher messageDispatcher)

logMsg

public void logMsg(int msgCode,
          java.lang.String msg)

postProcessAtServer

public void postProcessAtServer()

to be overridden by implementors of MessageWithResponse

systemTransaction

protected Transaction systemTransaction()