|
Rice Pastry API | |||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||
| Uses of TransportLayer in org.mpisws.p2p.testing.transportlayer |
|---|
| Uses of TransportLayer in org.mpisws.p2p.transport.bandwidthlimit |
|---|
| Subinterfaces of TransportLayer in org.mpisws.p2p.transport.bandwidthlimit | |
|---|---|
interface |
LimitBandwidhtTransportLayer<Identifier>
Can Limit Bandwidth of a node. |
| Uses of TransportLayer in org.mpisws.p2p.transport.commonapi |
|---|
| Subinterfaces of TransportLayer in org.mpisws.p2p.transport.commonapi | |
|---|---|
interface |
CommonAPITransportLayer<Identifier extends NodeHandle>
TransportLayer for the rice.p2p.commonapi. |
| Classes in org.mpisws.p2p.transport.commonapi that implement TransportLayer | |
|---|---|
class |
CommonAPITransportLayerImpl<Identifier extends NodeHandle>
|
| Constructors in org.mpisws.p2p.transport.commonapi with parameters of type TransportLayer | |
|---|---|
CommonAPITransportLayerImpl(TransportLayer<Identifier,java.nio.ByteBuffer> tl,
IdFactory idFactory,
RawMessageDeserializer deserializer,
ErrorHandler errorHandler,
Environment env)
|
|
| Uses of TransportLayer in org.mpisws.p2p.transport.direct |
|---|
| Classes in org.mpisws.p2p.transport.direct that implement TransportLayer | |
|---|---|
class |
DirectTransportLayer<Identifier,MessageType>
|
| Uses of TransportLayer in org.mpisws.p2p.transport.identity |
|---|
| Subinterfaces of TransportLayer in org.mpisws.p2p.transport.identity | |
|---|---|
interface |
LowerIdentity<Identifier,MessageType>
Prefixes outgoing messages/sockets with the identity of the destination. |
interface |
UpperIdentity<Identifier,MessageType>
When the LowerIdentity reports that a destination has changed, this layer cancels all pending messages. |
| Methods in org.mpisws.p2p.transport.identity with parameters of type TransportLayer | |
|---|---|
void |
IdentityImpl.initLowerLayer(TransportLayer<LowerIdentifier,java.nio.ByteBuffer> tl,
ErrorHandler<LowerIdentifier> handler)
|
void |
IdentityImpl.initUpperLayer(UpperIdentifier localIdentifier,
TransportLayer<MiddleIdentifier,UpperMsgType> tl,
LivenessProvider<MiddleIdentifier> live,
ProximityProvider<MiddleIdentifier> prox,
OverrideLiveness<LowerIdentifier> overrideLiveness)
|
| Uses of TransportLayer in org.mpisws.p2p.transport.limitsockets |
|---|
| Classes in org.mpisws.p2p.transport.limitsockets that implement TransportLayer | |
|---|---|
class |
LimitSocketsTransportLayer<Identifier,MessageType>
Automatically closes sockets based on LRU. |
| Fields in org.mpisws.p2p.transport.limitsockets declared as TransportLayer | |
|---|---|
protected TransportLayer<Identifier,MessageType> |
LimitSocketsTransportLayer.tl
|
| Constructors in org.mpisws.p2p.transport.limitsockets with parameters of type TransportLayer | |
|---|---|
LimitSocketsTransportLayer(int max_sockets,
TransportLayer<Identifier,MessageType> tl,
Environment env)
|
|
| Uses of TransportLayer in org.mpisws.p2p.transport.liveness |
|---|
| Subinterfaces of TransportLayer in org.mpisws.p2p.transport.liveness | |
|---|---|
interface |
LivenessTransportLayer<Identifier,MsgType>
|
| Classes in org.mpisws.p2p.transport.liveness that implement TransportLayer | |
|---|---|
class |
LivenessTransportLayerImpl<Identifier>
|
| Fields in org.mpisws.p2p.transport.liveness declared as TransportLayer | |
|---|---|
protected TransportLayer<Identifier,java.nio.ByteBuffer> |
LivenessTransportLayerImpl.tl
|
| Constructors in org.mpisws.p2p.transport.liveness with parameters of type TransportLayer | |
|---|---|
LivenessTransportLayerImpl(TransportLayer<Identifier,java.nio.ByteBuffer> tl,
Environment env,
ErrorHandler<Identifier> errorHandler,
int checkDeadThrottle)
|
|
| Uses of TransportLayer in org.mpisws.p2p.transport.multiaddress |
|---|
| Subinterfaces of TransportLayer in org.mpisws.p2p.transport.multiaddress | |
|---|---|
interface |
MultiInetAddressTransportLayer
This transport layer that can allow a node behind a NAT to talk to nodes outside or inside the firewall. |
| Classes in org.mpisws.p2p.transport.multiaddress that implement TransportLayer | |
|---|---|
class |
MultiInetAddressTransportLayerImpl
This class adds an epoch and a list of InetSocketAddresses, and also disambiguates between them for the lower layer. |
| Constructors in org.mpisws.p2p.transport.multiaddress with parameters of type TransportLayer | |
|---|---|
MultiInetAddressTransportLayerImpl(MultiInetSocketAddress localAddress,
TransportLayer<java.net.InetSocketAddress,java.nio.ByteBuffer> wire,
Environment env,
ErrorHandler<MultiInetSocketAddress> handler,
AddressStrategy strategy)
|
|
| Uses of TransportLayer in org.mpisws.p2p.transport.nat |
|---|
| Classes in org.mpisws.p2p.transport.nat that implement TransportLayer | |
|---|---|
class |
FirewallTLImpl<Identifier,MessageType>
Drops all incoming TCP connections. |
| Fields in org.mpisws.p2p.transport.nat declared as TransportLayer | |
|---|---|
protected TransportLayer<Identifier,MessageType> |
FirewallTLImpl.tl
|
| Constructors in org.mpisws.p2p.transport.nat with parameters of type TransportLayer | |
|---|---|
FirewallTLImpl(TransportLayer<Identifier,MessageType> tl,
int udp_open_millis,
Environment env)
|
|
| Uses of TransportLayer in org.mpisws.p2p.transport.peerreview |
|---|
| Classes in org.mpisws.p2p.transport.peerreview that implement TransportLayer | |
|---|---|
class |
PeerReviewImpl<Identifier,MessageType>
|
| Uses of TransportLayer in org.mpisws.p2p.transport.peerreview.replay.playback |
|---|
| Classes in org.mpisws.p2p.transport.peerreview.replay.playback that implement TransportLayer | |
|---|---|
class |
ReplayLayer<Identifier>
|
| Uses of TransportLayer in org.mpisws.p2p.transport.peerreview.replay.record |
|---|
| Classes in org.mpisws.p2p.transport.peerreview.replay.record that implement TransportLayer | |
|---|---|
class |
RecordLayer<Identifier>
|
| Constructors in org.mpisws.p2p.transport.peerreview.replay.record with parameters of type TransportLayer | |
|---|---|
RecordLayer(TransportLayer<Identifier,java.nio.ByteBuffer> tl,
java.lang.String name,
IdentifierSerializer<Identifier> serializer,
Environment env)
|
|
| Uses of TransportLayer in org.mpisws.p2p.transport.priority |
|---|
| Subinterfaces of TransportLayer in org.mpisws.p2p.transport.priority | |
|---|---|
interface |
PriorityTransportLayer<Identifier>
Does 3 things: a) Sends messages on a Socket (depending on the options). |
| Classes in org.mpisws.p2p.transport.priority that implement TransportLayer | |
|---|---|
class |
PriorityTransportLayerImpl<Identifier>
|
| Constructors in org.mpisws.p2p.transport.priority with parameters of type TransportLayer | |
|---|---|
PriorityTransportLayerImpl(TransportLayer<Identifier,java.nio.ByteBuffer> tl,
LivenessProvider<Identifier> livenessProvider,
ProximityProvider<Identifier> proximityProvider,
Environment env,
int maxMsgSize,
int maxQueueSize,
ErrorHandler<Identifier> handler)
The maximum message size; |
|
| Uses of TransportLayer in org.mpisws.p2p.transport.rendezvous |
|---|
| Classes in org.mpisws.p2p.transport.rendezvous that implement TransportLayer | |
|---|---|
class |
RendezvousTransportLayerImpl<Identifier,HighIdentifier extends RendezvousContact>
The trick here is that this layer is at some level, say InetSocketAddress, but must pass around very High-Level Identifiers, such as a NodeHandle for the rendezvous strategy to do its job, but maybe this can just be the RendezvousContact, and it can be casted. |
| Constructors in org.mpisws.p2p.transport.rendezvous with parameters of type TransportLayer | |
|---|---|
RendezvousTransportLayerImpl(TransportLayer<Identifier,java.nio.ByteBuffer> tl,
java.lang.String RENDEZVOUS_CONTACT_STRING,
HighIdentifier myRendezvousContact,
ContactDeserializer<Identifier,HighIdentifier> deserializer,
RendezvousGenerationStrategy<HighIdentifier> rendezvousGenerator,
RendezvousStrategy<HighIdentifier> rendezvousStrategy,
Environment env)
|
|
| Uses of TransportLayer in org.mpisws.p2p.transport.security |
|---|
| Subinterfaces of TransportLayer in org.mpisws.p2p.transport.security | |
|---|---|
interface |
CertificateTransportLayer
|
| Uses of TransportLayer in org.mpisws.p2p.transport.sourceroute |
|---|
| Subinterfaces of TransportLayer in org.mpisws.p2p.transport.sourceroute | |
|---|---|
interface |
SourceRouteTransportLayer<Identifier>
|
| Classes in org.mpisws.p2p.transport.sourceroute that implement TransportLayer | |
|---|---|
class |
SourceRouteTransportLayerImpl<Identifier>
This layer can only send/receive messages from a SourceRoute and determine liveness. |
| Constructors in org.mpisws.p2p.transport.sourceroute with parameters of type TransportLayer | |
|---|---|
SourceRouteTransportLayerImpl(SourceRouteFactory<Identifier> srFactory,
TransportLayer<Identifier,java.nio.ByteBuffer> etl,
Environment env,
ErrorHandler<SourceRoute<Identifier>> errorHandler)
|
|
| Uses of TransportLayer in org.mpisws.p2p.transport.sourceroute.manager |
|---|
| Subinterfaces of TransportLayer in org.mpisws.p2p.transport.sourceroute.manager | |
|---|---|
interface |
SourceRouteManager<Identifier>
The purpose of this class is to hide the detail of sourcerouting. |
| Classes in org.mpisws.p2p.transport.sourceroute.manager that implement TransportLayer | |
|---|---|
class |
SourceRouteManagerImpl<Identifier>
This class adapts a SourceRoute transport layer back to an Identifier layer. |
| Constructors in org.mpisws.p2p.transport.sourceroute.manager with parameters of type TransportLayer | |
|---|---|
SourceRouteManagerImpl(SourceRouteFactory<Identifier> srFactory,
TransportLayer<SourceRoute<Identifier>,java.nio.ByteBuffer> tl,
LivenessProvider<SourceRoute<Identifier>> livenessProvider,
ProximityProvider<SourceRoute<Identifier>> proxProvider,
Environment env,
SourceRouteStrategy<Identifier> strategy)
|
|
| Uses of TransportLayer in org.mpisws.p2p.transport.ssl |
|---|
| Subinterfaces of TransportLayer in org.mpisws.p2p.transport.ssl | |
|---|---|
interface |
SSLTransportLayer
Optionally Encrypts or Authenticates sockets. |
| Uses of TransportLayer in org.mpisws.p2p.transport.wire |
|---|
| Subinterfaces of TransportLayer in org.mpisws.p2p.transport.wire | |
|---|---|
interface |
WireTransportLayer
Sends/receives ByteBuffer from InetSocketAddress This layer does a lot of the difficult part: - Non-blocking I/O (using selector etc) - Enforcement of number of Sockets to prevent FileDescriptor Starvation |
| Classes in org.mpisws.p2p.transport.wire that implement TransportLayer | |
|---|---|
class |
WireTransportLayerImpl
|
| Uses of TransportLayer in org.mpisws.p2p.transport.wire.magicnumber |
|---|
| Classes in org.mpisws.p2p.transport.wire.magicnumber that implement TransportLayer | |
|---|---|
class |
MagicNumberTransportLayer<Identity>
This class eliminates random connections by dropping all messages/sockets that don't correlate to a specific header. |
| Fields in org.mpisws.p2p.transport.wire.magicnumber declared as TransportLayer | |
|---|---|
protected TransportLayer<Identity,java.nio.ByteBuffer> |
MagicNumberTransportLayer.wire
|
| Constructors in org.mpisws.p2p.transport.wire.magicnumber with parameters of type TransportLayer | |
|---|---|
MagicNumberTransportLayer(TransportLayer<Identity,java.nio.ByteBuffer> wtl,
Environment env,
ErrorHandler<Identity> errorHandler,
byte[] header,
int timeOut)
|
|
| Uses of TransportLayer in rice.pastry.socket |
|---|
| Uses of TransportLayer in rice.pastry.socket.nat.rendezvous |
|---|
| Methods in rice.pastry.socket.nat.rendezvous that return TransportLayer | |
|---|---|
protected TransportLayer<java.net.InetSocketAddress,java.nio.ByteBuffer> |
RendezvousSocketPastryNodeFactory.getMagicNumberTransportLayer(TransportLayer<java.net.InetSocketAddress,java.nio.ByteBuffer> wtl,
TLPastryNode pn)
|
protected TransportLayer<java.net.InetSocketAddress,java.nio.ByteBuffer> |
RendezvousSocketPastryNodeFactory.getRendezvousTransportLayer(TransportLayer<java.net.InetSocketAddress,java.nio.ByteBuffer> mtl,
TLPastryNode pn)
|
| Methods in rice.pastry.socket.nat.rendezvous with parameters of type TransportLayer | |
|---|---|
protected TransportLayer<java.net.InetSocketAddress,java.nio.ByteBuffer> |
RendezvousSocketPastryNodeFactory.getMagicNumberTransportLayer(TransportLayer<java.net.InetSocketAddress,java.nio.ByteBuffer> wtl,
TLPastryNode pn)
|
protected TransportLayer<java.net.InetSocketAddress,java.nio.ByteBuffer> |
RendezvousSocketPastryNodeFactory.getRendezvousTransportLayer(TransportLayer<java.net.InetSocketAddress,java.nio.ByteBuffer> mtl,
TLPastryNode pn)
|
| Uses of TransportLayer in rice.pastry.transport |
|---|
| Classes in rice.pastry.transport that implement TransportLayer | |
|---|---|
class |
NodeHandleAdapter
|
| Methods in rice.pastry.transport that return TransportLayer | |
|---|---|
TransportLayer |
NodeHandleAdapter.getTL()
|
TransportLayer<NodeHandle,RawMessage> |
TLPastryNode.getTL()
|
| Methods in rice.pastry.transport with parameters of type TransportLayer | |
|---|---|
void |
TLPastryNode.setSocketElements(NodeHandle localhandle,
int lsmf,
int rsmf,
TransportLayer<NodeHandle,RawMessage> tl,
LivenessProvider<NodeHandle> livenessProvider,
ProximityProvider<NodeHandle> proxProvider,
Deserializer deserializer,
NodeHandleFactory handleFactory)
|
| Constructors in rice.pastry.transport with parameters of type TransportLayer | |
|---|---|
NodeHandleAdapter(TransportLayer tl,
LivenessProvider livenessProvider,
ProximityProvider proxProvider)
|
|
| Uses of TransportLayer in rice.tutorial.transportlayer |
|---|
| Classes in rice.tutorial.transportlayer that implement TransportLayer | |
|---|---|
class |
BandwidthLimitingTransportLayer<Identifier>
|
| Fields in rice.tutorial.transportlayer declared as TransportLayer | |
|---|---|
protected TransportLayer<Identifier,java.nio.ByteBuffer> |
BandwidthLimitingTransportLayer.tl
The lower level transport layer. |
| Constructors in rice.tutorial.transportlayer with parameters of type TransportLayer | |
|---|---|
BandwidthLimitingTransportLayer(TransportLayer<Identifier,java.nio.ByteBuffer> tl,
int bucketSize,
int bucketTimelimit,
Environment env)
To send 10K/second specify use 10240,1000 |
|
|
Rice Pastry API | |||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||