|
Rice Pastry API | |||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||
| Uses of InputBuffer in rice.p2p.aggregation |
|---|
| Constructors in rice.p2p.aggregation with parameters of type InputBuffer | |
|---|---|
AggregateHandle(InputBuffer buf,
Endpoint endpoint)
|
|
| Uses of InputBuffer in rice.p2p.aggregation.messaging |
|---|
| Constructors in rice.p2p.aggregation.messaging with parameters of type InputBuffer | |
|---|---|
NonAggregate(InputBuffer buf,
Endpoint endpoint,
RawPastContent subContent,
PastContentDeserializer pcd)
|
|
| Uses of InputBuffer in rice.p2p.aggregation.raw |
|---|
| Constructors in rice.p2p.aggregation.raw with parameters of type InputBuffer | |
|---|---|
RawAggregate(InputBuffer buf,
Endpoint endpoint,
PastContentDeserializer contentDeserializer)
|
|
| Uses of InputBuffer in rice.p2p.commonapi |
|---|
| Methods in rice.p2p.commonapi with parameters of type InputBuffer | |
|---|---|
Id |
Endpoint.readId(InputBuffer buf,
short type)
To use a more efficient serialization format than Java Serialization |
IdRange |
Endpoint.readIdRange(InputBuffer buf)
To use Raw Serialization |
NodeHandleSet |
Endpoint.readNodeHandleSet(InputBuffer buf,
short type)
|
| Uses of InputBuffer in rice.p2p.commonapi.rawserialization |
|---|
| Methods in rice.p2p.commonapi.rawserialization with parameters of type InputBuffer | |
|---|---|
Message |
MessageDeserializer.deserialize(InputBuffer buf,
short type,
int priority,
NodeHandle sender)
RawMessage ret = super.deserialize(); if (ret != null) return ret; Endpoint endpoint; switch(type) { case 1: return new MyMessage(buf, endpoint); } |
NodeHandle |
NodeHandleReader.readNodeHandle(InputBuffer buf)
To use Raw Serialization |
| Uses of InputBuffer in rice.p2p.glacier |
|---|
| Methods in rice.p2p.glacier with parameters of type InputBuffer | |
|---|---|
void |
FragmentKeyRange.FragmentKeyRange(InputBuffer buf,
Endpoint endpoint)
|
void |
VersionKeyRange.VersionKeyRange(InputBuffer buf,
Endpoint endpoint)
|
| Constructors in rice.p2p.glacier with parameters of type InputBuffer | |
|---|---|
Fragment(InputBuffer buf)
|
|
FragmentKey(InputBuffer buf,
Endpoint endpoint)
|
|
VersionKey(InputBuffer buf,
Endpoint endpoint)
|
|
| Uses of InputBuffer in rice.p2p.glacier.v2 |
|---|
| Constructors in rice.p2p.glacier.v2 with parameters of type InputBuffer | |
|---|---|
BloomFilter(InputBuffer buf)
|
|
Manifest(InputBuffer buf)
|
|
| Uses of InputBuffer in rice.p2p.glacier.v2.messaging |
|---|
| Methods in rice.p2p.glacier.v2.messaging with parameters of type InputBuffer | |
|---|---|
static GlacierDataMessage |
GlacierDataMessage.build(InputBuffer buf,
Endpoint endpoint)
|
static GlacierFetchMessage |
GlacierFetchMessage.build(InputBuffer buf,
Endpoint endpoint)
|
static GlacierNeighborRequestMessage |
GlacierNeighborRequestMessage.build(InputBuffer buf,
Endpoint endpoint)
|
static GlacierNeighborResponseMessage |
GlacierNeighborResponseMessage.build(InputBuffer buf,
Endpoint endpoint)
|
static GlacierQueryMessage |
GlacierQueryMessage.build(InputBuffer buf,
Endpoint endpoint)
|
static GlacierRangeForwardMessage |
GlacierRangeForwardMessage.build(InputBuffer buf,
Endpoint endpoint)
|
static GlacierRangeQueryMessage |
GlacierRangeQueryMessage.build(InputBuffer buf,
Endpoint endpoint)
|
static GlacierRangeResponseMessage |
GlacierRangeResponseMessage.build(InputBuffer buf,
Endpoint endpoint)
|
static GlacierRefreshCompleteMessage |
GlacierRefreshCompleteMessage.build(InputBuffer buf,
Endpoint endpoint)
|
static GlacierRefreshPatchMessage |
GlacierRefreshPatchMessage.build(InputBuffer buf,
Endpoint endpoint)
|
static GlacierRefreshProbeMessage |
GlacierRefreshProbeMessage.build(InputBuffer buf,
Endpoint endpoint)
|
static GlacierRefreshResponseMessage |
GlacierRefreshResponseMessage.build(InputBuffer buf,
Endpoint endpoint)
|
static GlacierResponseMessage |
GlacierResponseMessage.build(InputBuffer buf,
Endpoint endpoint)
|
static GlacierSyncMessage |
GlacierSyncMessage.build(InputBuffer buf,
Endpoint endpoint)
|
| Constructors in rice.p2p.glacier.v2.messaging with parameters of type InputBuffer | |
|---|---|
GlacierMessage(InputBuffer buf,
Endpoint endpoint)
|
|
| Uses of InputBuffer in rice.p2p.multiring |
|---|
| Methods in rice.p2p.multiring with parameters of type InputBuffer | |
|---|---|
Id |
MultiringEndpoint.readId(InputBuffer buf,
short type)
|
IdRange |
MultiringEndpoint.readIdRange(InputBuffer buf)
|
NodeHandle |
MultiringEndpoint.readNodeHandle(InputBuffer buf)
|
NodeHandleSet |
MultiringEndpoint.readNodeHandleSet(InputBuffer buf,
short type)
|
| Constructors in rice.p2p.multiring with parameters of type InputBuffer | |
|---|---|
MultiringIdRange(InputBuffer buf,
Endpoint endpoint)
|
|
MultiringNodeHandle(InputBuffer buf,
Endpoint endpoint)
|
|
MultiringNodeHandleSet(InputBuffer buf,
Endpoint endpoint)
|
|
RingId(InputBuffer buf,
Endpoint endpoint)
|
|
| Uses of InputBuffer in rice.p2p.multiring.messaging |
|---|
| Constructors in rice.p2p.multiring.messaging with parameters of type InputBuffer | |
|---|---|
RingMessage(InputBuffer buf,
Endpoint ringEndpoint,
java.util.Hashtable endpoints)
TODO: This can probably be done more efficiently, IE, deserialize the message on getMessage(). |
|
| Uses of InputBuffer in rice.p2p.past |
|---|
| Methods in rice.p2p.past with parameters of type InputBuffer | |
|---|---|
Message |
PastImpl.PastDeserializer.deserialize(InputBuffer buf,
short type,
int priority,
NodeHandle sender)
|
| Constructors in rice.p2p.past with parameters of type InputBuffer | |
|---|---|
ContentHashPastContentHandle(InputBuffer buf,
Endpoint endpoint)
|
|
| Uses of InputBuffer in rice.p2p.past.gc |
|---|
| Methods in rice.p2p.past.gc with parameters of type InputBuffer | |
|---|---|
Message |
GCPastImpl.GCPastDeserializer.deserialize(InputBuffer buf,
short type,
int priority,
NodeHandle sender)
|
Id |
GCEndpoint.readId(InputBuffer buf,
short type)
|
IdRange |
GCEndpoint.readIdRange(InputBuffer buf)
|
NodeHandle |
GCEndpoint.readNodeHandle(InputBuffer buf)
|
NodeHandleSet |
GCEndpoint.readNodeHandleSet(InputBuffer buf,
short type)
|
| Constructors in rice.p2p.past.gc with parameters of type InputBuffer | |
|---|---|
GCId(InputBuffer buf,
Endpoint endpoint)
|
|
GCIdRange(InputBuffer buf,
Endpoint endpoint)
|
|
| Uses of InputBuffer in rice.p2p.past.gc.messaging |
|---|
| Methods in rice.p2p.past.gc.messaging with parameters of type InputBuffer | |
|---|---|
static GCRefreshMessage |
GCRefreshMessage.build(InputBuffer buf,
Endpoint endpoint)
|
static GCLookupHandlesMessage |
GCLookupHandlesMessage.buildGC(InputBuffer buf,
Endpoint endpoint)
|
static GCInsertMessage |
GCInsertMessage.buildGC(InputBuffer buf,
Endpoint endpoint,
PastContentDeserializer pcd)
|
| Uses of InputBuffer in rice.p2p.past.messaging |
|---|
| Methods in rice.p2p.past.messaging with parameters of type InputBuffer | |
|---|---|
static LookupHandlesMessage |
LookupHandlesMessage.build(InputBuffer buf,
Endpoint endpoint)
|
static CacheMessage |
CacheMessage.build(InputBuffer buf,
Endpoint endpoint,
PastContentDeserializer pcd)
|
static InsertMessage |
InsertMessage.build(InputBuffer buf,
Endpoint endpoint,
PastContentDeserializer pcd)
|
static LookupMessage |
LookupMessage.build(InputBuffer buf,
Endpoint endpoint,
PastContentDeserializer pcd)
|
static FetchMessage |
FetchMessage.build(InputBuffer buf,
Endpoint endpoint,
PastContentDeserializer pcd,
PastContentHandleDeserializer pchd)
|
static FetchHandleMessage |
FetchHandleMessage.build(InputBuffer buf,
Endpoint endpoint,
PastContentHandleDeserializer pchd)
|
void |
ContinuationMessage.deserialize(InputBuffer buf,
Endpoint endpoint)
|
| Constructors in rice.p2p.past.messaging with parameters of type InputBuffer | |
|---|---|
ContinuationMessage(InputBuffer buf,
Endpoint endpoint)
The serialization stategy is that usually the subtype will have an optimal serialization strategy, but sometimes we will have to revert to java serialization |
|
InsertMessage(InputBuffer buf,
Endpoint endpoint,
PastContentDeserializer pcd)
|
|
LookupHandlesMessage(InputBuffer buf,
Endpoint endpoint)
|
|
PastMessage(InputBuffer buf,
Endpoint endpoint)
|
|
| Uses of InputBuffer in rice.p2p.past.rawserialization |
|---|
| Methods in rice.p2p.past.rawserialization with parameters of type InputBuffer | |
|---|---|
PastContent |
JavaPastContentDeserializer.deserializePastContent(InputBuffer buf,
Endpoint endpoint,
short contentType)
|
PastContent |
PastContentDeserializer.deserializePastContent(InputBuffer buf,
Endpoint endpoint,
short contentType)
|
PastContentHandle |
JavaPastContentHandleDeserializer.deserializePastContentHandle(InputBuffer buf,
Endpoint endpoint,
short contentType)
|
PastContentHandle |
PastContentHandleDeserializer.deserializePastContentHandle(InputBuffer buf,
Endpoint endpoint,
short contentType)
|
| Uses of InputBuffer in rice.p2p.past.testing |
|---|
| Constructors in rice.p2p.past.testing with parameters of type InputBuffer | |
|---|---|
RawPastRegrTest.NonOverwritingTestPastContent(InputBuffer buf,
Endpoint endpoint,
PastContentDeserializer pcd)
|
|
RawPastRegrTest.TestPastContent(InputBuffer buf,
Endpoint endpoint,
PastContentDeserializer pcd)
|
|
RawPastRegrTest.TestPastContentHandle(InputBuffer buf,
Endpoint endpoint)
|
|
RawPastRegrTest.VersionedTestPastContent(InputBuffer buf,
Endpoint endpoint,
PastContentDeserializer pcd)
|
|
| Uses of InputBuffer in rice.p2p.replication.messaging |
|---|
| Methods in rice.p2p.replication.messaging with parameters of type InputBuffer | |
|---|---|
static RequestMessage |
RequestMessage.build(InputBuffer buf,
Endpoint endpoint)
|
static ResponseMessage |
ResponseMessage.build(InputBuffer buf,
Endpoint endpoint)
|
| Constructors in rice.p2p.replication.messaging with parameters of type InputBuffer | |
|---|---|
ReplicationMessage(InputBuffer buf,
Endpoint endpoint)
|
|
| Uses of InputBuffer in rice.p2p.scribe |
|---|
| Constructors in rice.p2p.scribe with parameters of type InputBuffer | |
|---|---|
Topic(InputBuffer buf,
Endpoint endpoint)
|
|
| Uses of InputBuffer in rice.p2p.scribe.messaging |
|---|
| Methods in rice.p2p.scribe.messaging with parameters of type InputBuffer | |
|---|---|
static DropMessage |
DropMessage.build(InputBuffer buf,
Endpoint endpoint)
|
static SubscribeAckMessage |
SubscribeAckMessage.build(InputBuffer buf,
Endpoint endpoint)
|
static SubscribeFailedMessage |
SubscribeFailedMessage.build(InputBuffer buf,
Endpoint endpoint)
|
static UnsubscribeMessage |
UnsubscribeMessage.build(InputBuffer buf,
Endpoint endpoint)
|
static AnycastMessage |
AnycastMessage.build(InputBuffer buf,
Endpoint endpoint,
ScribeContentDeserializer scd)
|
static PublishMessage |
PublishMessage.build(InputBuffer buf,
Endpoint endpoint,
ScribeContentDeserializer scd)
|
static PublishRequestMessage |
PublishRequestMessage.build(InputBuffer buf,
Endpoint endpoint,
ScribeContentDeserializer scd)
|
static SubscribeMessage |
SubscribeMessage.buildSM(InputBuffer buf,
Endpoint endpoint,
ScribeContentDeserializer scd)
|
| Constructors in rice.p2p.scribe.messaging with parameters of type InputBuffer | |
|---|---|
AbstractSubscribeMessage(InputBuffer buf,
Endpoint endpoint)
Protected because it should only be called from an extending class, to get version numbers correct. |
|
AnycastMessage(InputBuffer buf,
Endpoint endpoint,
ScribeContentDeserializer cd)
Protected because it should only be called from an extending class, to get version numbers correct. |
|
ScribeMessage(InputBuffer buf,
Endpoint endpoint)
Protected because it should only be called from an extending class, to get version numbers correct. |
|
| Uses of InputBuffer in rice.p2p.scribe.rawserialization |
|---|
| Methods in rice.p2p.scribe.rawserialization with parameters of type InputBuffer | |
|---|---|
ScribeContent |
JavaScribeContentDeserializer.deserializeScribeContent(InputBuffer buf,
Endpoint endpoint,
short contentType)
|
ScribeContent |
ScribeContentDeserializer.deserializeScribeContent(InputBuffer buf,
Endpoint endpoint,
short contentType)
|
| Uses of InputBuffer in rice.p2p.scribe.testing |
|---|
| Constructors in rice.p2p.scribe.testing with parameters of type InputBuffer | |
|---|---|
RawScribeRegrTest.TestScribeContent(InputBuffer buf,
Endpoint endpoint)
|
|
| Uses of InputBuffer in rice.p2p.splitstream |
|---|
| Constructors in rice.p2p.splitstream with parameters of type InputBuffer | |
|---|---|
SplitStreamContent(InputBuffer buf)
|
|
SplitStreamSubscribeContent(InputBuffer buf)
|
|
| Uses of InputBuffer in rice.p2p.util |
|---|
| Constructors in rice.p2p.util with parameters of type InputBuffer | |
|---|---|
BloomFilter(InputBuffer buf)
|
|
IdBloomFilter(InputBuffer buf)
|
|
| Uses of InputBuffer in rice.p2p.util.rawserialization |
|---|
| Classes in rice.p2p.util.rawserialization that implement InputBuffer | |
|---|---|
class |
SimpleInputBuffer
|
| Methods in rice.p2p.util.rawserialization with parameters of type InputBuffer | |
|---|---|
Message |
JavaSerializedDeserializer.deserialize(InputBuffer buf,
short type,
int priority,
NodeHandle sender)
|
| Uses of InputBuffer in rice.pastry |
|---|
| Methods in rice.pastry with parameters of type InputBuffer | |
|---|---|
static Id |
Id.build(InputBuffer buf)
Id (Version 0) +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+ + 160 Bit + + + + + + + + + +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+ |
NodeHandle |
NodeHandleFactory.readNodeHandle(InputBuffer buf)
|
| Constructors in rice.pastry with parameters of type InputBuffer | |
|---|---|
IdRange(InputBuffer buf)
|
|
NodeSet(InputBuffer buf,
NodeHandleFactory nhf)
|
|
| Uses of InputBuffer in rice.pastry.commonapi |
|---|
| Methods in rice.pastry.commonapi with parameters of type InputBuffer | |
|---|---|
Id |
PastryEndpoint.readId(InputBuffer buf,
short type)
|
IdRange |
PastryEndpoint.readIdRange(InputBuffer buf)
|
NodeHandle |
PastryEndpoint.readNodeHandle(InputBuffer buf)
|
NodeHandleSet |
PastryEndpoint.readNodeHandleSet(InputBuffer buf,
short type)
|
| Constructors in rice.pastry.commonapi with parameters of type InputBuffer | |
|---|---|
PastryEndpointMessage(int address,
InputBuffer buf,
MessageDeserializer md,
NodeHandle sender)
|
|
| Uses of InputBuffer in rice.pastry.direct |
|---|
| Methods in rice.pastry.direct with parameters of type InputBuffer | |
|---|---|
NodeHandle |
DirectPastryNode.readNodeHandle(InputBuffer buf)
|
| Uses of InputBuffer in rice.pastry.join |
|---|
| Constructors in rice.pastry.join with parameters of type InputBuffer | |
|---|---|
JoinRequest(InputBuffer buf,
NodeHandleFactory nhf,
NodeHandle sender,
PastryNode localNode)
|
|
| Uses of InputBuffer in rice.pastry.leafset |
|---|
| Methods in rice.pastry.leafset with parameters of type InputBuffer | |
|---|---|
static LeafSet |
LeafSet.build(InputBuffer buf,
NodeHandleFactory nhf)
So that small LeafSets (who have overlapping nodes) don't waste bandwidth, leafset first defines the NodeHandles to be loaded into an array, then specifies their locations. |
| Constructors in rice.pastry.leafset with parameters of type InputBuffer | |
|---|---|
BroadcastLeafSet(InputBuffer buf,
NodeHandleFactory nhf)
|
|
RequestLeafSet(NodeHandle sender,
InputBuffer buf)
|
|
| Uses of InputBuffer in rice.pastry.messaging |
|---|
| Methods in rice.pastry.messaging with parameters of type InputBuffer | |
|---|---|
RawMessageDelivery |
RawMessageDeliveryFactory.build(InputBuffer buf)
|
Message |
JavaSerializedDeserializer.deserialize(InputBuffer buf,
short type,
int priority,
NodeHandle sender)
|
abstract Message |
PJavaSerializedDeserializer.deserialize(InputBuffer buf,
short type,
int priority,
NodeHandle sender)
|
Message |
PJavaSerializedDeserializer.deserialize(InputBuffer buf,
short type,
int priority,
NodeHandle sender)
|
| Uses of InputBuffer in rice.pastry.routing |
|---|
| Methods in rice.pastry.routing with parameters of type InputBuffer | |
|---|---|
static RouteMessage |
RouteMessage.build(InputBuffer buf,
NodeHandleFactory nhf,
PastryNode pn)
+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+ + int auxAddress + +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+ + Id target + + + + + + + + + +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+ + NodeHandle prev + + (used to repair routing table during routing) + + + ... |
| Constructors in rice.pastry.routing with parameters of type InputBuffer | |
|---|---|
BroadcastRouteRow(InputBuffer buf,
NodeHandleFactory nhf,
PastryNode localNode)
|
|
RequestRouteRow(NodeHandle sender,
InputBuffer buf)
|
|
RouteMessage(Id target,
int auxAddress,
NodeHandle prev,
InputBuffer buf,
NodeHandleFactory nhf,
PastryNode pn)
|
|
RouteSet(InputBuffer buf,
NodeHandleFactory nhf,
PastryNode local)
|
|
| Uses of InputBuffer in rice.pastry.socket |
|---|
| Methods in rice.pastry.socket with parameters of type InputBuffer | |
|---|---|
static EpochInetSocketAddress |
EpochInetSocketAddress.build(InputBuffer buf)
EpochInetSocketAddress: (IPV4): +-+-+-+-+-+-+-+-+ + numAddrs + +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+ + internet address 0 + +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+ + port 0 + +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+ + internet address 1 + +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+ + port 1 + +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+ + internet address k + +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+ + port k + ... |
static SourceRoute |
SourceRoute.build(InputBuffer buf)
|
NodeHandle |
SocketPastryNode.readNodeHandle(InputBuffer buf)
|
| Uses of InputBuffer in rice.pastry.socket.messaging |
|---|
| Constructors in rice.pastry.socket.messaging with parameters of type InputBuffer | |
|---|---|
DatagramMessage(InputBuffer buf)
|
|
IPAddressRequestMessage(InputBuffer buf)
|
|
IPAddressResponseMessage(InputBuffer buf)
|
|
LeafSetResponseMessage(InputBuffer buf,
NodeHandleFactory nhf)
|
|
NodeIdResponseMessage(InputBuffer buf)
|
|
PingMessage(InputBuffer buf)
|
|
PingResponseMessage(InputBuffer buf)
|
|
RouteRowResponseMessage(InputBuffer buf,
NodeHandleFactory nhf,
PastryNode localNode)
|
|
RoutesResponseMessage(InputBuffer buf)
|
|
WrongEpochMessage(InputBuffer buf)
|
|
| Uses of InputBuffer in rice.pastry.standard |
|---|
| Methods in rice.pastry.standard with parameters of type InputBuffer | |
|---|---|
Message |
PeriodicLeafSetProtocol.PLSPMessageDeserializer.deserialize(InputBuffer buf,
short type,
int priority,
NodeHandle sender)
|
| Constructors in rice.pastry.standard with parameters of type InputBuffer | |
|---|---|
ConsistentJoinMsg(InputBuffer buf,
NodeHandleFactory nhf,
NodeHandle sender)
|
|
| Uses of InputBuffer in rice.tutorial.rawserialization |
|---|
| Constructors in rice.tutorial.rawserialization with parameters of type InputBuffer | |
|---|---|
MyMsg(InputBuffer buf,
Endpoint endpoint)
|
|
|
Rice Pastry API | |||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||