ostore.apps.qtree.impl
Class QTreeUpMsg

java.lang.Object
  |
  +--ostore.network.NetworkMessage
        |
        +--ostore.apps.qtree.impl.QTreeUpMsg

All Implemented Interfaces:

Cloneable, QueueElementIF, QuickSerializable

public class QTreeUpMsg

extends NetworkMessage

This is the intermediary message sent between QTree nodes to pass back [aggregated] results to the root. The data is stored in a QTreeFwd. Stages directly listen for this message. However, if not to be agggregated, QTree will dispatch the message towards the next hop. user_data() code taken from RouteMsg.

Author:

Jason Lee

Field Summary

protected QuickSerializable	_user_data
protected InputBuffer	_user_data_buffer
protected int	_user_data_length
protected boolean	aggregated
long	id
NodeId	source
protected SecureHash	treeId

Fields inherited from class ostore.network.NetworkMessage

comp_q, est_rtt_ms, inbound, peer, sender, tries, user_data, wait_ms

Constructor Summary

QTreeUpMsg(InputBuffer buffer)

QTreeUpMsg(NodeId peer, boolean inbound, QuickSerializable user_data, boolean aggregated, SecureHash treeId, long id, NodeId source)

Method Summary

boolean	automaticFwd()
boolean	equals(Object o)
SecureHash	getTreeId()
int	hashCode()
void	serialize(OutputBuffer buffer) Add the object to the buffer.
void	setTreeId(SecureHash treeId)
String	toString()
QuickSerializable	user_data()

Methods inherited from class ostore.network.NetworkMessage

clone

Methods inherited from class java.lang.Object

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

Field Detail

_user_data

protected QuickSerializable _user_data

_user_data_length

protected int _user_data_length

_user_data_buffer

protected InputBuffer _user_data_buffer

aggregated

protected boolean aggregated

id

public long id

treeId

protected SecureHash treeId

source

public NodeId source

Constructor Detail

QTreeUpMsg

public QTreeUpMsg(NodeId peer,
                  boolean inbound,
                  QuickSerializable user_data,
                  boolean aggregated,
                  SecureHash treeId,
                  long id,
                  NodeId source)

QTreeUpMsg

public QTreeUpMsg(InputBuffer buffer)
           throws QSException

Method Detail

user_data

public QuickSerializable user_data()
                            throws QSException

QSException

serialize

public void serialize(OutputBuffer buffer)

Description copied from interface: QuickSerializable

Add the object to the buffer.

Specified by:

serialize in interface QuickSerializable

Overrides:

serialize in class NetworkMessage

Parameters:

buffer - the output buffer to add the object to

toString

public String toString()

Overrides:

toString in class NetworkMessage

getTreeId

public SecureHash getTreeId()

setTreeId

public void setTreeId(SecureHash treeId)

automaticFwd

public boolean automaticFwd()

hashCode

public int hashCode()

Overrides:

hashCode in class Object

equals

public boolean equals(Object o)

Overrides:

equals in class Object