Rice Pastry API

Uses of Class
rice.pastry.socket.EpochInetSocketAddress

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

Copyright © 2001-2005 - Rice Pastry.


Imprint-Dataprotection