fabric.messages

Class PrepareTransactionMessage

java.lang.Object

fabric.messages.Message<PrepareTransactionMessage.Response,TransactionPrepareFailedException>

fabric.messages.PrepareTransactionMessage

public class PrepareTransactionMessage
extends Message<PrepareTransactionMessage.Response,TransactionPrepareFailedException>

A PrepareTransactionMessage represents a transaction request to a store.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	PrepareTransactionMessage.Response

Nested classes/interfaces inherited from class fabric.messages.Message

Message.MessageType, Message.NoException

Field Summary

Fields

Modifier and Type	Field and Description
java.util.Collection<Object._Impl>	creates The objects created during the transaction, unserialized.
boolean	readOnly A flag to indicate whether the transaction is read-only.
LongKeyMap<java.lang.Integer>	reads
java.util.Collection<SerializedObject>	serializedCreates The objects created during the transaction, serialized.
java.util.Collection<SerializedObject>	serializedWrites The objects modified during the transaction, serialized.
boolean	singleStore A flag to indicate whether objects from just a single (persistent) store are involved in this transaction.
long	tid
java.util.Collection<Object._Impl>	writes The objects modified during the transaction, unserialized.

Fields inherited from class fabric.messages.Message

exceptionClass, messageType

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	PrepareTransactionMessage(java.io.DataInput in)
	PrepareTransactionMessage(long tid) Used to prepare transactions at remote workers.
	PrepareTransactionMessage(long tid, boolean singleStore, boolean readOnly, java.util.Collection<Object._Impl> toCreate, LongKeyMap<java.lang.Integer> reads, java.util.Collection<Object._Impl> writes) Only used by the worker.

Method Summary

Modifier and Type	Method and Description
PrepareTransactionMessage.Response	dispatch(RemoteIdentity<RemoteWorker> client, MessageHandler h) Visitor method.
protected PrepareTransactionMessage.Response	readResponse(java.io.DataInput in) Creates a Response message of the appropriate type using the provided DataOutput
protected void	writeMessage(java.io.DataOutput out) Writes this message out on the given output stream.
protected void	writeResponse(java.io.DataOutput out, PrepareTransactionMessage.Response r) Writes a Response message of the appropriate type using the provided DataOutput.

Methods inherited from class fabric.messages.Message

readObject, readRef, receive, respond, respond, send, writeObject, writeRef

Methods inherited from class java.lang.Object

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

Field Detail

tid

public final long tid

singleStore

public final boolean singleStore

A flag to indicate whether objects from just a single (persistent) store are involved in this transaction. This is always false if the transaction is distributed. If this is true, then the store will commit the transaction as soon as it is prepared.

readOnly

public final boolean readOnly

A flag to indicate whether the transaction is read-only. A transaction is read-only if it does not modify any persistent objects. If this value is true, then the store will commit the transaction as soon as it is prepared.

reads

public final LongKeyMap<java.lang.Integer> reads

creates

public final java.util.Collection<Object._Impl> creates

The objects created during the transaction, unserialized. This will only be non-null on the worker. The store should use the serializedCreates field instead.

serializedCreates

public final java.util.Collection<SerializedObject> serializedCreates

The objects created during the transaction, serialized. This will only be non-null on the store. The worker should use the creates field instead.

writes

public final java.util.Collection<Object._Impl> writes

The objects modified during the transaction, unserialized. This will only be non-null on the worker. The store should use the serializedWrites field instead.

serializedWrites

public final java.util.Collection<SerializedObject> serializedWrites

The objects modified during the transaction, serialized. This will only be non-null on the store. The worker should use the writes field instead.

Constructor Detail

PrepareTransactionMessage

public PrepareTransactionMessage(long tid)

Used to prepare transactions at remote workers.

PrepareTransactionMessage

public PrepareTransactionMessage(long tid,
                                 boolean singleStore,
                                 boolean readOnly,
                                 java.util.Collection<Object._Impl> toCreate,
                                 LongKeyMap<java.lang.Integer> reads,
                                 java.util.Collection<Object._Impl> writes)

Only used by the worker.

PrepareTransactionMessage

protected PrepareTransactionMessage(java.io.DataInput in)
                             throws java.io.IOException

Throws:

java.io.IOException

Method Detail

dispatch

public PrepareTransactionMessage.Response dispatch(RemoteIdentity<RemoteWorker> client,
                                                   MessageHandler h)
                                            throws TransactionPrepareFailedException

Description copied from class: Message

Visitor method.

Specified by:

dispatch in class Message<PrepareTransactionMessage.Response,TransactionPrepareFailedException>

Parameters:

client - the node that is issuing the request.

h - the handler to which this message is to be dispatched.

Throws:

TransactionPrepareFailedException

writeMessage

protected void writeMessage(java.io.DataOutput out)
                     throws java.io.IOException

Description copied from class: Message

Writes this message out on the given output stream.

Specified by:

writeMessage in class Message<PrepareTransactionMessage.Response,TransactionPrepareFailedException>

Throws:

java.io.IOException - if the DataOutput fails.

writeResponse

protected void writeResponse(java.io.DataOutput out,
                             PrepareTransactionMessage.Response r)
                      throws java.io.IOException

Description copied from class: Message

Writes a Response message of the appropriate type using the provided DataOutput.

Specified by:

writeResponse in class Message<PrepareTransactionMessage.Response,TransactionPrepareFailedException>

Throws:

java.io.IOException - if the DataOutput fails.

readResponse

protected PrepareTransactionMessage.Response readResponse(java.io.DataInput in)
                                                   throws java.io.IOException

Description copied from class: Message

Creates a Response message of the appropriate type using the provided DataOutput

Specified by:

readResponse in class Message<PrepareTransactionMessage.Response,TransactionPrepareFailedException>

Throws:

java.io.IOException - if the response is malformed, or if the DataInput fails.