|
Rice Pastry API | |||||||||
PREV NEXT | FRAMES NO FRAMES |
Uses of InputBuffer in org.mpisws.p2p.pki.x509 |
---|
Methods in org.mpisws.p2p.pki.x509 with parameters of type InputBuffer | |
---|---|
java.security.Key |
KeySerializer.deserialize(InputBuffer buf)
|
java.security.Key |
KeySerializerImpl.deserialize(InputBuffer buf)
|
java.security.cert.X509Certificate |
X509SerializerImpl.deserialize(InputBuffer buf)
|
Uses of InputBuffer in org.mpisws.p2p.testing.transportlayer.replay |
---|
Methods in org.mpisws.p2p.testing.transportlayer.replay with parameters of type InputBuffer | |
---|---|
void |
Replayer.replayEvent(short type,
InputBuffer entry)
|
Uses of InputBuffer in org.mpisws.p2p.transport.commonapi |
---|
Methods in org.mpisws.p2p.transport.commonapi with parameters of type InputBuffer | |
---|---|
Id |
IdFactory.build(InputBuffer buf)
|
RawMessage |
RawMessageDeserializer.deserialize(InputBuffer b,
NodeHandle sender)
|
Uses of InputBuffer in org.mpisws.p2p.transport.identity |
---|
Methods in org.mpisws.p2p.transport.identity with parameters of type InputBuffer | |
---|---|
UpperIdentifier |
IdentitySerializer.deserialize(InputBuffer buf,
LowerIdentifier l)
|
Uses of InputBuffer in org.mpisws.p2p.transport.liveness |
---|
Constructors in org.mpisws.p2p.transport.liveness with parameters of type InputBuffer | |
---|---|
PingMessage(InputBuffer buf)
|
|
PongMessage(InputBuffer buf)
|
Uses of InputBuffer in org.mpisws.p2p.transport.multiaddress |
---|
Methods in org.mpisws.p2p.transport.multiaddress with parameters of type InputBuffer | |
---|---|
static MultiInetSocketAddress |
MultiInetSocketAddress.build(InputBuffer buf)
EpochInetSocketAddress: (IPV4): +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+ + numAddrs + IPVersion 0 + +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+ + internet address 0 ... |
Uses of InputBuffer in org.mpisws.p2p.transport.peerreview |
---|
Methods in org.mpisws.p2p.transport.peerreview with parameters of type InputBuffer | |
---|---|
boolean |
PeerReviewCallback.loadCheckpoint(InputBuffer buffer)
Return false if the checkpoint is bogus. |
Uses of InputBuffer in org.mpisws.p2p.transport.peerreview.audit |
---|
Methods in org.mpisws.p2p.transport.peerreview.audit with parameters of type InputBuffer | |
---|---|
protected static long |
SnippetEntry.decodeSeq(InputBuffer buf,
long prevSeq)
|
int |
SnippetEntry.decodeSize(InputBuffer buf)
|
Constructors in org.mpisws.p2p.transport.peerreview.audit with parameters of type InputBuffer | |
---|---|
LogSnippet(InputBuffer buf,
int hashSize)
|
|
SnippetEntry(InputBuffer buf,
int hashSize,
SnippetEntry prev)
|
|
SnippetEntry(InputBuffer buf,
long seq,
int hashSize)
|
Uses of InputBuffer in org.mpisws.p2p.transport.peerreview.commitment |
---|
Methods in org.mpisws.p2p.transport.peerreview.commitment with parameters of type InputBuffer | |
---|---|
Authenticator |
AuthenticatorSerializer.deserialize(InputBuffer buf)
|
Authenticator |
AuthenticatorSerializerImpl.deserialize(InputBuffer buf)
|
Constructors in org.mpisws.p2p.transport.peerreview.commitment with parameters of type InputBuffer | |
---|---|
Authenticator(InputBuffer buf,
int hashSize,
int signatureSize)
|
Uses of InputBuffer in org.mpisws.p2p.transport.peerreview.evidence |
---|
Methods in org.mpisws.p2p.transport.peerreview.evidence with parameters of type InputBuffer | |
---|---|
Evidence |
EvidenceSerializerImpl.deserialize(InputBuffer buf,
byte type,
boolean response)
|
Constructors in org.mpisws.p2p.transport.peerreview.evidence with parameters of type InputBuffer | |
---|---|
AuditResponse(InputBuffer buf,
Serializer<Handle> serializer,
int hashSize)
|
|
ChallengeAudit(InputBuffer buf,
int hashSize,
int signatureSize)
|
|
ProofInconsistent(InputBuffer buf,
AuthenticatorSerializer serializer,
int hashSize)
|
|
ProofNonconformant(InputBuffer buf,
Serializer<Handle> serializer,
int hashSize,
int signatureSize)
|
Uses of InputBuffer in org.mpisws.p2p.transport.peerreview.history |
---|
Methods in org.mpisws.p2p.transport.peerreview.history with parameters of type InputBuffer | |
---|---|
IndexEntry |
IndexEntryFactory.build(InputBuffer indexFile)
|
IndexEntry |
SecureHistoryFactoryImpl.build(InputBuffer buf)
|
Uses of InputBuffer in org.mpisws.p2p.transport.peerreview.history.logentry |
---|
Constructors in org.mpisws.p2p.transport.peerreview.history.logentry with parameters of type InputBuffer | |
---|---|
EvtAck(InputBuffer buf,
Serializer<Identifier> idSerializer,
int hashSize,
int signatureSize)
|
|
EvtInit(InputBuffer buf,
Serializer<Handle> handleSerializer)
|
|
EvtRecv(InputBuffer buf,
Serializer<Handle> serializer,
int hashSize)
|
|
EvtSend(InputBuffer buf,
Serializer<Identifier> idSerializer,
int hashSize)
|
|
EvtSendSign(InputBuffer buf,
int signatureSize)
|
|
EvtSign(InputBuffer buf,
int hashSize,
int signatureSize)
|
Uses of InputBuffer in org.mpisws.p2p.transport.peerreview.history.stub |
---|
Methods in org.mpisws.p2p.transport.peerreview.history.stub with parameters of type InputBuffer | |
---|---|
byte[] |
NullHashProvider.build(InputBuffer buf)
|
Uses of InputBuffer in org.mpisws.p2p.transport.peerreview.infostore |
---|
Methods in org.mpisws.p2p.transport.peerreview.infostore with parameters of type InputBuffer | |
---|---|
Evidence |
EvidenceSerializer.deserialize(InputBuffer buf,
byte type,
boolean isResponse)
|
Uses of InputBuffer in org.mpisws.p2p.transport.peerreview.message |
---|
Methods in org.mpisws.p2p.transport.peerreview.message with parameters of type InputBuffer | ||
---|---|---|
static
|
UserDataMessage.build(InputBuffer buf,
Serializer<H> serializer,
int hashSize,
int sigSize)
|
|
static
|
AuthPushMessage.build(InputBuffer buf,
Serializer<I> idSerializer,
AuthenticatorSerializer authSerializer)
|
|
static
|
AckMessage.build(InputBuffer sib,
Serializer<Identifier> serializer,
int hashSizeInBytes,
int signatureSizeInBytes)
|
Constructors in org.mpisws.p2p.transport.peerreview.message with parameters of type InputBuffer | |
---|---|
AccusationMessage(InputBuffer buf,
Serializer<Identifier> idSerializer,
EvidenceSerializer evSerializer)
|
|
AuthRequest(InputBuffer buf,
Serializer<Identifier> serializer)
|
|
AuthResponse(InputBuffer buf,
Serializer<Identifier> serializer,
int hashSize,
int signatureSize)
|
|
ChallengeMessage(InputBuffer buf,
Serializer<Identifier> idSerializer,
EvidenceSerializer evidenceSerializer)
|
|
ResponseMessage(InputBuffer buf,
Serializer<Identifier> idSerializer,
EvidenceSerializer evSerializer)
|
Uses of InputBuffer in org.mpisws.p2p.transport.peerreview.replay |
---|
Methods in org.mpisws.p2p.transport.peerreview.replay with parameters of type InputBuffer | |
---|---|
protected java.io.IOException |
VerifierImpl.deserializeException(InputBuffer nextEvent)
|
void |
EventCallback.replayEvent(short type,
InputBuffer entry)
|
Uses of InputBuffer in org.mpisws.p2p.transport.peerreview.replay.playback |
---|
Methods in org.mpisws.p2p.transport.peerreview.replay.playback with parameters of type InputBuffer | |
---|---|
protected java.io.IOException |
ReplayVerifier.deserializeException(InputBuffer nextEvent)
|
Uses of InputBuffer in org.mpisws.p2p.transport.peerreview.statement |
---|
Constructors in org.mpisws.p2p.transport.peerreview.statement with parameters of type InputBuffer | |
---|---|
Statement(InputBuffer buf,
Serializer<Identifier> idSerializer,
EvidenceSerializer evSerializer)
|
Uses of InputBuffer in org.mpisws.p2p.transport.rendezvous |
---|
Methods in org.mpisws.p2p.transport.rendezvous with parameters of type InputBuffer | |
---|---|
HighIdentifier |
ContactDeserializer.deserialize(InputBuffer sib)
|
Uses of InputBuffer in org.mpisws.p2p.transport.simpleidentity |
---|
Methods in org.mpisws.p2p.transport.simpleidentity with parameters of type InputBuffer | |
---|---|
java.net.InetSocketAddress |
InetSocketAddressSerializer.deserialize(InputBuffer buf)
|
Identifier |
Serializer.deserialize(InputBuffer b,
Identifier i,
java.util.Map<java.lang.String,java.lang.Object> options)
|
java.net.InetSocketAddress |
InetSocketAddressSerializer.deserialize(InputBuffer b,
java.net.InetSocketAddress i,
java.util.Map<java.lang.String,java.lang.Object> options)
|
java.net.InetSocketAddress |
PortSerializer.deserialize(InputBuffer b,
java.net.InetSocketAddress i,
java.util.Map<java.lang.String,java.lang.Object> options)
|
static java.net.InetSocketAddress |
InetSocketAddressSerializer.deserializeAddress(InputBuffer b)
|
Uses of InputBuffer in org.mpisws.p2p.transport.sourceroute |
---|
Methods in org.mpisws.p2p.transport.sourceroute with parameters of type InputBuffer | |
---|---|
SourceRoute<Identifier> |
SourceRouteFactory.build(InputBuffer buf,
Identifier local,
Identifier lastHop)
|
Uses of InputBuffer in org.mpisws.p2p.transport.sourceroute.factory |
---|
Methods in org.mpisws.p2p.transport.sourceroute.factory with parameters of type InputBuffer | |
---|---|
SourceRoute<java.net.InetSocketAddress> |
WireSourceRouteFactory.build(InputBuffer buf,
java.net.InetSocketAddress localAddr,
java.net.InetSocketAddress lastHop)
|
SourceRoute<MultiInetSocketAddress> |
MultiAddressSourceRouteFactory.build(InputBuffer buf,
MultiInetSocketAddress local,
MultiInetSocketAddress lastHop)
2 in the path is a special case, and we can just generate it from the local and last hops |
Uses of InputBuffer in org.mpisws.p2p.transport.util |
---|
Classes in org.mpisws.p2p.transport.util that implement InputBuffer | |
---|---|
class |
FileInputBuffer
|
class |
SocketInputBuffer
An easy way to read a complete object in from a socket. |
Methods in org.mpisws.p2p.transport.util with parameters of type InputBuffer | |
---|---|
Identifier |
Serializer.deserialize(InputBuffer buf)
|
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 |
NodeHandle |
Endpoint.readNodeHandle(InputBuffer buf)
|
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<java.lang.String,Endpoint> 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.javaserialized |
---|
Methods in rice.p2p.scribe.javaserialized with parameters of type InputBuffer | |
---|---|
ScribeContent |
JavaScribeContentDeserializer.deserializeScribeContent(InputBuffer buf,
Endpoint endpoint,
short contentType)
|
Uses of InputBuffer in rice.p2p.scribe.messaging |
---|
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 |
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.RawTestScribeContent(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 |
---|
Classes in rice.p2p.util that implement InputBuffer | |
---|---|
class |
RandomAccessFileIOBuffer
|
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 + + + + + + + + + +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+ |
NH |
NodeHandleFactory.readNodeHandle(InputBuffer buf)
|
NodeHandle |
PastryNode.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,
short type,
int priority,
NodeHandle sender)
|
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.peerreview |
---|
Methods in rice.pastry.peerreview with parameters of type InputBuffer | |
---|---|
boolean |
PeerReviewCallbackImpl.loadCheckpoint(InputBuffer buffer)
Load rt/leafset |
Constructors in rice.pastry.peerreview with parameters of type InputBuffer | |
---|---|
FetchLeafsetResponse(InputBuffer buf,
NodeHandleFactory nhf,
NodeHandle sender)
|
Uses of InputBuffer in rice.pastry.pns.messages |
---|
Methods in rice.pastry.pns.messages with parameters of type InputBuffer | |
---|---|
static Message |
LeafSetResponse.build(InputBuffer buf,
NodeHandleFactory nhf,
int dest)
|
static LeafSetRequest |
LeafSetRequest.build(InputBuffer buf,
NodeHandle sender,
int dest)
|
static Message |
RouteRowRequest.build(InputBuffer buf,
NodeHandle sender,
int dest)
|
Constructors in rice.pastry.pns.messages with parameters of type InputBuffer | |
---|---|
RouteRowResponse(InputBuffer buf,
PastryNode localNode,
NodeHandle sender,
int dest)
|
Uses of InputBuffer in rice.pastry.routing |
---|
Methods in rice.pastry.routing with parameters of type InputBuffer | |
---|---|
static RouteMessage |
RouteMessage.build(InputBuffer buf,
byte priority,
PastryNode pn,
NodeHandle prev,
byte outputVersion)
version 1: +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+ + int auxAddress + +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+ + bool hasHndle + // if it has a destinationHandle instead of an Id +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+ + Id target + + (only existis if the hasHandle boolean is false + + + + + + + +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+ + NodeHandle destinationHandle + + (used if the RouteMessage is intended for a specific node) + + (only exists if the hasHandle boolean is true) + ... |
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,
byte priority,
PastryNode pn,
NodeHandle destinationHandle,
byte serializeVersion)
|
|
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 + ... |
protected SocketNodeHandle |
SPNFIdentitySerializer.buildSNH(InputBuffer buf,
MultiInetSocketAddress i,
long epoch,
Id nid)
|
SocketNodeHandle |
SocketNodeHandleFactory.deserialize(InputBuffer buf)
|
TransportLayerNodeHandle<MultiInetSocketAddress> |
SPNFIdentitySerializer.deserialize(InputBuffer buf,
SourceRoute<MultiInetSocketAddress> i)
This is different from the normal deserializer b/c we already have the address |
SocketNodeHandle |
SocketNodeHandleFactory.readNodeHandle(InputBuffer buf)
|
Uses of InputBuffer in rice.pastry.socket.nat.probe |
---|
Methods in rice.pastry.socket.nat.probe with parameters of type InputBuffer | |
---|---|
static ProbeRequestMessage |
ProbeRequestMessage.build(InputBuffer buf,
int appAddress)
|
Uses of InputBuffer in rice.pastry.socket.nat.rendezvous |
---|
Methods in rice.pastry.socket.nat.rendezvous with parameters of type InputBuffer | |
---|---|
protected SocketNodeHandle |
RendezvousSPNFIdentitySerializer.buildSNH(InputBuffer buf,
MultiInetSocketAddress i,
long epoch,
Id nid)
|
SocketNodeHandle |
RendezvousSNHFactory.readNodeHandle(InputBuffer buf)
|
Constructors in rice.pastry.socket.nat.rendezvous with parameters of type InputBuffer | |
---|---|
RendezvousJoinRequest(InputBuffer buf,
NodeHandleFactory nhf,
NodeHandle sender,
PastryNode localNode)
|
Uses of InputBuffer in rice.pastry.standard |
---|
Methods in rice.pastry.standard with parameters of type InputBuffer | |
---|---|
Message |
ConsistentJoinProtocol.CJPDeserializer.deserialize(InputBuffer buf,
short type,
int priority,
NodeHandle sender)
|
Message |
PeriodicLeafSetProtocol.PLSPMessageDeserializer.deserialize(InputBuffer buf,
short type,
int priority,
NodeHandle sender)
|
Message |
StandardJoinProtocol.SJPDeserializer.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.pastry.transport |
---|
Methods in rice.pastry.transport with parameters of type InputBuffer | |
---|---|
RawMessage |
TLDeserializer.deserialize(InputBuffer buf,
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 | |||||||||
PREV NEXT | FRAMES NO FRAMES |