|
Rice Pastry API | |||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use EpochInetSocketAddress | |
---|---|
rice.pastry.socket | |
rice.pastry.socket.messaging |
Uses of EpochInetSocketAddress in rice.pastry.socket |
---|
Fields in rice.pastry.socket declared as EpochInetSocketAddress | |
---|---|
protected EpochInetSocketAddress |
PingManager.Envelope.destination
|
protected EpochInetSocketAddress |
SocketNodeHandle.eaddress
|
protected EpochInetSocketAddress[] |
SourceRoute.path
|
Methods in rice.pastry.socket that return EpochInetSocketAddress | |
---|---|
static EpochInetSocketAddress |
EpochInetSocketAddress.build(InputBuffer buf)
EpochInetSocketAddress: (IPV4): +-+-+-+-+-+-+-+-+ + numAddrs + +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+ + internet address 0 + +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+ + port 0 + +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+ + internet address 1 + +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+ + port 1 + +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+ + internet address k + +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+ + port k + ... |
static EpochInetSocketAddress[] |
SocketChannelRepeater.decodeFullHeader(byte[] array,
int num)
|
static EpochInetSocketAddress |
SocketChannelRepeater.decodeHeader(byte[] array)
Method which can be used to decode the necessary header for the intermediate hop |
static EpochInetSocketAddress |
SocketChannelRepeater.decodeHeader(byte[] array,
int offset)
Method which can be used to decode the necessary header for the intermediate hop |
EpochInetSocketAddress |
SocketNodeHandle.getEpochAddress()
|
EpochInetSocketAddress |
SourceRoute.getFirstHop()
Method which returns the first "hop" of this source route |
EpochInetSocketAddress |
SourceRoute.getHop(int i)
Returns the hop at the given index |
EpochInetSocketAddress |
SourceRoute.getLastHop()
Method which returns the first "hop" of this source route |
Methods in rice.pastry.socket with parameters of type EpochInetSocketAddress | |
---|---|
boolean |
EpochInetSocketAddress.addressEquals(EpochInetSocketAddress that)
|
SourceRoute |
SourceRoute.append(EpochInetSocketAddress address)
Method which creates a new source route by appending the given address to the end of this one |
void |
SocketSourceRouteManager.bootstrap(EpochInetSocketAddress address,
Message msg)
Method which sends a bootstrap message across the wire. |
static SourceRoute |
SourceRoute.build(EpochInetSocketAddress address)
Constructor. |
static SourceRoute |
SourceRoute.build(EpochInetSocketAddress[] path)
Constructor. |
void |
SocketSourceRouteManager.checkLiveness(EpochInetSocketAddress address)
Method which FORCES a check of liveness of the remote node. |
void |
SocketSourceRouteManager.connect(EpochInetSocketAddress address,
int appAddress,
AppSocketReceiver receiver,
int timeout)
Method which sends a message across the wire. |
protected void |
SocketCollectionManager.SourceRouteManager.createConnection(EpochInetSocketAddress address)
Creates the outgoing socket to the remote handle |
void |
SocketCollectionManager.declaredDead(EpochInetSocketAddress address)
Method which should be called when a remote node is declared dead. |
SocketNodeHandle |
TimerWeakHashSet.get(EpochInetSocketAddress eisa)
|
SocketNodeHandle |
WeakHashSet.get(EpochInetSocketAddress eisa)
|
java.net.InetSocketAddress |
EpochInetSocketAddress.getAddress(EpochInetSocketAddress local)
Method which returns the address of this address |
SocketSourceRouteManager.AddressManager |
SocketSourceRouteManager.getAddressManager(EpochInetSocketAddress address)
|
protected SocketSourceRouteManager.AddressManager |
SocketSourceRouteManager.getAddressManager(EpochInetSocketAddress address,
boolean search)
Internal method which returns (or builds) the manager associated with an address |
protected SourceRoute[] |
SocketSourceRouteManager.getAllRoutes(EpochInetSocketAddress destination)
Internal method which returns a list of all possible routes to a given address. |
protected SourceRoute |
SocketSourceRouteManager.getBestRoute(EpochInetSocketAddress address)
Internal method which returns the best known route to the given destination |
int |
SocketSourceRouteManager.getLiveness(EpochInetSocketAddress address)
Method which returns the last cached liveness value for the given address. |
SocketNodeHandle |
SocketSourceRouteManager.getNodeHandle(EpochInetSocketAddress address)
|
boolean |
SourceRoute.goesThrough(EpochInetSocketAddress address)
Returns whether or not this route goes through the given address |
protected void |
SocketSourceRouteManager.markDead(EpochInetSocketAddress address)
This method should be called when a known node is declared dead - this is ONLY called when a new epoch of that node is detected. |
void |
SocketSourceRouteManager.ping(EpochInetSocketAddress address)
Method which suggests a ping to the remote node. |
SourceRoute |
SourceRoute.prepend(EpochInetSocketAddress address)
Method which creates a new source route by appending the given address to the end of this one |
int |
SocketSourceRouteManager.proximity(EpochInetSocketAddress address)
Method which returns the last cached proximity value for the given address. |
SocketSourceRouteManager.AddressManager |
SocketSourceRouteManager.putAddressManager(EpochInetSocketAddress address,
boolean search)
Should be called while synchronized on nodeHandles |
protected void |
SocketSourceRouteManager.reroute(EpochInetSocketAddress address,
SocketBuffer m)
Reroutes the given message. |
SourceRoute |
SourceRoute.reverse(EpochInetSocketAddress localAddress)
Method which revereses path and cliams the corresponding address |
void |
SocketSourceRouteManager.send(EpochInetSocketAddress address,
Message msg)
|
void |
SocketSourceRouteManager.send(EpochInetSocketAddress address,
SocketBuffer message)
Method which sends a message across the wire. |
void |
SocketPastryNode.setSocketElements(EpochInetSocketAddress address,
int lsmf,
int rsmf)
Helper method which allows the WirePastryNodeFactory to initialize a number of the pastry node's elements. |
Constructors in rice.pastry.socket with parameters of type EpochInetSocketAddress | |
---|---|
PingManager.Envelope(EpochInetSocketAddress destination,
SocketBuffer data)
Constructor for Envelope. |
|
PingManager(SocketPastryNode spn,
SocketSourceRouteManager manager,
EpochInetSocketAddress bindAddress,
EpochInetSocketAddress proxyAddress)
|
|
SocketBuffer(EpochInetSocketAddress address,
SourceRoute path,
PRawMessage msg)
This serializes UDP messages with the appropriate source route header. |
|
SocketCollectionManager(SocketPastryNode node,
SocketSourceRouteManager manager,
EpochInetSocketAddress bindAddress,
EpochInetSocketAddress proxyAddress,
RandomSource random)
Constructs a new SocketManager. |
|
SocketNodeHandle(EpochInetSocketAddress address,
Id nodeId)
Constructor |
|
SocketSourceRouteManager(SocketPastryNode node,
EpochInetSocketAddress bindAddress,
EpochInetSocketAddress proxyAddress,
RandomSource random)
Constructor |
Uses of EpochInetSocketAddress in rice.pastry.socket.messaging |
---|
Fields in rice.pastry.socket.messaging declared as EpochInetSocketAddress | |
---|---|
protected EpochInetSocketAddress |
WrongEpochMessage.correct
|
protected EpochInetSocketAddress |
WrongEpochMessage.incorrect
|
Methods in rice.pastry.socket.messaging that return EpochInetSocketAddress | |
---|---|
EpochInetSocketAddress |
WrongEpochMessage.getCorrect()
|
EpochInetSocketAddress |
WrongEpochMessage.getIncorrect()
|
Constructors in rice.pastry.socket.messaging with parameters of type EpochInetSocketAddress | |
---|---|
WrongEpochMessage(EpochInetSocketAddress incorrect,
EpochInetSocketAddress correct,
long start)
Constructor |
|
Rice Pastry API | |||||||||
PREV NEXT | FRAMES NO FRAMES |