|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object | +--ostore.network.NetworkMessage | +--dd.directmail.impl.DirectMailMsg
DirectMailMsg
is a
message
sent out and forwarded by the
DirectMailStage
as a type of multicast msg
that will efficiently deliver the msg
to all the
nodes
in the system.
Field Summary | |
---|---|
int |
currentRadius
currentRadius is the number of hops between the
src node and the local node. |
QSVector |
path
path includes all the nodes that the
DirectMailMsg has visited (i.e. src to local node). |
Fields inherited from class ostore.network.NetworkMessage |
---|
comp_q, est_rtt_ms, inbound, peer, sender, tries, user_data, wait_ms |
Constructor Summary | |
---|---|
DirectMailMsg(DirectMail mail,
NodeId peer,
SecureHash src,
int currentRadius,
int targetRadius,
QSVector path,
long nonce)
Constucts a data-driven server hb message from specified parameters. |
|
DirectMailMsg(InputBuffer buffer)
Constructs a DirectMailMsg from its
serialized form. |
Method Summary | |
---|---|
Object |
clone()
Specified by java.lang.Object |
int |
getCurrentRadius()
getCurrentRadius returns the number of hops between the
src node and the local node. |
DirectMail |
getMail()
getMail returns the mail that is to be delivered
to every node. |
QSVector |
getPath()
getPath returns the path that includes all the
nodes that the DirectMailMsg has visited
(i.e. src to local node). |
SecureHash |
getSrc()
getSrc returns the mail that is to be delivered
to every node. |
int |
getTargetRadius()
getTargetRadius returns the maximum radius for the mail
msg; that is, TTL. |
SecureHash |
getXactId()
getXactId returns xactId of the
DirectMailMsg |
void |
serialize(OutputBuffer buffer)
Specified by ostore.util.QuickSerializable |
String |
toString()
Specified by java.lang.Object |
Methods inherited from class java.lang.Object |
---|
equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Field Detail |
public int currentRadius
currentRadius
is the number of hops between the
src
node and the local node.
public QSVector path
path
includes all the nodes that the
DirectMailMsg
has visited (i.e. src to local node).
Constructor Detail |
public DirectMailMsg(DirectMail mail, NodeId peer, SecureHash src, int currentRadius, int targetRadius, QSVector path, long nonce)
mail
- The mail msg itself to be delivered to each node.peer
- NodeId
of next forward hop.src
- Identifier of the src
node
currentRadius
- number of hops between src peer
node
and local node.targetRadius
- Max radius for heartbeat i.e. TTL.path
- All the nodes that the DirectMailMsg
has visited.nonce
- unique number like a monotonically increasing
number or current time, etc. Used in a
transaction id for msg.public DirectMailMsg(InputBuffer buffer) throws QSException
DirectMailMsg
from its
serialized
form.
buffer
- serialized
form of object.Method Detail |
public void serialize(OutputBuffer buffer)
serialize
in interface QuickSerializable
serialize
in class NetworkMessage
public DirectMail getMail()
getMail
returns the mail that is to be delivered
to every node.
public SecureHash getSrc()
getSrc
returns the mail that is to be delivered
to every node.
public int getTargetRadius()
getTargetRadius
returns the maximum radius for the mail
msg; that is, TTL.
public int getCurrentRadius()
getCurrentRadius
returns the number of hops between the
src
node and the local node.
src
node
and the local node.public SecureHash getXactId()
getXactId
returns xactId
of the
DirectMailMsg
public QSVector getPath()
getPath
returns the path that includes all the
nodes that the DirectMailMsg
has visited
(i.e. src to local node).
path
from src to localnode.public Object clone() throws CloneNotSupportedException
clone
in class NetworkMessage
CloneNotSupportedException
public String toString()
toString
in class NetworkMessage
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |