|
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 |
LimitBandwidthTransportLayer<Identifier>
Can Limit Bandwidth of a node. |
Uses of TransportLayer in org.mpisws.p2p.transport.bandwidthmeasure |
---|
Classes in org.mpisws.p2p.transport.bandwidthmeasure that implement TransportLayer | |
---|---|
class |
BandwidthMeasuringTransportLayer<Identifier>
Measure the bandwidth of the connections. |
Constructors in org.mpisws.p2p.transport.bandwidthmeasure with parameters of type TransportLayer | |
---|---|
BandwidthMeasuringTransportLayer(int measurementPeriod,
TransportLayer<Identifier,java.nio.ByteBuffer> tl,
Environment env)
|
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,
OptionsAdder optionsAdder,
ErrorHandler<Identifier> 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,
ErrorHandler<Identifier> handler,
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 |
AggressiveLivenessTransportLayerImpl<Identifier>
Cancels liveness check if you read/write to TCP or read UDP from the node. |
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 | |
---|---|
AggressiveLivenessTransportLayerImpl(TransportLayer<Identifier,java.nio.ByteBuffer> tl,
Environment env,
ErrorHandler<Identifier> errorHandler,
int checkDeadThrottle)
|
|
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.networkinfo |
---|
Classes in org.mpisws.p2p.transport.networkinfo that implement TransportLayer | |
---|---|
class |
NetworkInfoTransportLayer
Can open a TCP connection to a known node, and it will return your IP address. |
Fields in org.mpisws.p2p.transport.networkinfo declared as TransportLayer | |
---|---|
protected TransportLayer<java.net.InetSocketAddress,java.nio.ByteBuffer> |
NetworkInfoTransportLayer.tl
|
Constructors in org.mpisws.p2p.transport.networkinfo with parameters of type TransportLayer | |
---|---|
NetworkInfoTransportLayer(TransportLayer<java.net.InetSocketAddress,java.nio.ByteBuffer> tl,
Environment env,
ErrorHandler<java.net.InetSocketAddress> errorHandler)
|
Uses of TransportLayer in org.mpisws.p2p.transport.peerreview |
---|
Subinterfaces of TransportLayer in org.mpisws.p2p.transport.peerreview | |
---|---|
interface |
PeerReview<Handle extends RawSerializable,Identifier extends RawSerializable>
|
Classes in org.mpisws.p2p.transport.peerreview that implement TransportLayer | |
---|---|
class |
PeerReviewImpl<Handle extends RawSerializable,Identifier extends RawSerializable>
|
Uses of TransportLayer in org.mpisws.p2p.transport.peerreview.identity |
---|
Subinterfaces of TransportLayer in org.mpisws.p2p.transport.peerreview.identity | |
---|---|
interface |
IdentityTransport<Handle,Identifier>
|
Classes in org.mpisws.p2p.transport.peerreview.identity that implement TransportLayer | |
---|---|
class |
IdentityTransportLayerImpl<Identifier,I>
TODO: make it store known certs to a file, make it periodically check the revocation server. |
Constructors in org.mpisws.p2p.transport.peerreview.identity with parameters of type TransportLayer | |
---|---|
IdentityTransportLayerImpl(Serializer<I> iSerializer,
X509Serializer cSerializer,
I localId,
java.security.cert.X509Certificate localCert,
java.security.PrivateKey localPrivate,
TransportLayer<Identifier,java.nio.ByteBuffer> tl,
HashProvider hasher,
Environment env)
|
Uses of TransportLayer in org.mpisws.p2p.transport.peerreview.replay |
---|
Subinterfaces of TransportLayer in org.mpisws.p2p.transport.peerreview.replay | |
---|---|
interface |
Verifier<Handle>
|
Classes in org.mpisws.p2p.transport.peerreview.replay that implement TransportLayer | |
---|---|
class |
VerifierImpl<Handle extends RawSerializable,Identifier extends RawSerializable>
|
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>
|
class |
ReplayVerifier<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,
Serializer<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.rc4 |
---|
Classes in org.mpisws.p2p.transport.rc4 that implement TransportLayer | |
---|---|
class |
RC4TransportLayer<Identifier,MsgType>
Only encrypts socket traffic!!! Encrypts channels based on a password. |
Fields in org.mpisws.p2p.transport.rc4 declared as TransportLayer | |
---|---|
protected TransportLayer<Identifier,MsgType> |
RC4TransportLayer.tl
Default 1 1 = encrypt 0 = don't encrypt Need to implemet this before we add it to the API |
Constructors in org.mpisws.p2p.transport.rc4 with parameters of type TransportLayer | |
---|---|
RC4TransportLayer(TransportLayer<Identifier,MsgType> tl,
Environment env,
java.lang.String password,
ErrorHandler<Identifier> errorHandler)
|
|
RC4TransportLayer(TransportLayer<Identifier,MsgType> tl,
Environment env,
java.lang.String password,
int pwSeedLength,
RandomSource random,
ErrorHandler<Identifier> errorHandler)
|
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. |
Fields in org.mpisws.p2p.transport.rendezvous declared as TransportLayer | |
---|---|
protected TransportLayer<Identifier,java.nio.ByteBuffer> |
RendezvousTransportLayerImpl.tl
|
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,
PilotFinder<HighIdentifier> pilotFinder,
RendezvousStrategy<HighIdentifier> rendezvousStrategy,
ResponseStrategy<Identifier> responseStrategy,
ContactDirectStrategy<HighIdentifier> contactDirectStrategy,
Environment env)
|
Uses of TransportLayer in org.mpisws.p2p.transport.simpleidentity |
---|
Classes in org.mpisws.p2p.transport.simpleidentity that implement TransportLayer | |
---|---|
class |
SimpleIdentityTransportLayer<Identifier,MessageType>
The purpose of this layer is to identify the opener of a TCP connection, because the socket is using an ephemeral port. |
Fields in org.mpisws.p2p.transport.simpleidentity declared as TransportLayer | |
---|---|
protected TransportLayer<Identifier,MessageType> |
SimpleIdentityTransportLayer.tl
|
Constructors in org.mpisws.p2p.transport.simpleidentity with parameters of type TransportLayer | |
---|---|
SimpleIdentityTransportLayer(TransportLayer<Identifier,MessageType> tl,
Serializer<Identifier> serializer,
LocalIdentifierStrategy<Identifier> localIdStrategy,
Environment env,
ErrorHandler<Identifier> handler)
|
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,
SourceRouteForwardStrategy<Identifier> fSRs,
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<Identifier,MessageType>
Optionally Encrypts or Authenticates sockets. |
Classes in org.mpisws.p2p.transport.ssl that implement TransportLayer | |
---|---|
class |
SSLTransportLayerImpl<Identifier,MessageType>
Does not encrypt UDP messages The server authenticates to the client via a CACert |
Fields in org.mpisws.p2p.transport.ssl declared as TransportLayer | |
---|---|
protected TransportLayer<Identifier,MessageType> |
SSLTransportLayerImpl.tl
|
Constructors in org.mpisws.p2p.transport.ssl with parameters of type TransportLayer | |
---|---|
SSLTransportLayerImpl(TransportLayer<Identifier,MessageType> tl,
java.security.KeyStore keyStore,
java.security.KeyStore trustStore,
Environment env)
|
|
SSLTransportLayerImpl(TransportLayer<Identifier,MessageType> tl,
java.security.KeyStore keyStore,
java.security.KeyStore trustStore,
int clientAuth,
Environment env)
|
Uses of TransportLayer in org.mpisws.p2p.transport.table |
---|
Subinterfaces of TransportLayer in org.mpisws.p2p.transport.table | |
---|---|
interface |
TableTransportLayer<Identifier,Key,Value>
Keeps a store of information at each node, such that other nodes can query for the information. |
Classes in org.mpisws.p2p.transport.table that implement TransportLayer | |
---|---|
class |
TableTransprotLayerImpl<Identifier,Key,Value>
|
Fields in org.mpisws.p2p.transport.table declared as TransportLayer | |
---|---|
protected TransportLayer<Identifier,java.nio.ByteBuffer> |
TableTransprotLayerImpl.tl
|
Constructors in org.mpisws.p2p.transport.table with parameters of type TransportLayer | |
---|---|
TableTransprotLayerImpl(Serializer<Key> iSerializer,
Serializer<Value> cSerializer,
TableStore<Key,Value> tableStore,
TransportLayer<Identifier,java.nio.ByteBuffer> tl,
Environment env)
|
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<Identifier>
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<Identifier,java.nio.ByteBuffer> |
MagicNumberTransportLayer.wire
|
Constructors in org.mpisws.p2p.transport.wire.magicnumber with parameters of type TransportLayer | |
---|---|
MagicNumberTransportLayer(TransportLayer<Identifier,java.nio.ByteBuffer> wtl,
Environment env,
ErrorHandler<Identifier> errorHandler,
byte[] header,
int timeOut)
|
Uses of TransportLayer in rice.pastry |
---|
Fields in rice.pastry declared as TransportLayer | |
---|---|
protected TransportLayer<NodeHandle,RawMessage> |
PastryNode.tl
The top level transport layer. |
Methods in rice.pastry that return TransportLayer | |
---|---|
TransportLayer<NodeHandle,RawMessage> |
PastryNode.getTL()
|
Methods in rice.pastry with parameters of type TransportLayer | |
---|---|
void |
PastryNode.setSocketElements(int lsmf,
int rsmf,
TransportLayer<NodeHandle,RawMessage> tl,
LivenessProvider<NodeHandle> livenessProvider,
ProximityProvider<NodeHandle> proxProvider,
NodeHandleFactory handleFactory)
|
Uses of TransportLayer in rice.pastry.direct |
---|
Methods in rice.pastry.direct that return TransportLayer | |
---|---|
protected TransportLayer<NodeHandle,RawMessage> |
DirectPastryNodeFactory.getDirectTransportLayer(PastryNode pn,
NodeRecord nr)
Override me |
Uses of TransportLayer in rice.pastry.peerreview |
---|
Classes in rice.pastry.peerreview that implement TransportLayer | |
---|---|
class |
PeerReviewCallbackImpl
|
Constructors in rice.pastry.peerreview with parameters of type TransportLayer | |
---|---|
PeerReviewCallbackImpl(PastryNode pn,
TransportLayer<TransportLayerNodeHandle<MultiInetSocketAddress>,java.nio.ByteBuffer> tl,
CallbackFactory nodeFactory)
|
|
PeerReviewCallbackImpl(TransportLayer<TransportLayerNodeHandle<MultiInetSocketAddress>,java.nio.ByteBuffer> tl)
|
Uses of TransportLayer in rice.pastry.socket |
---|
Fields in rice.pastry.socket declared as TransportLayer | |
---|---|
protected TransportLayer<TransportLayerNodeHandle<MultiInetSocketAddress>,RawMessage> |
SocketPastryNodeFactory.TLBootstrapper.tl
|
Methods in rice.pastry.socket that return TransportLayer | |
---|---|
TransportLayer<java.net.InetSocketAddress,java.nio.ByteBuffer> |
SocketPastryNodeFactory.getBottomLayers(PastryNode pn,
MultiInetSocketAddress proxyAddress)
This is split off so we can get the IpServiceLayer easily. |
protected TransportLayer<TransportLayerNodeHandle<MultiInetSocketAddress>,RawMessage> |
SocketPastryNodeFactory.getCommonAPITransportLayer(TransportLayer<TransportLayerNodeHandle<MultiInetSocketAddress>,java.nio.ByteBuffer> upperIdentity,
PastryNode pn,
TLDeserializer deserializer)
|
protected TransportLayer<java.net.InetSocketAddress,java.nio.ByteBuffer> |
SocketPastryNodeFactory.getIpServiceTransportLayer(TransportLayer<java.net.InetSocketAddress,java.nio.ByteBuffer> wtl,
PastryNode pn)
|
protected TransportLayer<java.net.InetSocketAddress,java.nio.ByteBuffer> |
SocketPastryNodeFactory.getLimitSocketsTransportLayer(TransportLayer<java.net.InetSocketAddress,java.nio.ByteBuffer> mntl,
PastryNode pn)
|
protected TransportLayer<SourceRoute<MultiInetSocketAddress>,java.nio.ByteBuffer> |
SocketPastryNodeFactory.getLowerIdentityLayer(TransportLayer<SourceRoute<MultiInetSocketAddress>,java.nio.ByteBuffer> srl,
PastryNode pn,
IdentityImpl<TransportLayerNodeHandle<MultiInetSocketAddress>,MultiInetSocketAddress,java.nio.ByteBuffer,SourceRoute<MultiInetSocketAddress>> identity)
|
protected TransportLayer<java.net.InetSocketAddress,java.nio.ByteBuffer> |
SocketPastryNodeFactory.getMagicNumberTransportLayer(TransportLayer<java.net.InetSocketAddress,java.nio.ByteBuffer> wtl,
PastryNode pn)
|
protected TransportLayer<MultiInetSocketAddress,java.nio.ByteBuffer> |
SocketPastryNodeFactory.getMultiAddressSourceRouteTransportLayer(TransportLayer<java.net.InetSocketAddress,java.nio.ByteBuffer> mntl,
PastryNode pn,
MultiInetSocketAddress localAddress)
|
protected TransportLayer<SourceRoute<MultiInetSocketAddress>,java.nio.ByteBuffer> |
SocketPastryNodeFactory.getSourceRouteTransportLayer(TransportLayer<MultiInetSocketAddress,java.nio.ByteBuffer> etl,
PastryNode pn,
MultiAddressSourceRouteFactory esrFactory)
|
TransportLayer<Identifier,MessageType> |
SocketPastryNodeFactory.TransLiveness.getTransportLayer()
|
TransportLayer<Identifier,java.nio.ByteBuffer> |
SocketPastryNodeFactory.TransLivenessProximity.getTransportLayer()
|
protected TransportLayer<java.net.InetSocketAddress,java.nio.ByteBuffer> |
SocketPastryNodeFactory.getWireTransportLayer(java.net.InetSocketAddress innermostAddress,
PastryNode pn)
|
Constructors in rice.pastry.socket with parameters of type TransportLayer | |
---|---|
SocketPastryNodeFactory.TLBootstrapper(PastryNode pn,
TransportLayer<TransportLayerNodeHandle<MultiInetSocketAddress>,RawMessage> tl,
SocketNodeHandleFactory handleFactory,
ProximityNeighborSelector pns)
|
Uses of TransportLayer in rice.pastry.socket.appsocket |
---|
Methods in rice.pastry.socket.appsocket that return TransportLayer | |
---|---|
protected TransportLayer<java.net.InetSocketAddress,java.nio.ByteBuffer> |
AppSocketPastryNodeFactory.getWireTransportLayer(java.net.InetSocketAddress innermostAddress,
PastryNode pn)
This code tells the WireTransportLayerImpl not to create a server-socket if we are using the BogusTLPastryNode |
Methods in rice.pastry.socket.appsocket with parameters of type TransportLayer | |
---|---|
protected SocketPastryNodeFactory.TransLiveness<SourceRoute<MultiInetSocketAddress>,java.nio.ByteBuffer> |
AppSocketPastryNodeFactory.getLivenessTransportLayer(TransportLayer<SourceRoute<MultiInetSocketAddress>,java.nio.ByteBuffer> tl,
PastryNode pn)
If it's for a remote node, eliminate the liveness layer, and just return bogus results |
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.getIpServiceTransportLayer(TransportLayer<java.net.InetSocketAddress,java.nio.ByteBuffer> wtl,
PastryNode pn)
|
protected TransportLayer<java.net.InetSocketAddress,java.nio.ByteBuffer> |
RendezvousSocketPastryNodeFactory.getRendezvousTransportLayer(TransportLayer<java.net.InetSocketAddress,java.nio.ByteBuffer> mtl,
PastryNode pn)
|
protected TransportLayer<java.net.InetSocketAddress,java.nio.ByteBuffer> |
RendezvousSocketPastryNodeFactory.getWireTransportLayer(java.net.InetSocketAddress innermostAddress,
PastryNode pn)
For testing, may return a FirewallTL impl for testing. |
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()
|
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 |