|
Rice Pastry API | |||||||||
PREV NEXT | FRAMES NO FRAMES |
Uses of SourceRoute in org.mpisws.p2p.testing.transportlayer |
---|
Methods in org.mpisws.p2p.testing.transportlayer that return SourceRoute | |
---|---|
SourceRoute<java.net.InetSocketAddress> |
WireSRTest.getBogusIdentifier(SourceRoute<java.net.InetSocketAddress> local)
|
SourceRoute<MultiInetSocketAddress> |
SRTest.getBogusIdentifier(SourceRoute<MultiInetSocketAddress> local)
|
SourceRoute |
WireSRTest.getIdentifier(TransportLayer<SourceRoute<java.net.InetSocketAddress>,java.nio.ByteBuffer> a,
TransportLayer<SourceRoute<java.net.InetSocketAddress>,java.nio.ByteBuffer> b)
|
SourceRoute<MultiInetSocketAddress> |
LivenessTest.getIdentifier(TransportLayer<SourceRoute<MultiInetSocketAddress>,java.nio.ByteBuffer> a,
TransportLayer<SourceRoute<MultiInetSocketAddress>,java.nio.ByteBuffer> b)
|
SourceRoute |
SRTest.getIdentifier(TransportLayer<SourceRoute<MultiInetSocketAddress>,java.nio.ByteBuffer> a,
TransportLayer<SourceRoute<MultiInetSocketAddress>,java.nio.ByteBuffer> b)
|
Methods in org.mpisws.p2p.testing.transportlayer with parameters of type SourceRoute | |
---|---|
SourceRoute<java.net.InetSocketAddress> |
WireSRTest.getBogusIdentifier(SourceRoute<java.net.InetSocketAddress> local)
|
SourceRoute<MultiInetSocketAddress> |
SRTest.getBogusIdentifier(SourceRoute<MultiInetSocketAddress> local)
|
static int |
LivenessTest.getDelay(SourceRoute a,
SourceRoute b)
|
static int |
LivenessTest.getDelay(SourceRoute a,
SourceRoute b)
|
static int |
SRManagerTest.getDelay(SourceRoute a,
SourceRoute b)
|
static int |
SRManagerTest.getDelay(SourceRoute a,
SourceRoute b)
|
Uses of SourceRoute in org.mpisws.p2p.transport.sourceroute |
---|
Methods in org.mpisws.p2p.transport.sourceroute that return SourceRoute | |
---|---|
SourceRoute<Identifier> |
SourceRouteFactory.build(InputBuffer buf,
Identifier local,
Identifier lastHop)
|
SourceRoute |
SourceRouteTransportLayerImpl.getLocalIdentifier()
|
SourceRoute<Identifier> |
SourceRouteFactory.getSourceRoute(Identifier local)
|
SourceRoute<Identifier> |
SourceRouteFactory.getSourceRoute(Identifier local,
Identifier dest)
|
SourceRoute<Identifier> |
SourceRouteFactory.getSourceRoute(java.util.List<Identifier> route)
|
SourceRoute<Identifier> |
SourceRouteFactory.reverse(SourceRoute<Identifier> route)
|
Methods in org.mpisws.p2p.transport.sourceroute that return types with arguments of type SourceRoute | |
---|---|
SocketRequestHandle<SourceRoute<Identifier>> |
SourceRouteTransportLayerImpl.openSocket(SourceRoute<Identifier> i,
SocketCallback<SourceRoute<Identifier>> deliverSocketToMe,
java.util.Map<java.lang.String,java.lang.Object> options)
|
MessageRequestHandle<SourceRoute<Identifier>,java.nio.ByteBuffer> |
SourceRouteTransportLayerImpl.sendMessage(SourceRoute<Identifier> i,
java.nio.ByteBuffer m,
MessageCallback<SourceRoute<Identifier>,java.nio.ByteBuffer> deliverAckToMe,
java.util.Map<java.lang.String,java.lang.Object> options)
|
Methods in org.mpisws.p2p.transport.sourceroute with parameters of type SourceRoute | |
---|---|
boolean |
DefaultForwardSourceRouteStrategy.forward(Identifier nextHop,
SourceRoute<Identifier> sr,
boolean socket,
java.util.Map<java.lang.String,java.lang.Object> options)
|
boolean |
SourceRouteForwardStrategy.forward(Identifier nextHop,
SourceRoute<Identifier> sr,
boolean socket,
java.util.Map<java.lang.String,java.lang.Object> options)
|
protected void |
SourceRouteTransportLayerImpl.incomingSocketHelper(P2PSocket<Identifier> socket,
SourceRoute<Identifier> sr)
To override this behavior if needed. |
SocketRequestHandle<SourceRoute<Identifier>> |
SourceRouteTransportLayerImpl.openSocket(SourceRoute<Identifier> i,
SocketCallback<SourceRoute<Identifier>> deliverSocketToMe,
java.util.Map<java.lang.String,java.lang.Object> options)
|
protected void |
SourceRouteTransportLayerImpl.openSocketHelper(SocketCallback<SourceRoute<Identifier>> deliverSocketToMe,
SocketRequestHandleImpl<SourceRoute<Identifier>> handle,
P2PSocket<Identifier> socket,
SourceRoute<Identifier> i)
|
void |
SourceRouteTap.receivedBytes(java.nio.ByteBuffer m,
SourceRoute path,
P2PSocket a,
P2PSocket b)
We are the intermediate node for some bytes from Socket a to Socket b |
void |
SourceRouteTap.receivedMessage(java.nio.ByteBuffer m,
SourceRoute path)
We are the intermediate node for a message. |
SourceRoute<Identifier> |
SourceRouteFactory.reverse(SourceRoute<Identifier> route)
|
MessageRequestHandle<SourceRoute<Identifier>,java.nio.ByteBuffer> |
SourceRouteTransportLayerImpl.sendMessage(SourceRoute<Identifier> i,
java.nio.ByteBuffer m,
MessageCallback<SourceRoute<Identifier>,java.nio.ByteBuffer> deliverAckToMe,
java.util.Map<java.lang.String,java.lang.Object> options)
|
void |
SourceRouteTap.socketClosed(SourceRoute path,
P2PSocket a,
P2PSocket b)
|
void |
SourceRouteTap.socketOpened(SourceRoute path,
P2PSocket a,
P2PSocket b)
|
Method parameters in org.mpisws.p2p.transport.sourceroute with type arguments of type SourceRoute | |
---|---|
SocketRequestHandle<SourceRoute<Identifier>> |
SourceRouteTransportLayerImpl.openSocket(SourceRoute<Identifier> i,
SocketCallback<SourceRoute<Identifier>> deliverSocketToMe,
java.util.Map<java.lang.String,java.lang.Object> options)
|
protected void |
SourceRouteTransportLayerImpl.openSocketHelper(SocketCallback<SourceRoute<Identifier>> deliverSocketToMe,
SocketRequestHandleImpl<SourceRoute<Identifier>> handle,
P2PSocket<Identifier> socket,
SourceRoute<Identifier> i)
|
protected void |
SourceRouteTransportLayerImpl.openSocketHelper(SocketCallback<SourceRoute<Identifier>> deliverSocketToMe,
SocketRequestHandleImpl<SourceRoute<Identifier>> handle,
P2PSocket<Identifier> socket,
SourceRoute<Identifier> i)
|
MessageRequestHandle<SourceRoute<Identifier>,java.nio.ByteBuffer> |
SourceRouteTransportLayerImpl.sendMessage(SourceRoute<Identifier> i,
java.nio.ByteBuffer m,
MessageCallback<SourceRoute<Identifier>,java.nio.ByteBuffer> deliverAckToMe,
java.util.Map<java.lang.String,java.lang.Object> options)
|
void |
SourceRouteTransportLayerImpl.setCallback(TransportLayerCallback<SourceRoute<Identifier>,java.nio.ByteBuffer> callback)
|
void |
SourceRouteTransportLayerImpl.setErrorHandler(ErrorHandler<SourceRoute<Identifier>> errorHandler)
|
Constructors in org.mpisws.p2p.transport.sourceroute with parameters of type SourceRoute | |
---|---|
Forwarder(SourceRoute<Identifier> sr,
P2PSocket<Identifier> socka,
P2PSocket<Identifier> sockb,
Logger logger)
|
Constructor parameters in org.mpisws.p2p.transport.sourceroute with type arguments of type SourceRoute | |
---|---|
SourceRouteTransportLayerImpl(SourceRouteFactory<Identifier> srFactory,
TransportLayer<Identifier,java.nio.ByteBuffer> etl,
SourceRouteForwardStrategy<Identifier> fSRs,
Environment env,
ErrorHandler<SourceRoute<Identifier>> errorHandler)
|
Uses of SourceRoute in org.mpisws.p2p.transport.sourceroute.factory |
---|
Subclasses of SourceRoute in org.mpisws.p2p.transport.sourceroute.factory | |
---|---|
class |
MultiAddressSourceRoute
|
class |
WireSourceRoute
|
Methods in org.mpisws.p2p.transport.sourceroute.factory that return SourceRoute | |
---|---|
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 |
SourceRoute<java.net.InetSocketAddress> |
WireSourceRouteFactory.getSourceRoute(java.net.InetSocketAddress local)
|
SourceRoute<java.net.InetSocketAddress> |
WireSourceRouteFactory.getSourceRoute(java.net.InetSocketAddress local,
java.net.InetSocketAddress dest)
|
SourceRoute<java.net.InetSocketAddress> |
WireSourceRouteFactory.getSourceRoute(java.util.List<java.net.InetSocketAddress> route)
|
SourceRoute<MultiInetSocketAddress> |
MultiAddressSourceRouteFactory.getSourceRoute(java.util.List<MultiInetSocketAddress> route)
|
SourceRoute<MultiInetSocketAddress> |
MultiAddressSourceRouteFactory.getSourceRoute(MultiInetSocketAddress local)
|
SourceRoute<MultiInetSocketAddress> |
MultiAddressSourceRouteFactory.getSourceRoute(MultiInetSocketAddress local,
MultiInetSocketAddress dest)
|
SourceRoute<java.net.InetSocketAddress> |
WireSourceRouteFactory.reverse(SourceRoute<java.net.InetSocketAddress> route)
|
SourceRoute<MultiInetSocketAddress> |
MultiAddressSourceRouteFactory.reverse(SourceRoute<MultiInetSocketAddress> route)
|
Methods in org.mpisws.p2p.transport.sourceroute.factory with parameters of type SourceRoute | |
---|---|
SourceRoute<java.net.InetSocketAddress> |
WireSourceRouteFactory.reverse(SourceRoute<java.net.InetSocketAddress> route)
|
SourceRoute<MultiInetSocketAddress> |
MultiAddressSourceRouteFactory.reverse(SourceRoute<MultiInetSocketAddress> route)
|
Uses of SourceRoute in org.mpisws.p2p.transport.sourceroute.manager |
---|
Fields in org.mpisws.p2p.transport.sourceroute.manager declared as SourceRoute | |
---|---|
protected SourceRoute<Identifier> |
SourceRouteManagerImpl.AddressManager.best
the current best route to this remote address if best == null, we are already in a CheckDead, which means we are searching for a path |
Methods in org.mpisws.p2p.transport.sourceroute.manager that return types with arguments of type SourceRoute | |
---|---|
java.util.Collection<SourceRoute<Identifier>> |
SourceRouteStrategy.getSourceRoutes(Identifier destination)
Do not include the destination in the list. |
Methods in org.mpisws.p2p.transport.sourceroute.manager with parameters of type SourceRoute | |
---|---|
void |
SourceRouteManagerImpl.livenessChanged(SourceRoute<Identifier> i,
int val,
java.util.Map<java.lang.String,java.lang.Object> options)
|
void |
SourceRouteManagerImpl.AddressManager.livenessChanged(SourceRoute<Identifier> i,
int val,
java.util.Map<java.lang.String,java.lang.Object> options)
|
protected void |
SourceRouteManagerImpl.AddressManager.markAlive(SourceRoute<Identifier> route,
java.util.Map<java.lang.String,java.lang.Object> options)
This method should be called when a known route is declared alive. |
protected void |
SourceRouteManagerImpl.AddressManager.markDead(SourceRoute<Identifier> deadRoute,
java.util.Map<java.lang.String,java.lang.Object> options)
This method should be called when a known route is declared dead. |
protected void |
SourceRouteManagerImpl.AddressManager.markProximity(SourceRoute<Identifier> route,
int proximity,
java.util.Map<java.lang.String,java.lang.Object> options)
This method should be called when a known route has its proximity updated |
protected void |
SourceRouteManagerImpl.AddressManager.markSuspected(SourceRoute<Identifier> route,
java.util.Map<java.lang.String,java.lang.Object> options)
This method should be called when a known route is declared suspected. |
void |
SourceRouteManagerImpl.messageReceived(SourceRoute<Identifier> i,
java.nio.ByteBuffer m,
java.util.Map<java.lang.String,java.lang.Object> options)
|
void |
SourceRouteManagerImpl.proximityChanged(SourceRoute<Identifier> i,
int newProximity,
java.util.Map<java.lang.String,java.lang.Object> options)
|
Method parameters in org.mpisws.p2p.transport.sourceroute.manager with type arguments of type SourceRoute | |
---|---|
void |
SourceRouteManagerImpl.incomingSocket(P2PSocket<SourceRoute<Identifier>> s)
|
Uses of SourceRoute in org.mpisws.p2p.transport.sourceroute.manager.simple |
---|
Methods in org.mpisws.p2p.transport.sourceroute.manager.simple that return types with arguments of type SourceRoute | |
---|---|
java.util.Collection<SourceRoute<Identifier>> |
SimpleSourceRouteStrategy.getSourceRoutes(Identifier destination)
Note, this implementation only allows 1 - hop routes, need to check the liveness, of a route to determine longer routes. |
Uses of SourceRoute in rice.pastry.socket |
---|
Methods in rice.pastry.socket with parameters of type SourceRoute | |
---|---|
TransportLayerNodeHandle<MultiInetSocketAddress> |
SPNFIdentitySerializer.deserialize(InputBuffer buf,
SourceRoute<MultiInetSocketAddress> i)
This is different from the normal deserializer b/c we already have the address |
boolean |
LivenesSourceRouteForwardStrategy.forward(Identifier nextHop,
SourceRoute<Identifier> sr,
boolean socket,
java.util.Map<java.lang.String,java.lang.Object> options)
|
MultiInetSocketAddress |
SPNFIdentitySerializer.translateUp(SourceRoute<MultiInetSocketAddress> i)
|
Uses of SourceRoute in rice.pastry.socket.appsocket |
---|
Methods in rice.pastry.socket.appsocket that return types with arguments of type SourceRoute | |
---|---|
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 |
Method parameters in rice.pastry.socket.appsocket with type arguments of type SourceRoute | |
---|---|
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 SourceRoute in rice.pastry.socket.nat.rendezvous |
---|
Methods in rice.pastry.socket.nat.rendezvous that return types with arguments of type SourceRoute | |
---|---|
protected IdentitySerializer<TransportLayerNodeHandle<MultiInetSocketAddress>,MultiInetSocketAddress,SourceRoute<MultiInetSocketAddress>> |
RendezvousSocketPastryNodeFactory.getIdentiySerializer(PastryNode pn,
SocketNodeHandleFactory handleFactory)
|
|
Rice Pastry API | |||||||||
PREV NEXT | FRAMES NO FRAMES |