bftsmart.tom.core.messages

Class TOMMessage

java.lang.Object

bftsmart.communication.SystemMessage

bftsmart.tom.core.messages.TOMMessage

All Implemented Interfaces:

java.io.Externalizable, java.io.Serializable, java.lang.Cloneable, java.lang.Comparable

public class TOMMessage
extends SystemMessage
implements java.io.Externalizable, java.lang.Comparable, java.lang.Cloneable

This class represents a total ordered message

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
long	acceptSentTime
boolean	alreadyProposed
long	consensusStartTime
long	decisionTime
long	deliveryTime
int	destination
long	executedTime
byte[]	nonces
long	proposeReceivedTime
long	receptionTime
boolean	recvFromClient
TOMMessage	reply
byte[]	serializedMessage
byte[]	serializedMessageMAC
byte[]	serializedMessageSignature
boolean	signed
boolean	timeout
long	timestamp
long	writeSentTime

Fields inherited from class bftsmart.communication.SystemMessage

authenticated, sender

Constructor Summary

Constructors

Constructor and Description
TOMMessage()
TOMMessage(int sender, int session, int sequence, byte[] content, int view) Creates a new instance of TOMMessage
TOMMessage(int sender, int session, int sequence, byte[] content, int view, TOMMessageType type) Creates a new instance of TOMMessage
TOMMessage(int sender, int session, int sequence, int operationId, byte[] content, int view, TOMMessageType type) Creates a new instance of TOMMessage.

Method Summary

Methods

Modifier and Type	Method and Description
static TOMMessage	bytesToMessage(byte[] b)
java.lang.Object	clone()
int	compareTo(java.lang.Object o)
boolean	equals(java.lang.Object o) Verifies if two TOMMessage are equal.
byte[]	getContent() Retrieves the content of the message
DebugInfo	getDebugInfo() Retrieves the debug info from the TOM layer
int	getId() Retrieves the ID for this message.
int	getOperationId()
int	getReplyServer()
TOMMessageType	getReqType()
static int	getSenderFromId(int id) Retrieves the process ID of the sender given a message ID
int	getSequence() Retrieves the sequence number defined by the client
int	getSession() Retrieves the session id of this message
int	getViewID()
int	hashCode()
static byte[]	messageToBytes(TOMMessage m)
void	rExternal(java.io.DataInput in)
void	setDebugInfo(DebugInfo info) Retrieves the debug info from the TOM layer
void	setReplyServer(int replyServer)
java.lang.String	toString()
void	wExternal(java.io.DataOutput out)

Methods inherited from class bftsmart.communication.SystemMessage

getSender, readExternal, writeExternal

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.io.Externalizable

readExternal, writeExternal

Field Detail

timestamp

public transient long timestamp

nonces

public transient byte[] nonces

destination

public transient int destination

signed

public transient boolean signed

receptionTime

public transient long receptionTime

timeout

public transient boolean timeout

recvFromClient

public transient boolean recvFromClient

serializedMessage

public transient byte[] serializedMessage

serializedMessageSignature

public transient byte[] serializedMessageSignature

serializedMessageMAC

public transient byte[] serializedMessageMAC

consensusStartTime

public transient long consensusStartTime

proposeReceivedTime

public transient long proposeReceivedTime

writeSentTime

public transient long writeSentTime

acceptSentTime

public transient long acceptSentTime

decisionTime

public transient long decisionTime

deliveryTime

public transient long deliveryTime

executedTime

public transient long executedTime

reply

public transient TOMMessage reply

alreadyProposed

public transient boolean alreadyProposed

Constructor Detail

TOMMessage

public TOMMessage()

TOMMessage

public TOMMessage(int sender,
          int session,
          int sequence,
          byte[] content,
          int view)

Creates a new instance of TOMMessage

Parameters:

sender - ID of the process which sent the message

session - Session id of the sender

sequence - Sequence number defined by the client

content - Content of the message

view - ViewId of the message

TOMMessage

public TOMMessage(int sender,
          int session,
          int sequence,
          byte[] content,
          int view,
          TOMMessageType type)

Creates a new instance of TOMMessage

Parameters:

sender - ID of the process which sent the message

session - Session id of the sender

sequence - Sequence number defined by the client

content - Content of the message

view - ViewId of the message

type - Type of the request

TOMMessage

public TOMMessage(int sender,
          int session,
          int sequence,
          int operationId,
          byte[] content,
          int view,
          TOMMessageType type)

Creates a new instance of TOMMessage. This one has an operationId parameter used for FIFO executions

Parameters:

sender - The client id

session - The session id of the sender

sequence - The sequence number created based on the message type

operationId - The operation sequence number disregarding message type

content - The command to be executed

view - The view in which the message was sent

type - Ordered or Unordered request

Method Detail

getDebugInfo

public DebugInfo getDebugInfo()

Retrieves the debug info from the TOM layer

Returns:

The debug info from the TOM layer

setDebugInfo

public void setDebugInfo(DebugInfo info)

Retrieves the debug info from the TOM layer

getSession

public int getSession()

Retrieves the session id of this message

Returns:

The session id of this message

getSequence

public int getSequence()

Retrieves the sequence number defined by the client

Returns:

The sequence number defined by the client

getOperationId

public int getOperationId()

getViewID

public int getViewID()

getReqType

public TOMMessageType getReqType()

getId

public int getId()

Retrieves the ID for this message. It should be unique

Returns:

The ID for this message.

getContent

public byte[] getContent()

Retrieves the content of the message

Returns:

The content of the message

equals

public boolean equals(java.lang.Object o)

Verifies if two TOMMessage are equal. For performance reasons, the method only verifies if the send and sequence are equal. Two TOMMessage are equal if they have the same sender, sequence number and content.

Overrides:

equals in class java.lang.Object

hashCode

public int hashCode()

Overrides:

hashCode in class java.lang.Object

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

wExternal

public void wExternal(java.io.DataOutput out)
               throws java.io.IOException

Throws:

java.io.IOException

rExternal

public void rExternal(java.io.DataInput in)
               throws java.io.IOException,
                      java.lang.ClassNotFoundException

Throws:

java.io.IOException

java.lang.ClassNotFoundException

getSenderFromId

public static int getSenderFromId(int id)

Retrieves the process ID of the sender given a message ID

Parameters:

id - Message ID

Returns:

Process ID of the sender

messageToBytes

public static byte[] messageToBytes(TOMMessage m)

bytesToMessage

public static TOMMessage bytesToMessage(byte[] b)

compareTo

public int compareTo(java.lang.Object o)

Specified by:

compareTo in interface java.lang.Comparable

clone

public java.lang.Object clone()
                       throws java.lang.CloneNotSupportedException

Overrides:

clone in class java.lang.Object

Throws:

java.lang.CloneNotSupportedException

getReplyServer

public int getReplyServer()

setReplyServer

public void setReplyServer(int replyServer)