Serialized Form
Package rice.p2p.commonapi |
myId
Id myId
storageNode
NodeHandle storageNode
myId
Id myId
Package rice.p2p.past.messaging |
content
PastContent content
response
java.lang.Object response
exception
java.lang.Exception exception
id
Id id
handle
PastContentHandle handle
cached
boolean cached
content
PastContent content
id
Id id
max
int max
id
Id id
cached
boolean cached
handle
NodeHandle handle
id
int id
source
NodeHandle source
dest
Id dest
isResponse
boolean isResponse
Package rice.p2p.past.testing |
id
Id id
existing
PastContent existing
handle
NodeHandle handle
id
Id id
id
Id id
nextHop
NodeHandle nextHop
message
Message message
version
int version
Package rice.p2p.replication.manager.messaging |
uid
int uid
- THe unique id of this message
Package rice.p2p.replication.messaging |
source
NodeHandle source
ranges
IdRange[] ranges
hashes
Id[] hashes
ids
IdSet ids
id
Id id
- The Id to which this topic is mapped
Package rice.p2p.scribe.messaging |
id
int id
- The id of this subscribe message
content
ScribeContent content
- the content of this message
visited
java.util.Vector visited
- the list of nodes which we have visited
toVisit
java.util.LinkedList toVisit
- the list of nodes which we are going to visit
content
ScribeContent content
content
ScribeContent content
source
NodeHandle source
topic
Topic topic
pathToRoot
Id[] pathToRoot
- The contained path to the root
subscriber
NodeHandle subscriber
- The original subscriber
previousParent
Id previousParent
- The previous parent
id
int id
- The id of this message
Package rice.p2p.scribe.testing |
id
Id id
nextHop
NodeHandle nextHop
message
Message message
topic
Topic topic
- DESCRIBE THE FIELD
num
int num
- DESCRIBE THE FIELD
Package rice.p2p.splitstream |
data
byte[] data
- The internal data - just the bytes
stage
int stage
- The stage that the client attempting to join is in
Package rice.past.messaging |
_exists
boolean _exists
- Deprecated.
- Content to be returned
_content
java.io.Serializable _content
- Deprecated.
- Content to be returned
_file
java.io.Serializable _file
- Deprecated.
- The file to insert.
_success
boolean _success
- Deprecated.
- Whether the insert was successful (on a response).
_content
java.io.Serializable _content
- Deprecated.
- Content to be returned
_success
boolean _success
- Deprecated.
- Whether the reclaim request was successful
_messageID
PASTMessageID _messageID
- Deprecated.
- A key for uniquely identifying the message.
_messageType
int _messageType
- Deprecated.
- Whether this is a request or a response.
_fileId
Id _fileId
- Deprecated.
- The fileId of the file, to be used as destination.
_senderId
Id _senderId
- Deprecated.
- The id of the sender
_idCode
java.lang.Long _idCode
- Deprecated.
- Internally, the ID is represented by a
Long.
Package rice.past.testing |
Id
int[] Id
difference
int[] difference
empty
boolean empty
ccw
Id ccw
cw
Id cw
idSet
java.util.TreeSet idSet
cachedHash
Id cachedHash
validHash
boolean validHash
readObject
private void readObject(java.io.ObjectInputStream in)
throws java.io.IOException,
java.lang.ClassNotFoundException
- Called on deserialization. Adds itself to a pending-setLocalNode
list. This list is in a static (global) hash, indexed by the
ObjectInputStream. Refer to README.handles_localnode for details.
readObject
private void readObject(java.io.ObjectInputStream in)
throws java.io.IOException,
java.lang.ClassNotFoundException
- Called on deserialization. Adds itself to a pending-setLocalNode
list. This list is in a static (global) hash, indexed by the
ObjectInputStream. Refer to README.handles_localnode for details.
set
java.util.Vector set
Package rice.pastry.commonapi |
message
Message message
Package rice.pastry.direct |
remoteNode
PastryNode remoteNode
simulator
NetworkSimulator simulator
readObject
private void readObject(java.io.ObjectInputStream ois)
throws java.io.IOException,
java.lang.ClassNotFoundException
- Overridden in order to restore default values for all of the
variables concerning node distance, status, etc...
nodeId
NodeId nodeId
address
java.net.InetSocketAddress address
handle
NodeHandle handle
readObject
private void readObject(java.io.ObjectInputStream in)
throws java.io.IOException,
java.lang.ClassNotFoundException
writeObject
private void writeObject(java.io.ObjectOutputStream out)
throws java.io.IOException,
java.lang.ClassNotFoundException
handle
NodeHandle handle
joinHandle
NodeHandle joinHandle
rowCount
int rowCount
rows
RouteSet[][] rows
leafSet
LeafSet leafSet
Package rice.pastry.leafset |
fromNode
NodeHandle fromNode
theLeafSet
LeafSet theLeafSet
theType
int theType
baseId
NodeId baseId
baseHandle
NodeHandle baseHandle
cwSet
SimilarSet cwSet
ccwSet
SimilarSet ccwSet
theSize
int theSize
readObject
private void readObject(java.io.ObjectInputStream in)
throws java.io.IOException,
java.lang.ClassNotFoundException
writeObject
private void writeObject(java.io.ObjectOutputStream out)
throws java.io.IOException,
java.lang.ClassNotFoundException
handle
NodeHandle handle
ln
NodeHandle ln
clockwise
boolean clockwise
nodes
NodeHandle[] nodes
theSize
int theSize
Package rice.pastry.messaging |
readObject
private void readObject(java.io.ObjectInputStream in)
throws java.io.IOException,
java.lang.ClassNotFoundException
destination
Address destination
senderId
NodeId senderId
priority
boolean priority
readObject
private void readObject(java.io.ObjectInputStream in)
throws java.io.IOException,
java.lang.ClassNotFoundException
writeObject
private void writeObject(java.io.ObjectOutputStream out)
throws java.io.IOException,
java.lang.ClassNotFoundException
remoteNode
RMIRemoteNodeI remoteNode
Package rice.pastry.routing |
fromNode
NodeHandle fromNode
row
RouteSet[] row
handle
NodeHandle handle
row
int row
target
Id target
internalMsg
Message internalMsg
prevNode
NodeHandle prevNode
auxAddress
Address auxAddress
readObject
private void readObject(java.io.ObjectInputStream in)
throws java.io.IOException,
java.lang.ClassNotFoundException
writeObject
private void writeObject(java.io.ObjectOutputStream out)
throws java.io.IOException,
java.lang.ClassNotFoundException
readObject
private void readObject(java.io.ObjectInputStream in)
throws java.io.IOException,
java.lang.ClassNotFoundException
writeObject
private void writeObject(java.io.ObjectOutputStream out)
throws java.io.IOException,
java.lang.ClassNotFoundException
readObject
private void readObject(java.io.ObjectInputStream in)
throws java.io.IOException,
java.lang.ClassNotFoundException
- deserialize the routeSet
pings the handle the was the closests on the sending node
writeObject
private void writeObject(java.io.ObjectOutputStream out)
throws java.io.IOException,
java.lang.ClassNotFoundException
- serialize the RouteSet
records the closest node
nodes
NodeHandle[] nodes
theSize
int theSize
closest
int closest
readObject
private void readObject(java.io.ObjectInputStream in)
throws java.io.IOException,
java.lang.ClassNotFoundException
writeObject
private void writeObject(java.io.ObjectOutputStream out)
throws java.io.IOException,
java.lang.ClassNotFoundException
random
boolean random
noShortCuts
boolean noShortCuts
shortestPath
boolean shortestPath
allowMultipleHops
boolean allowMultipleHops
Package rice.pastry.security |
Package rice.pastry.standard |
myCode
int myCode
name
java.lang.String name
Package rice.pastry.testing |
source
NodeId source
target
Id target
actualReceiver
NodeId actualReceiver
msgid
int msgid
id
NodeId id
myCode
int myCode
source
NodeId source
target
NodeId target
nHops
int nHops
fDistance
double fDistance
readObject
private void readObject(java.io.ObjectInputStream ois)
throws java.io.IOException,
java.lang.ClassNotFoundException
- Overridden in order to specify the default state (using UDP)
- Throws:
java.io.IOException
- DESCRIBE THE EXCEPTION
java.lang.ClassNotFoundException
- DESCRIBE THE EXCEPTION
Package rice.pastry.wire.exception |
originalException
java.lang.Exception originalException
- The original reason we found the node to be dead.
Package rice.pastry.wire.messaging.datagram |
address
java.net.InetSocketAddress address
num
int num
- DESCRIBE THE FIELD
source
NodeId source
- DESCRIBE THE FIELD
destination
NodeId destination
- DESCRIBE THE FIELD
o
java.lang.Object o
writeObject
private void writeObject(java.io.ObjectOutputStream oos)
throws java.io.IOException
- DESCRIBE THE METHOD
- Throws:
java.io.IOException
- DESCRIBE THE EXCEPTION
Package rice.pastry.wire.messaging.socket |
address
java.net.InetSocketAddress address
nodeId
NodeId nodeId
dest
NodeId dest
address
java.net.InetSocketAddress address
nodeId
NodeId nodeId
dest
NodeId dest
leafset
LeafSet leafset
nid
NodeId nid
row
int row
- DESCRIBE THE FIELD
set
RouteSet[] set
o
java.lang.Object o
destination
NodeId destination
Package rice.rm.messaging |
_authorCred
Credentials _authorCred
- The credentials of the author for the object contained in this object
_source
NodeHandle _source
- The ID of the source of this message.
Should be serializable.
_seqno
int _seqno
- for debugging purposes only
reqRange
IdRange reqRange
hashEnabled
boolean hashEnabled
keySet
IdSet keySet
hash
Id hash
numKeys
int numKeys
range
IdRange range
- This range is got by the intersection of the reqRange
and the responsible range on the responder side.
rangeSet
java.util.Vector rangeSet
- The list of ranges whose corresponding key sets the issuer of this
message is interested in.
eventId
int eventId
- This is to handle the loss of this type of messages.
(The other kind of messages do not require a Timeout mechanism,
hence they do not have this field).
Specifically, if a Timeout occurred for a RMRequestKeysMsg, then the
subsequent RMRequestKeysMsg that will be resent will have the SAME
eventId but an INCREASED value of seqNo. Also the RMResponseKeysMsg
sent in response to this message will have the SAME eventId.
attempt
int attempt
- In the Timeout mechanism upto MAXATTEMPTS will be made.
This represents the number of attempts made so far.
rangeSet
java.util.Vector rangeSet
- The list of ranges whose corresponding key sets the issuer of its
corresponding RMRequestKeysMsg message was interested in, except with
the difference that the ranges in this list are a result of the
intersection of the ranges requested for and 'myRange' of the responder.
eventId
int eventId
- Event Id of the RMRequestKeysMsg to which this is a response.
wmsg
RMRequestKeysMsg.WrappedMsg wmsg
objectKey
Id objectKey
objectKey
Id objectKey
object
java.lang.Object object
- The object that needs to be inserted.
objectKey
Id objectKey
objectKey
Id objectKey
objectKey
Id objectKey
replicaSet
NodeSet replicaSet
objectKey
Id objectKey
objectKey
Id objectKey
_authorCred
Credentials _authorCred
- The credentials of the author for the object contained in this object
_source
NodeHandle _source
- The ID of the source of this message.
Should be serializable.
Package rice.scribe.maintenance |
Package rice.scribe.messaging |
send_to
java.util.Vector send_to
- Holds the list of NodeHandles to send to (used for DFS)
already_seen
java.util.Vector already_seen
- Holds the list of NodeHandles already examined (used for DFS)
c
Credentials c
- Credentials
m_data
java.io.Serializable m_data
- This is the information inside the message.
Should be serializable.
m_topicId
NodeId m_topicId
- The ID of the topic that this message refers to.
Should be serializable.
m_source
NodeHandle m_source
- The ID of the source of this message.
Should be serializable.
Package rice.scribe.testing |