Rice Pastry API

Uses of Interface
rice.p2p.commonapi.rawserialization.InputBuffer

Packages that use InputBuffer
rice.p2p.aggregation   
rice.p2p.aggregation.messaging   
rice.p2p.aggregation.raw   
rice.p2p.commonapi   
rice.p2p.commonapi.rawserialization   
rice.p2p.glacier   
rice.p2p.glacier.v2   
rice.p2p.glacier.v2.messaging   
rice.p2p.multiring   
rice.p2p.multiring.messaging   
rice.p2p.past   
rice.p2p.past.gc   
rice.p2p.past.gc.messaging   
rice.p2p.past.messaging   
rice.p2p.past.rawserialization   
rice.p2p.past.testing   
rice.p2p.replication.messaging   
rice.p2p.scribe   
rice.p2p.scribe.messaging   
rice.p2p.scribe.rawserialization   
rice.p2p.scribe.testing   
rice.p2p.splitstream   
rice.p2p.util   
rice.p2p.util.rawserialization   
rice.pastry   
rice.pastry.commonapi   
rice.pastry.direct   
rice.pastry.join   
rice.pastry.leafset   
rice.pastry.messaging   
rice.pastry.routing   
rice.pastry.socket   
rice.pastry.socket.messaging   
rice.pastry.standard   
rice.tutorial.rawserialization   
 

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)
          Typical implementation: 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)
          Deserializing constructor.
 


Rice Pastry API

Copyright © 2001-2005 - Rice Pastry.


Imprint-Dataprotection