|
Rice Pastry API | |||||||||
PREV NEXT | FRAMES NO FRAMES |
Uses of MultiInetSocketAddress in org.mpisws.p2p.testing.transportlayer |
---|
Methods in org.mpisws.p2p.testing.transportlayer that return MultiInetSocketAddress | |
---|---|
MultiInetSocketAddress |
EpochTest.getBogusIdentifier(MultiInetSocketAddress local)
|
MultiInetSocketAddress |
SRManagerTest.getBogusIdentifier(MultiInetSocketAddress local)
|
Methods in org.mpisws.p2p.testing.transportlayer that return types with arguments of type MultiInetSocketAddress | |
---|---|
SourceRoute<MultiInetSocketAddress> |
SRTest.getBogusIdentifier(SourceRoute<MultiInetSocketAddress> local)
|
SourceRoute<MultiInetSocketAddress> |
LivenessTest.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 MultiInetSocketAddress | |
---|---|
MultiInetSocketAddress |
EpochTest.getBogusIdentifier(MultiInetSocketAddress local)
|
MultiInetSocketAddress |
SRManagerTest.getBogusIdentifier(MultiInetSocketAddress local)
|
Uses of MultiInetSocketAddress in org.mpisws.p2p.transport.multiaddress |
---|
Methods in org.mpisws.p2p.transport.multiaddress that return MultiInetSocketAddress | |
---|---|
static MultiInetSocketAddress |
MultiInetSocketAddress.build(InputBuffer buf)
EpochInetSocketAddress: (IPV4): +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+ + numAddrs + IPVersion 0 + +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+ + internet address 0 ... |
MultiInetSocketAddress |
MultiInetAddressTransportLayerImpl.getLocalIdentifier()
|
Methods in org.mpisws.p2p.transport.multiaddress that return types with arguments of type MultiInetSocketAddress | |
---|---|
SocketRequestHandle<MultiInetSocketAddress> |
MultiInetAddressTransportLayerImpl.openSocket(MultiInetSocketAddress i,
SocketCallback<MultiInetSocketAddress> deliverSocketToMe,
java.util.Map<java.lang.String,java.lang.Object> options)
|
MessageRequestHandle<MultiInetSocketAddress,java.nio.ByteBuffer> |
MultiInetAddressTransportLayerImpl.sendMessage(MultiInetSocketAddress i,
java.nio.ByteBuffer m,
MessageCallback<MultiInetSocketAddress,java.nio.ByteBuffer> deliverAckToMe,
java.util.Map<java.lang.String,java.lang.Object> options)
|
Methods in org.mpisws.p2p.transport.multiaddress with parameters of type MultiInetSocketAddress | |
---|---|
boolean |
MultiInetSocketAddress.addressEquals(MultiInetSocketAddress that)
|
java.net.InetSocketAddress |
AddressStrategy.getAddress(MultiInetSocketAddress local,
MultiInetSocketAddress remote)
|
java.net.InetSocketAddress |
SimpleAddressStrategy.getAddress(MultiInetSocketAddress local,
MultiInetSocketAddress remote)
Method which returns the address of this address |
SocketRequestHandle<MultiInetSocketAddress> |
MultiInetAddressTransportLayerImpl.openSocket(MultiInetSocketAddress i,
SocketCallback<MultiInetSocketAddress> deliverSocketToMe,
java.util.Map<java.lang.String,java.lang.Object> options)
|
MessageRequestHandle<MultiInetSocketAddress,java.nio.ByteBuffer> |
MultiInetAddressTransportLayerImpl.sendMessage(MultiInetSocketAddress i,
java.nio.ByteBuffer m,
MessageCallback<MultiInetSocketAddress,java.nio.ByteBuffer> deliverAckToMe,
java.util.Map<java.lang.String,java.lang.Object> options)
|
Method parameters in org.mpisws.p2p.transport.multiaddress with type arguments of type MultiInetSocketAddress | |
---|---|
SocketRequestHandle<MultiInetSocketAddress> |
MultiInetAddressTransportLayerImpl.openSocket(MultiInetSocketAddress i,
SocketCallback<MultiInetSocketAddress> deliverSocketToMe,
java.util.Map<java.lang.String,java.lang.Object> options)
|
MessageRequestHandle<MultiInetSocketAddress,java.nio.ByteBuffer> |
MultiInetAddressTransportLayerImpl.sendMessage(MultiInetSocketAddress i,
java.nio.ByteBuffer m,
MessageCallback<MultiInetSocketAddress,java.nio.ByteBuffer> deliverAckToMe,
java.util.Map<java.lang.String,java.lang.Object> options)
|
void |
MultiInetAddressTransportLayerImpl.setCallback(TransportLayerCallback<MultiInetSocketAddress,java.nio.ByteBuffer> callback)
|
void |
MultiInetAddressTransportLayerImpl.setErrorHandler(ErrorHandler<MultiInetSocketAddress> handler)
|
Constructors in org.mpisws.p2p.transport.multiaddress with parameters of type MultiInetSocketAddress | |
---|---|
MultiInetAddressTransportLayerImpl(MultiInetSocketAddress localAddress,
TransportLayer<java.net.InetSocketAddress,java.nio.ByteBuffer> wire,
Environment env,
ErrorHandler<MultiInetSocketAddress> handler,
AddressStrategy strategy)
|
Constructor parameters in org.mpisws.p2p.transport.multiaddress with type arguments of type MultiInetSocketAddress | |
---|---|
MultiInetAddressTransportLayerImpl(MultiInetSocketAddress localAddress,
TransportLayer<java.net.InetSocketAddress,java.nio.ByteBuffer> wire,
Environment env,
ErrorHandler<MultiInetSocketAddress> handler,
AddressStrategy strategy)
|
Uses of MultiInetSocketAddress in org.mpisws.p2p.transport.networkinfo |
---|
Methods in org.mpisws.p2p.transport.networkinfo with parameters of type MultiInetSocketAddress | |
---|---|
Cancellable |
ProbeStrategy.requestProbe(MultiInetSocketAddress addr,
long uid,
Continuation<java.lang.Boolean,java.lang.Exception> deliverResultToMe)
Finds another node in the network and asks them to probe the addr with the uid calls Prober.probe() on another node |
Cancellable |
InetSocketAddressLookup.verifyConnectivity(MultiInetSocketAddress local,
java.net.InetSocketAddress probeAddresses,
ConnectivityResult deliverResultToMe,
java.util.Map<java.lang.String,java.lang.Object> options)
Verify that I have connectivity by using a third party. |
Cancellable |
NetworkInfoTransportLayer.verifyConnectivity(MultiInetSocketAddress local,
java.net.InetSocketAddress probeAddress,
ConnectivityResult deliverResultToMe,
java.util.Map<java.lang.String,java.lang.Object> options)
ask probeAddress to call probeStrategy.requestProbe() |
Uses of MultiInetSocketAddress in org.mpisws.p2p.transport.sourceroute.factory |
---|
Methods in org.mpisws.p2p.transport.sourceroute.factory that return types with arguments of type MultiInetSocketAddress | |
---|---|
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<MultiInetSocketAddress> |
MultiAddressSourceRouteFactory.getSourceRoute(java.util.List<MultiInetSocketAddress> route)
|
SourceRoute<MultiInetSocketAddress> |
MultiAddressSourceRouteFactory.getSourceRoute(MultiInetSocketAddress local)
|
SourceRoute<MultiInetSocketAddress> |
MultiAddressSourceRouteFactory.getSourceRoute(MultiInetSocketAddress local,
MultiInetSocketAddress dest)
|
SourceRoute<MultiInetSocketAddress> |
MultiAddressSourceRouteFactory.reverse(SourceRoute<MultiInetSocketAddress> route)
|
Methods in org.mpisws.p2p.transport.sourceroute.factory with parameters of type MultiInetSocketAddress | |
---|---|
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<MultiInetSocketAddress> |
MultiAddressSourceRouteFactory.getSourceRoute(MultiInetSocketAddress local)
|
SourceRoute<MultiInetSocketAddress> |
MultiAddressSourceRouteFactory.getSourceRoute(MultiInetSocketAddress local,
MultiInetSocketAddress dest)
|
Method parameters in org.mpisws.p2p.transport.sourceroute.factory with type arguments of type MultiInetSocketAddress | |
---|---|
SourceRoute<MultiInetSocketAddress> |
MultiAddressSourceRouteFactory.getSourceRoute(java.util.List<MultiInetSocketAddress> route)
|
SourceRoute<MultiInetSocketAddress> |
MultiAddressSourceRouteFactory.reverse(SourceRoute<MultiInetSocketAddress> route)
|
Uses of MultiInetSocketAddress in rice.pastry.peerreview |
---|
Methods in rice.pastry.peerreview that return types with arguments of type MultiInetSocketAddress | |
---|---|
TransportLayerNodeHandle<MultiInetSocketAddress> |
PeerReviewCallbackImpl.getLocalIdentifier()
|
java.util.Collection<TransportLayerNodeHandle<MultiInetSocketAddress>> |
PeerReviewCallbackImpl.getMyWitnessedNodes()
|
PeerReviewCallback<TransportLayerNodeHandle<MultiInetSocketAddress>,Id> |
PeerReviewCallbackImpl.getReplayInstance(Verifier<TransportLayerNodeHandle<MultiInetSocketAddress>> v)
Construct a PastryNode down to my layer (figure out how to borrow the code from the PastryNodeFactory) Construct a PeerReviewCallbackImpl with the PastryNode/Verifier Construct the layers above self, attach them appropriately. |
SocketRequestHandle<TransportLayerNodeHandle<MultiInetSocketAddress>> |
PeerReviewCallbackImpl.openSocket(TransportLayerNodeHandle<MultiInetSocketAddress> i,
SocketCallback<TransportLayerNodeHandle<MultiInetSocketAddress>> deliverSocketToMe,
java.util.Map<java.lang.String,java.lang.Object> options)
|
MessageRequestHandle<TransportLayerNodeHandle<MultiInetSocketAddress>,java.nio.ByteBuffer> |
PeerReviewCallbackImpl.sendMessage(TransportLayerNodeHandle<MultiInetSocketAddress> i,
java.nio.ByteBuffer m,
MessageCallback<TransportLayerNodeHandle<MultiInetSocketAddress>,java.nio.ByteBuffer> deliverAckToMe,
java.util.Map<java.lang.String,java.lang.Object> options)
|
Constructor parameters in rice.pastry.peerreview with type arguments of type MultiInetSocketAddress | |
---|---|
PeerReviewCallbackImpl(PastryNode pn,
TransportLayer<TransportLayerNodeHandle<MultiInetSocketAddress>,java.nio.ByteBuffer> tl,
CallbackFactory nodeFactory)
|
|
PeerReviewCallbackImpl(TransportLayer<TransportLayerNodeHandle<MultiInetSocketAddress>,java.nio.ByteBuffer> tl)
|
Uses of MultiInetSocketAddress in rice.pastry.socket |
---|
Fields in rice.pastry.socket declared as MultiInetSocketAddress | |
---|---|
MultiInetSocketAddress |
SocketNodeHandle.eaddress
|
Fields in rice.pastry.socket with type parameters of type MultiInetSocketAddress | |
---|---|
protected TransportLayer<TransportLayerNodeHandle<MultiInetSocketAddress>,RawMessage> |
SocketPastryNodeFactory.TLBootstrapper.tl
|
Methods in rice.pastry.socket that return MultiInetSocketAddress | |
---|---|
MultiInetSocketAddress |
SocketNodeHandle.getAddress()
Returns the InetSocketAddress that should be used to contact the node |
MultiInetSocketAddress |
SocketNodeHandle.getIdentifier()
|
MultiInetSocketAddress |
SPNFIdentitySerializer.translateDown(TransportLayerNodeHandle<MultiInetSocketAddress> i)
|
MultiInetSocketAddress |
SPNFIdentitySerializer.translateUp(SourceRoute<MultiInetSocketAddress> i)
|
Methods in rice.pastry.socket with parameters of type MultiInetSocketAddress | |
---|---|
protected SocketNodeHandle |
SPNFIdentitySerializer.buildSNH(InputBuffer buf,
MultiInetSocketAddress i,
long epoch,
Id nid)
|
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<MultiInetSocketAddress,java.nio.ByteBuffer> |
SocketPastryNodeFactory.getMultiAddressSourceRouteTransportLayer(TransportLayer<java.net.InetSocketAddress,java.nio.ByteBuffer> mntl,
PastryNode pn,
MultiInetSocketAddress localAddress)
|
protected NextHopStrategy<MultiInetSocketAddress> |
SocketPastryNodeFactory.getNextHopStrategy(TransportLayer<SourceRoute<MultiInetSocketAddress>,java.nio.ByteBuffer> ltl,
LivenessProvider<SourceRoute<MultiInetSocketAddress>> livenessProvider,
Pinger<SourceRoute<MultiInetSocketAddress>> pinger,
PastryNode pn,
MultiInetSocketAddress proxyAddress,
MultiAddressSourceRouteFactory esrFactory)
|
SocketNodeHandle |
SocketNodeHandleFactory.getNodeHandle(MultiInetSocketAddress i,
long epoch,
Id id)
This is kind of weird, may need to rethink this. |
protected SocketPastryNodeFactory.TransLivenessProximity<MultiInetSocketAddress,java.nio.ByteBuffer> |
SocketPastryNodeFactory.getSourceRouteManagerLayer(TransportLayer<SourceRoute<MultiInetSocketAddress>,java.nio.ByteBuffer> ltl,
LivenessProvider<SourceRoute<MultiInetSocketAddress>> livenessProvider,
Pinger<SourceRoute<MultiInetSocketAddress>> pinger,
PastryNode pn,
MultiInetSocketAddress proxyAddress,
MultiAddressSourceRouteFactory esrFactory)
|
protected SourceRouteStrategy<MultiInetSocketAddress> |
SocketPastryNodeFactory.getSourceRouteStrategy(TransportLayer<SourceRoute<MultiInetSocketAddress>,java.nio.ByteBuffer> ltl,
LivenessProvider<SourceRoute<MultiInetSocketAddress>> livenessProvider,
Pinger<SourceRoute<MultiInetSocketAddress>> pinger,
PastryNode pn,
MultiInetSocketAddress proxyAddress,
MultiAddressSourceRouteFactory esrFactory)
|
PastryNode |
SocketPastryNodeFactory.newNode(Id nodeId,
MultiInetSocketAddress pAddress)
Method which creates a Pastry node from the next port with the specified nodeId (or one generated from the NodeIdFactory if not specified) |
protected void |
SocketPastryNodeFactory.newNodeSelector(Id nodeId,
MultiInetSocketAddress proxyAddress,
Continuation<PastryNode,java.io.IOException> deliverResultToMe,
java.util.Map<java.lang.String,java.lang.Object> initialVars)
Only call this on the selector thread. |
Constructors in rice.pastry.socket with parameters of type MultiInetSocketAddress | |
---|---|
SocketNodeHandle(MultiInetSocketAddress eisa,
long epoch,
Id id,
PastryNode node)
|
Constructor parameters in rice.pastry.socket with type arguments of type MultiInetSocketAddress | |
---|---|
SocketPastryNodeFactory.TLBootstrapper(PastryNode pn,
TransportLayer<TransportLayerNodeHandle<MultiInetSocketAddress>,RawMessage> tl,
SocketNodeHandleFactory handleFactory,
ProximityNeighborSelector pns)
|
Uses of MultiInetSocketAddress in rice.pastry.socket.appsocket |
---|
Methods in rice.pastry.socket.appsocket that return types with arguments of type MultiInetSocketAddress | |
---|---|
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 MultiInetSocketAddress | |
---|---|
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 MultiInetSocketAddress in rice.pastry.socket.internet |
---|
Methods in rice.pastry.socket.internet with parameters of type MultiInetSocketAddress | |
---|---|
protected boolean |
InternetPastryNodeFactory.isInternetRoutable(MultiInetSocketAddress proxyAddress)
|
protected void |
InternetPastryNodeFactory.newNodeSelector(Id nodeId,
MultiInetSocketAddress proxyAddress,
Continuation<PastryNode,java.io.IOException> deliverResultToMe,
java.util.Map<java.lang.String,java.lang.Object> initialVars)
This is where the action takes place. |
protected boolean |
InternetPastryNodeFactory.shouldCheckConnectivity(MultiInetSocketAddress proxyAddress,
java.util.Collection<java.net.InetSocketAddress> bootstraps)
|
protected void |
InternetPastryNodeFactory.verifyConnectivityThenMakeNewNode(Id nodeId,
MultiInetSocketAddress proxyAddress,
Continuation<PastryNode,java.io.IOException> deliverResultToMe)
Verifies the connectivity (if necessary), then calls super.newNodeSelector() if connectivity fails, then uses Rendezvous |
Uses of MultiInetSocketAddress in rice.pastry.socket.nat.connectivityverifiier |
---|
Methods in rice.pastry.socket.nat.connectivityverifiier with parameters of type MultiInetSocketAddress | |
---|---|
Cancellable |
ConnectivityVerifier.verifyConnectivity(MultiInetSocketAddress local,
java.util.Collection<java.net.InetSocketAddress> probeAddresses,
ConnectivityResult deliverResultToMe)
Verify my connectivity using a 3rd party |
Cancellable |
ConnectivityVerifierImpl.verifyConnectivity(MultiInetSocketAddress local,
java.util.Collection<java.net.InetSocketAddress> probeAddresses,
ConnectivityResult deliverResultToMe)
Call this to determine if your connectivity is good. |
void |
ConnectivityVerifierImpl.verifyConnectivityHelper(InetSocketAddressLookup lookup,
AttachableCancellable ret,
MultiInetSocketAddress local,
java.util.List<java.net.InetSocketAddress> probeList,
ConnectivityResult deliverResultToMe)
|
Uses of MultiInetSocketAddress in rice.pastry.socket.nat.probe |
---|
Methods in rice.pastry.socket.nat.probe that return MultiInetSocketAddress | |
---|---|
MultiInetSocketAddress |
ProbeRequestMessage.getProbeRequester()
|
Methods in rice.pastry.socket.nat.probe with parameters of type MultiInetSocketAddress | |
---|---|
Cancellable |
ProbeApp.requestProbe(MultiInetSocketAddress addr,
long uid,
Continuation<java.lang.Boolean,java.lang.Exception> deliverResultToMe)
Send a ProbeRequestMessage to a node in the leafset. |
Constructors in rice.pastry.socket.nat.probe with parameters of type MultiInetSocketAddress | |
---|---|
ProbeRequestMessage(MultiInetSocketAddress probeRequestor,
long uid,
int appAddress)
|
Uses of MultiInetSocketAddress in rice.pastry.socket.nat.rendezvous |
---|
Methods in rice.pastry.socket.nat.rendezvous with parameters of type MultiInetSocketAddress | |
---|---|
protected SocketNodeHandle |
RendezvousSPNFIdentitySerializer.buildSNH(InputBuffer buf,
MultiInetSocketAddress i,
long epoch,
Id nid)
|
java.util.Collection<MultiInetSocketAddress> |
RendezvousLeafSetNHStrategy.getNextHops(MultiInetSocketAddress destination)
|
protected NextHopStrategy<MultiInetSocketAddress> |
RendezvousSocketPastryNodeFactory.getNextHopStrategy(TransportLayer<SourceRoute<MultiInetSocketAddress>,java.nio.ByteBuffer> ltl,
LivenessProvider<SourceRoute<MultiInetSocketAddress>> livenessProvider,
Pinger<SourceRoute<MultiInetSocketAddress>> pinger,
PastryNode pn,
MultiInetSocketAddress proxyAddress,
MultiAddressSourceRouteFactory esrFactory)
|
SocketNodeHandle |
RendezvousSNHFactory.getNodeHandle(MultiInetSocketAddress i,
long epoch,
Id id)
|
SocketNodeHandle |
RendezvousSNHFactory.getNodeHandle(MultiInetSocketAddress i,
long epoch,
Id id,
byte contactState)
|
protected void |
RendezvousSocketPastryNodeFactory.newNodeSelector(Id nodeId,
MultiInetSocketAddress proxyAddress,
Continuation<PastryNode,java.io.IOException> deliverResultToMe,
java.util.Map<java.lang.String,java.lang.Object> initialVars,
boolean firewalled)
Can override the contactState on a per-node basis |
protected void |
RendezvousSocketPastryNodeFactory.newNodeSelector(Id nodeId,
MultiInetSocketAddress proxyAddress,
Continuation<PastryNode,java.io.IOException> deliverResultToMe,
java.util.Map<java.lang.String,java.lang.Object> initialVars,
byte contactState)
Can override the contactState on a per-node basis |
Constructor parameters in rice.pastry.socket.nat.rendezvous with type arguments of type MultiInetSocketAddress | |
---|---|
RendezvousRouterStrategy(PriorityTransportLayer<MultiInetSocketAddress> priority,
Environment env)
|
Uses of MultiInetSocketAddress in rice.pastry.transport |
---|
Methods in rice.pastry.transport that return types with arguments of type MultiInetSocketAddress | |
---|---|
java.util.Collection<MultiInetSocketAddress> |
LeafSetNHStrategy.getNextHops(MultiInetSocketAddress destination)
|
Methods in rice.pastry.transport with parameters of type MultiInetSocketAddress | |
---|---|
java.util.Collection<MultiInetSocketAddress> |
LeafSetNHStrategy.getNextHops(MultiInetSocketAddress destination)
|
|
Rice Pastry API | |||||||||
PREV NEXT | FRAMES NO FRAMES |