A B C D E F G H I K L M N O P R S T U V

A

AcknowledgeMessage - class org.planx.xmlstore.routing.operation.AcknowledgeMessage.

AcknowledgeMessage() - Constructor for class org.planx.xmlstore.routing.operation.AcknowledgeMessage

AcknowledgeMessage(Node) - Constructor for class org.planx.xmlstore.routing.operation.AcknowledgeMessage

AcknowledgeMessage(DataInput) - Constructor for class org.planx.xmlstore.routing.operation.AcknowledgeMessage

B

B - Variable in class org.planx.xmlstore.routing.Configuration

Log base exponent.

baseTime - Variable in class org.planx.xmlstore.routing.operation.HashMessage

begin - Variable in class org.planx.xmlstore.routing.operation.StoreRequestMessage

C

CODE_ACKNOWLEDGE - Static variable in class org.planx.xmlstore.routing.operation.MessageFactoryImpl

CODE_CONNECT - Static variable in class org.planx.xmlstore.routing.operation.MessageFactoryImpl

CODE_DATA - Static variable in class org.planx.xmlstore.routing.operation.MessageFactoryImpl

CODE_DATA_LOOKUP - Static variable in class org.planx.xmlstore.routing.operation.MessageFactoryImpl

CODE_HASH - Static variable in class org.planx.xmlstore.routing.operation.MessageFactoryImpl

CODE_HASH_REQUEST - Static variable in class org.planx.xmlstore.routing.operation.MessageFactoryImpl

CODE_NODE_LOOKUP - Static variable in class org.planx.xmlstore.routing.operation.MessageFactoryImpl

CODE_NODE_REPLY - Static variable in class org.planx.xmlstore.routing.operation.MessageFactoryImpl

CODE_REMOVE - Static variable in class org.planx.xmlstore.routing.operation.MessageFactoryImpl

CODE_STORE - Static variable in class org.planx.xmlstore.routing.operation.MessageFactoryImpl

CODE_STORE_REQUEST - Static variable in class org.planx.xmlstore.routing.operation.MessageFactoryImpl

CONCURRENCY - Variable in class org.planx.xmlstore.routing.Configuration

Maximum number of concurrent messages in transit.

Configuration - class org.planx.xmlstore.routing.Configuration.

A set of Kademlia configuration parameters.

Configuration() - Constructor for class org.planx.xmlstore.routing.Configuration

ConnectMessage - class org.planx.xmlstore.routing.operation.ConnectMessage.

ConnectMessage() - Constructor for class org.planx.xmlstore.routing.operation.ConnectMessage

ConnectMessage(Node) - Constructor for class org.planx.xmlstore.routing.operation.ConnectMessage

ConnectMessage(DataInput) - Constructor for class org.planx.xmlstore.routing.operation.ConnectMessage

ConnectOperation - class org.planx.xmlstore.routing.operation.ConnectOperation.

Connects to an existing Kademlia network using a bootstrap node.

ConnectOperation(Configuration, MessageServer, Space, Node, InetAddress, int) - Constructor for class org.planx.xmlstore.routing.operation.ConnectOperation

ConnectReceiver - class org.planx.xmlstore.routing.operation.ConnectReceiver.

Receives a ConnectMessage and sends an AcknowledgeMessage as reply.

ConnectReceiver(MessageServer, Node, Space) - Constructor for class org.planx.xmlstore.routing.operation.ConnectReceiver

calculateHash(List) - Method in class org.planx.xmlstore.routing.HashCalculator

Calculates a unique hash of the keys in the specified bundle.

close() - Method in interface org.planx.xmlstore.routing.DistributedMap

Closes the map and releases all ressources.

close() - Method in class org.planx.xmlstore.routing.Kademlia

Closes the map.

close() - Method in class org.planx.xmlstore.routing.messaging.MessageServer

Signals to the MessageServer thread that it should stop running.

code() - Method in interface org.planx.xmlstore.routing.messaging.Message

The unique code for the message type, used to differentiate all messages from each other.

code() - Method in class org.planx.xmlstore.routing.operation.AcknowledgeMessage

code() - Method in class org.planx.xmlstore.routing.operation.ConnectMessage

code() - Method in class org.planx.xmlstore.routing.operation.DataLookupMessage

code() - Method in class org.planx.xmlstore.routing.operation.DataMessage

code() - Method in class org.planx.xmlstore.routing.operation.HashMessage

code() - Method in class org.planx.xmlstore.routing.operation.HashRequestMessage

code() - Method in class org.planx.xmlstore.routing.operation.LookupMessage

code() - Method in class org.planx.xmlstore.routing.operation.NodeLookupMessage

code() - Method in class org.planx.xmlstore.routing.operation.NodeReplyMessage

code() - Method in class org.planx.xmlstore.routing.operation.OriginMessage

code() - Method in class org.planx.xmlstore.routing.operation.RemoveMessage

code() - Method in class org.planx.xmlstore.routing.operation.StoreMessage

code() - Method in class org.planx.xmlstore.routing.operation.StoreRequestMessage

compare(Object, Object) - Method in class org.planx.xmlstore.routing.Node.DistanceComparator

Compare two objects which must both be of type Node and determine which is closest to the identifier specified in the constructor.

compare(Object, Object) - Method in class org.planx.xmlstore.routing.Node.FirstSeenComparator

Compare two objects which must both be of type Node and determine which is seen first.

compare(Object, Object) - Method in class org.planx.xmlstore.routing.Node.LastSeenComparator

Compare two objects which must both be of type Node and determine which is seen last.

conf - Variable in class org.planx.xmlstore.routing.operation.NodeLookupOperation

connect(InetSocketAddress) - Method in class org.planx.xmlstore.routing.Kademlia

Attempts to connect to an existing peer-to-peer network.

contains(Identifier) - Method in interface org.planx.xmlstore.routing.DistributedMap

Returns true if the map contains the specified key and false otherwise.

contains(Identifier) - Method in class org.planx.xmlstore.routing.Kademlia

Returns true if the map contains the specified key and false otherwise.

createMessage(byte, DataInput) - Method in interface org.planx.xmlstore.routing.messaging.MessageFactory

Creates a Message of type code from the specified stream.

createMessage(byte, DataInput) - Method in class org.planx.xmlstore.routing.operation.MessageFactoryImpl

createReceiver(byte, MessageServer) - Method in interface org.planx.xmlstore.routing.messaging.MessageFactory

Creates a Receiver for handling a Message of type code.

createReceiver(byte, MessageServer) - Method in class org.planx.xmlstore.routing.operation.MessageFactoryImpl

D

DataLookupMessage - class org.planx.xmlstore.routing.operation.DataLookupMessage.

DataLookupMessage() - Constructor for class org.planx.xmlstore.routing.operation.DataLookupMessage

DataLookupMessage(Node, Identifier) - Constructor for class org.planx.xmlstore.routing.operation.DataLookupMessage

DataLookupMessage(DataInput) - Constructor for class org.planx.xmlstore.routing.operation.DataLookupMessage

DataLookupOperation - class org.planx.xmlstore.routing.operation.DataLookupOperation.

Looks up the specified identifier and returns the value associated with it.

DataLookupOperation(Configuration, MessageServer, Space, Node, Identifier) - Constructor for class org.planx.xmlstore.routing.operation.DataLookupOperation

DataLookupReceiver - class org.planx.xmlstore.routing.operation.DataLookupReceiver.

Responds to a DataLookupMessage by sending a DataMessage containing the requested mapping or by sending a NodeReplyMessage containing the K closest nodes to the request key known by this node.

DataLookupReceiver(MessageServer, Node, Space, Map) - Constructor for class org.planx.xmlstore.routing.operation.DataLookupReceiver

DataMessage - class org.planx.xmlstore.routing.operation.DataMessage.

DataMessage() - Constructor for class org.planx.xmlstore.routing.operation.DataMessage

DataMessage(Node, Identifier, TimestampedValue) - Constructor for class org.planx.xmlstore.routing.operation.DataMessage

DataMessage(DataInput) - Constructor for class org.planx.xmlstore.routing.operation.DataMessage

DistributedMap - interface org.planx.xmlstore.routing.DistributedMap.

Maps keys to values in a distributed setting using Identifiers as keys.

E

end - Variable in class org.planx.xmlstore.routing.operation.StoreRequestMessage

equals(Object) - Method in class org.planx.xmlstore.routing.Identifier

equals(Object) - Method in class org.planx.xmlstore.routing.Node

Returns true if o is a Node and has the same identifier as this.

error - Variable in class org.planx.xmlstore.routing.operation.NodeLookupOperation

execute() - Method in class org.planx.xmlstore.routing.operation.ConnectOperation

execute() - Method in class org.planx.xmlstore.routing.operation.DataLookupOperation

execute() - Method in class org.planx.xmlstore.routing.operation.NodeLookupOperation

execute() - Method in class org.planx.xmlstore.routing.operation.Operation

Starts the operation and returns when the operation is finished.

execute() - Method in class org.planx.xmlstore.routing.operation.RefreshOperation

execute() - Method in class org.planx.xmlstore.routing.operation.RemoveOperation

execute() - Method in class org.planx.xmlstore.routing.operation.RestoreOperation

execute() - Method in class org.planx.xmlstore.routing.operation.StoreOperation

F

FIRSTSEEN_COMPARATOR - Static variable in class org.planx.xmlstore.routing.Node

firstSeen() - Method in class org.planx.xmlstore.routing.Node

Returns the time this node was first seen.

fromStream(DataInput) - Method in class org.planx.xmlstore.routing.Identifier

fromStream(DataInput) - Method in class org.planx.xmlstore.routing.Node

fromStream(DataInput) - Method in class org.planx.xmlstore.routing.TimestampedValue

fromStream(DataInput) - Method in interface org.planx.xmlstore.routing.messaging.Streamable

Reads the internal state of the Streamable object from the input stream.

fromStream(DataInput) - Method in class org.planx.xmlstore.routing.operation.DataMessage

fromStream(DataInput) - Method in class org.planx.xmlstore.routing.operation.HashMessage

fromStream(DataInput) - Method in class org.planx.xmlstore.routing.operation.LookupMessage

fromStream(DataInput) - Method in class org.planx.xmlstore.routing.operation.NodeReplyMessage

fromStream(DataInput) - Method in class org.planx.xmlstore.routing.operation.OriginMessage

fromStream(DataInput) - Method in class org.planx.xmlstore.routing.operation.RemoveMessage

fromStream(DataInput) - Method in class org.planx.xmlstore.routing.operation.StoreMessage

fromStream(DataInput) - Method in class org.planx.xmlstore.routing.operation.StoreRequestMessage

G

get(Identifier) - Method in interface org.planx.xmlstore.routing.DistributedMap

Returns the value associated with the specified key or null if does not exist.

get(Identifier) - Method in class org.planx.xmlstore.routing.Kademlia

Returns the value associated with the specified key.

getAll() - Method in class org.planx.xmlstore.routing.Space

Returns all nodes in the tree of spaces rooted at this space.

getBaseTime() - Method in class org.planx.xmlstore.routing.operation.HashMessage

getBegin() - Method in class org.planx.xmlstore.routing.operation.StoreRequestMessage

getByteArray() - Method in class org.planx.xmlstore.routing.TimestampedValue

Returns the value as a byte array.

getClosestNodes(Identifier) - Method in class org.planx.xmlstore.routing.Space

Returns the K nodes known by this space closest to the specified id.

getEnd() - Method in class org.planx.xmlstore.routing.operation.StoreRequestMessage

getHashes() - Method in class org.planx.xmlstore.routing.operation.HashMessage

getId() - Method in class org.planx.xmlstore.routing.Node

Returns the identifier of this node.

getInetAddress() - Method in class org.planx.xmlstore.routing.Node

Returns the IP address of this node.

getKey() - Method in class org.planx.xmlstore.routing.TimestampedEntry

getKey() - Method in class org.planx.xmlstore.routing.operation.DataMessage

getKey() - Method in class org.planx.xmlstore.routing.operation.RemoveMessage

getLookupId() - Method in class org.planx.xmlstore.routing.operation.LookupMessage

getNeighbourhood() - Method in class org.planx.xmlstore.routing.Space

Returns all nodes in the neighbourhood of the local node.

getNodes() - Method in class org.planx.xmlstore.routing.operation.NodeReplyMessage

getObject() - Method in class org.planx.xmlstore.routing.TimestampedValue

Returns the value as an Object.

getOrigin() - Method in class org.planx.xmlstore.routing.operation.OriginMessage

getPort() - Method in class org.planx.xmlstore.routing.Node

Returns the UDP port of this node.

getRefreshList() - Method in class org.planx.xmlstore.routing.Space

Returns a list containing random Identifiers in bucket ranges that needs to be refreshed.

getValue() - Method in class org.planx.xmlstore.routing.TimestampedEntry

getValue() - Method in class org.planx.xmlstore.routing.operation.DataMessage

H

HASH_LENGTH - Static variable in class org.planx.xmlstore.routing.HashCalculator

HashCalculator - class org.planx.xmlstore.routing.HashCalculator.

Calculates group hashes for mappings.

HashCalculator(Node, Space, Map) - Constructor for class org.planx.xmlstore.routing.HashCalculator

HashMessage - class org.planx.xmlstore.routing.operation.HashMessage.

HashMessage() - Constructor for class org.planx.xmlstore.routing.operation.HashMessage

HashMessage(Node, long, List) - Constructor for class org.planx.xmlstore.routing.operation.HashMessage

HashMessage(DataInput) - Constructor for class org.planx.xmlstore.routing.operation.HashMessage

HashReceiver - class org.planx.xmlstore.routing.operation.HashReceiver.

Receives a HashMessage and compares it to hashes generated locally.

HashReceiver(MessageServer, Node, Space, Map) - Constructor for class org.planx.xmlstore.routing.operation.HashReceiver

HashRequestMessage - class org.planx.xmlstore.routing.operation.HashRequestMessage.

HashRequestMessage() - Constructor for class org.planx.xmlstore.routing.operation.HashRequestMessage

HashRequestMessage(Node) - Constructor for class org.planx.xmlstore.routing.operation.HashRequestMessage

HashRequestMessage(DataInput) - Constructor for class org.planx.xmlstore.routing.operation.HashRequestMessage

HashRequestReceiver - class org.planx.xmlstore.routing.operation.HashRequestReceiver.

Receives a HashRequestMessage and replies with a HashMessage containing group hashes of mappings that should both be available at the local node and the origin node.

HashRequestReceiver(MessageServer, Node, Space, Map) - Constructor for class org.planx.xmlstore.routing.operation.HashRequestReceiver

hashCode() - Method in class org.planx.xmlstore.routing.Identifier

hashCode() - Method in class org.planx.xmlstore.routing.Node

hashes - Variable in class org.planx.xmlstore.routing.operation.HashMessage

I

IDSIZE - Static variable in class org.planx.xmlstore.routing.Identifier

Number of bits in an ID.

Identifier - class org.planx.xmlstore.routing.Identifier.

An identifier consists of at most Identifier.IDSIZE bit and it is always positive.

Identifier() - Constructor for class org.planx.xmlstore.routing.Identifier

Constructs an Identifier with value 0.

Identifier(byte[]) - Constructor for class org.planx.xmlstore.routing.Identifier

Constructs an Identifier from the specified byte array which is interpreted as a positive integer in big-endian order (most significant byte is in the zeroth element)

Identifier(BigInteger) - Constructor for class org.planx.xmlstore.routing.Identifier

Constructs an Identifier from the specified BigInteger.

Identifier(DataInput) - Constructor for class org.planx.xmlstore.routing.Identifier

Constructs an Identifier by reading IDSIZE/8 bytes from the specified DataInput.

id - Variable in class org.planx.xmlstore.routing.operation.NodeLookupOperation

incFailCount() - Method in class org.planx.xmlstore.routing.Node

Increments the failure counter and returns the new value.

insertNode(Node) - Method in class org.planx.xmlstore.routing.Space

Inserts the specified node into this space.

K

K - Variable in class org.planx.xmlstore.routing.Configuration

Bucket size.

Kademlia - class org.planx.xmlstore.routing.Kademlia.

Maps keys to values in a distributed setting using the Kademlia protocol.

Kademlia(Identifier, int) - Constructor for class org.planx.xmlstore.routing.Kademlia

Creates a Kademlia DistributedMap with the specified identifier and no persistence.

Kademlia(Identifier, int, Configuration) - Constructor for class org.planx.xmlstore.routing.Kademlia

Creates a Kademlia DistributedMap with the specified identifier and no persistence.

Kademlia(String, int, InetSocketAddress, Configuration) - Constructor for class org.planx.xmlstore.routing.Kademlia

Creates a Kademlia DistributedMap using the specified name as filename base.

Kademlia(String, Identifier, int, InetSocketAddress, Configuration) - Constructor for class org.planx.xmlstore.routing.Kademlia

Creates a Kademlia DistributedMap using the specified name as filename base.

key - Variable in class org.planx.xmlstore.routing.operation.DataMessage

key - Variable in class org.planx.xmlstore.routing.operation.RemoveMessage

L

LASTSEEN_COMPARATOR - Static variable in class org.planx.xmlstore.routing.Node

LookupMessage - class org.planx.xmlstore.routing.operation.LookupMessage.

LookupMessage() - Constructor for class org.planx.xmlstore.routing.operation.LookupMessage

LookupMessage(Node, Identifier) - Constructor for class org.planx.xmlstore.routing.operation.LookupMessage

LookupMessage(DataInput) - Constructor for class org.planx.xmlstore.routing.operation.LookupMessage

lastSeen() - Method in class org.planx.xmlstore.routing.Node

Returns the time this node was last seen.

local - Variable in class org.planx.xmlstore.routing.operation.NodeLookupOperation

local - Variable in class org.planx.xmlstore.routing.operation.OriginReceiver

localMap - Variable in class org.planx.xmlstore.routing.operation.DataLookupReceiver

logarithmicHashes(Node, long) - Method in class org.planx.xmlstore.routing.HashCalculator

Calculates bundled hashes of the set of keys which is the intersection of keys that both the local node and the specified node are responsible for.

lookup - Variable in class org.planx.xmlstore.routing.operation.LookupMessage

lookupMessage - Variable in class org.planx.xmlstore.routing.operation.NodeLookupOperation

Message sent to each peer.

M

Message - interface org.planx.xmlstore.routing.messaging.Message.

MessageFactory - interface org.planx.xmlstore.routing.messaging.MessageFactory.

Creates Message and Receiver objects based on message code types.

MessageFactoryImpl - class org.planx.xmlstore.routing.operation.MessageFactoryImpl.

Essentially this class translates numbers into classes.

MessageFactoryImpl(Map, Node, Space) - Constructor for class org.planx.xmlstore.routing.operation.MessageFactoryImpl

MessageServer - class org.planx.xmlstore.routing.messaging.MessageServer.

Listens for incoming UDP messages and provides a framework for sending messages and responding to received messages.

MessageServer(int, MessageFactory, long) - Constructor for class org.planx.xmlstore.routing.messaging.MessageServer

Constructs a MessageServer listening on the specified UDP port using the specified MessageFactory for interpreting incoming messages.

mappingsBetween(Node, long, long) - Method in class org.planx.xmlstore.routing.HashCalculator

Returns the subset of mappings in the local map with timestamps between begin (including) and end (not including) that the specified node is also responsible for.

N

NeighbourhoodListener - interface org.planx.xmlstore.routing.NeighbourhoodListener.

Listens for newly arrived nodes in the neighbourhood of the local node.

NeighbourhoodListenerImpl - class org.planx.xmlstore.routing.NeighbourhoodListenerImpl.

When a new node is inserted into the neighbourhood of the local node a HashRequestMessage is sent to it.

NeighbourhoodListenerImpl(Node) - Constructor for class org.planx.xmlstore.routing.NeighbourhoodListenerImpl

Note that the MessageServer must be set with NeighbourhoodListenerImpl.setMessageServer(org.planx.xmlstore.routing.messaging.MessageServer) before use.

Node - class org.planx.xmlstore.routing.Node.

Represents a node and contains information about the IP address, UDP port, and ID of the node.

Node(InetAddress, int, Identifier) - Constructor for class org.planx.xmlstore.routing.Node

Constructs a node with the specified IP address, UDP port, and identifier.

Node(DataInput) - Constructor for class org.planx.xmlstore.routing.Node

Constructs a node by reading the state from a DataInput.

Node.DistanceComparator - class org.planx.xmlstore.routing.Node.DistanceComparator.

A DistanceComparator is capable of comparing Node objects according to closeness to a predetermined identifier using the XOR metric.

Node.DistanceComparator(Identifier) - Constructor for class org.planx.xmlstore.routing.Node.DistanceComparator

The identifier relative to which the distance should be measured.

Node.FirstSeenComparator - class org.planx.xmlstore.routing.Node.FirstSeenComparator.

A FirstSeenComparator is capable of comparing Node objects according to time first seen.

Node.FirstSeenComparator() - Constructor for class org.planx.xmlstore.routing.Node.FirstSeenComparator

Node.LastSeenComparator - class org.planx.xmlstore.routing.Node.LastSeenComparator.

A LastSeenComparator is capable of comparing Node objects according to time last seen.

Node.LastSeenComparator() - Constructor for class org.planx.xmlstore.routing.Node.LastSeenComparator

NodeLookupMessage - class org.planx.xmlstore.routing.operation.NodeLookupMessage.

NodeLookupMessage() - Constructor for class org.planx.xmlstore.routing.operation.NodeLookupMessage

NodeLookupMessage(Node, Identifier) - Constructor for class org.planx.xmlstore.routing.operation.NodeLookupMessage

NodeLookupMessage(DataInput) - Constructor for class org.planx.xmlstore.routing.operation.NodeLookupMessage

NodeLookupOperation - class org.planx.xmlstore.routing.operation.NodeLookupOperation.

Finds the K closest nodes to a specified identifier.

NodeLookupOperation(Configuration, MessageServer, Space, Node, Identifier) - Constructor for class org.planx.xmlstore.routing.operation.NodeLookupOperation

Create a NodeLookupOperation for the specified id.

NodeLookupReceiver - class org.planx.xmlstore.routing.operation.NodeLookupReceiver.

Handles incoming LookupMessages by sending a NodeReplyMessage containing the K closest nodes to the requested identifier.

NodeLookupReceiver(MessageServer, Node, Space) - Constructor for class org.planx.xmlstore.routing.operation.NodeLookupReceiver

NodeReplyMessage - class org.planx.xmlstore.routing.operation.NodeReplyMessage.

NodeReplyMessage() - Constructor for class org.planx.xmlstore.routing.operation.NodeReplyMessage

NodeReplyMessage(Node, List) - Constructor for class org.planx.xmlstore.routing.operation.NodeReplyMessage

NodeReplyMessage(DataInput) - Constructor for class org.planx.xmlstore.routing.operation.NodeReplyMessage

nodeArrived(Node) - Method in interface org.planx.xmlstore.routing.NeighbourhoodListener

A new node has been inserted in a bucket in the neighbourhood.

nodeArrived(Node) - Method in class org.planx.xmlstore.routing.NeighbourhoodListenerImpl

nodeCount() - Method in class org.planx.xmlstore.routing.Space

Returns the number of nodes in the range covered by this space.

nodes - Variable in class org.planx.xmlstore.routing.operation.NodeReplyMessage

O

OPERATION_TIMEOUT - Variable in class org.planx.xmlstore.routing.Configuration

Maximum number of milliseconds for performing an operation.

Operation - class org.planx.xmlstore.routing.operation.Operation.

User initiated operations should be subclasses of this class.

Operation() - Constructor for class org.planx.xmlstore.routing.operation.Operation

OriginMessage - class org.planx.xmlstore.routing.operation.OriginMessage.

A message containing the origin node.

OriginMessage() - Constructor for class org.planx.xmlstore.routing.operation.OriginMessage

OriginMessage(Node) - Constructor for class org.planx.xmlstore.routing.operation.OriginMessage

OriginMessage(DataInput) - Constructor for class org.planx.xmlstore.routing.operation.OriginMessage

OriginReceiver - class org.planx.xmlstore.routing.operation.OriginReceiver.

Handles updating of the local space when messages are received and provides easy implementation of more specific receivers.

OriginReceiver(MessageServer, Node, Space) - Constructor for class org.planx.xmlstore.routing.operation.OriginReceiver

org.planx.xmlstore.routing - package org.planx.xmlstore.routing

org.planx.xmlstore.routing.messaging - package org.planx.xmlstore.routing.messaging

org.planx.xmlstore.routing.operation - package org.planx.xmlstore.routing.operation

origin - Variable in class org.planx.xmlstore.routing.operation.OriginMessage

P

put(Identifier, Serializable) - Method in interface org.planx.xmlstore.routing.DistributedMap

Associates the specified value with the specified key.

put(Identifier, Serializable) - Method in class org.planx.xmlstore.routing.Kademlia

Associates the specified value with the specified key.

R

RCSIZE - Variable in class org.planx.xmlstore.routing.Configuration

Size of replacement cache.

RESPONSE_TIMEOUT - Variable in class org.planx.xmlstore.routing.Configuration

If no reply received from a node in this period (in milliseconds) consider the node unresponsive.

RESTORE_INTERVAL - Variable in class org.planx.xmlstore.routing.Configuration

Interval in milliseconds between execution of RestoreOperations.

Receiver - interface org.planx.xmlstore.routing.messaging.Receiver.

A Receiver waits for incoming messages and performs some action if various events occur.

RefreshOperation - class org.planx.xmlstore.routing.operation.RefreshOperation.

Refreshes all buckets.

RefreshOperation(Configuration, MessageServer, Space, Node) - Constructor for class org.planx.xmlstore.routing.operation.RefreshOperation

RemoveMessage - class org.planx.xmlstore.routing.operation.RemoveMessage.

RemoveMessage() - Constructor for class org.planx.xmlstore.routing.operation.RemoveMessage

RemoveMessage(Node, Identifier) - Constructor for class org.planx.xmlstore.routing.operation.RemoveMessage

RemoveMessage(DataInput) - Constructor for class org.planx.xmlstore.routing.operation.RemoveMessage

RemoveOperation - class org.planx.xmlstore.routing.operation.RemoveOperation.

Removes the mapping at the K closest nodes to the key of the mapping.

RemoveOperation(Configuration, MessageServer, Space, Map, Node, Identifier) - Constructor for class org.planx.xmlstore.routing.operation.RemoveOperation

RemoveReceiver - class org.planx.xmlstore.routing.operation.RemoveReceiver.

Handles incoming remove messages by removing the mapping with the specified key from the local map.

RemoveReceiver(MessageServer, Node, Space, Map) - Constructor for class org.planx.xmlstore.routing.operation.RemoveReceiver

RestoreOperation - class org.planx.xmlstore.routing.operation.RestoreOperation.

Refreshes all buckets and sends HashMessages to all nodes that are among the K closest to mappings stored at this node.

RestoreOperation(Configuration, MessageServer, Space, Node, Map) - Constructor for class org.planx.xmlstore.routing.operation.RestoreOperation

RoutingException - exception org.planx.xmlstore.routing.RoutingException.

RoutingException() - Constructor for class org.planx.xmlstore.routing.RoutingException

RoutingException(String) - Constructor for class org.planx.xmlstore.routing.RoutingException

RoutingException(Throwable) - Constructor for class org.planx.xmlstore.routing.RoutingException

RoutingException(String, Throwable) - Constructor for class org.planx.xmlstore.routing.RoutingException

randomIdentifier() - Static method in class org.planx.xmlstore.routing.Identifier

Returns a random Identifer.

receive(Message, int) - Method in interface org.planx.xmlstore.routing.messaging.Receiver

Message is received with communication identifier comm.

receive(Message, int) - Method in class org.planx.xmlstore.routing.operation.ConnectOperation

Receives an AcknowledgeMessage from the boot strap node.

receive(Message, int) - Method in class org.planx.xmlstore.routing.operation.ConnectReceiver

Responds to a ConnectMessage by sending a ConnectReplyMessage.

receive(Message, int) - Method in class org.planx.xmlstore.routing.operation.DataLookupOperation

Once a DataMessage is received the algorithm terminates.

receive(Message, int) - Method in class org.planx.xmlstore.routing.operation.DataLookupReceiver

receive(Message, int) - Method in class org.planx.xmlstore.routing.operation.HashReceiver

receive(Message, int) - Method in class org.planx.xmlstore.routing.operation.HashRequestReceiver

receive(Message, int) - Method in class org.planx.xmlstore.routing.operation.NodeLookupOperation

Receives an incoming NodeReplyMessage.

receive(Message, int) - Method in class org.planx.xmlstore.routing.operation.NodeLookupReceiver

receive(Message, int) - Method in class org.planx.xmlstore.routing.operation.OriginReceiver

Updates the local space by inserting the origin node.

receive(Message, int) - Method in class org.planx.xmlstore.routing.operation.RemoveReceiver

receive(Message, int) - Method in class org.planx.xmlstore.routing.operation.StoreReceiver

receive(Message, int) - Method in class org.planx.xmlstore.routing.operation.StoreRequestReceiver

remove(Identifier) - Method in interface org.planx.xmlstore.routing.DistributedMap

Removes the mapping with the specified key from this map.

remove(Identifier) - Method in class org.planx.xmlstore.routing.Kademlia

Removes the mapping with the specified key.

removeNode(Node) - Method in class org.planx.xmlstore.routing.Space

Marks a node as unresponsive and removes it from the tree of spaces rooted at this space if it has been marked in this way STALE times.

reply(int, Message, InetAddress, int) - Method in class org.planx.xmlstore.routing.messaging.MessageServer

Sends a reply to the message with the specified communication id.

S

STALE - Variable in class org.planx.xmlstore.routing.Configuration

Number of times a node can be marked as stale before it is actually removed.

Space - class org.planx.xmlstore.routing.Space.

Represents a space (or subspace) containing nodes.

Space(Node, Configuration) - Constructor for class org.planx.xmlstore.routing.Space

Construct an empty top level space that covers the complete range of identifiers.

Space(Node, Configuration, NeighbourhoodListener) - Constructor for class org.planx.xmlstore.routing.Space

Construct an empty top level space that covers the complete range of identifiers.

StoreMessage - class org.planx.xmlstore.routing.operation.StoreMessage.

Message representing a mapping from a key to a value.

StoreMessage() - Constructor for class org.planx.xmlstore.routing.operation.StoreMessage

StoreMessage(Node, Identifier, TimestampedValue, boolean) - Constructor for class org.planx.xmlstore.routing.operation.StoreMessage

StoreMessage(DataInput) - Constructor for class org.planx.xmlstore.routing.operation.StoreMessage

StoreOperation - class org.planx.xmlstore.routing.operation.StoreOperation.

Stores the mapping at the K closest nodes to the key.

StoreOperation(Configuration, MessageServer, Space, Map, Node, Identifier, TimestampedValue) - Constructor for class org.planx.xmlstore.routing.operation.StoreOperation

StoreReceiver - class org.planx.xmlstore.routing.operation.StoreReceiver.

Receives a StoreMessage and stores the mapping if a mapping with the same key and a newer timestamp does not exist.

StoreReceiver(MessageServer, Node, Space, Map) - Constructor for class org.planx.xmlstore.routing.operation.StoreReceiver

StoreRequestMessage - class org.planx.xmlstore.routing.operation.StoreRequestMessage.

StoreRequestMessage() - Constructor for class org.planx.xmlstore.routing.operation.StoreRequestMessage

StoreRequestMessage(Node, long, long) - Constructor for class org.planx.xmlstore.routing.operation.StoreRequestMessage

StoreRequestMessage(DataInput) - Constructor for class org.planx.xmlstore.routing.operation.StoreRequestMessage

StoreRequestReceiver - class org.planx.xmlstore.routing.operation.StoreRequestReceiver.

Receives an incoming StoreRequestMessage and issues StoreMessages for mappings in the requested interval that should be available at the origin node.

StoreRequestReceiver(MessageServer, Node, Space, Map) - Constructor for class org.planx.xmlstore.routing.operation.StoreRequestReceiver

Streamable - interface org.planx.xmlstore.routing.messaging.Streamable.

A Streamable object is able to write it's state to an output stream and a class implementing Streamable must be able to recreate an instance of the class from an input stream.

seenNow() - Method in class org.planx.xmlstore.routing.Node

Update time last seen for this node and reset fail count.

send(Message, InetAddress, int, Receiver) - Method in class org.planx.xmlstore.routing.messaging.MessageServer

Sends the specified Message and calls the specified Receiver when a reply for the message is received.

server - Variable in class org.planx.xmlstore.routing.operation.NodeLookupOperation

server - Variable in class org.planx.xmlstore.routing.operation.OriginReceiver

setMessageServer(MessageServer) - Method in class org.planx.xmlstore.routing.NeighbourhoodListenerImpl

sort(Collection, Identifier) - Static method in class org.planx.xmlstore.routing.Node

Sorts the nodes in the specified list in order of increasing distance to the specified identifier.

space - Variable in class org.planx.xmlstore.routing.operation.NodeLookupOperation

space - Variable in class org.planx.xmlstore.routing.operation.OriginReceiver

T

TimestampedEntry - class org.planx.xmlstore.routing.TimestampedEntry.

A timestamped mapping consisting of a key and value.

TimestampedEntry(Identifier, TimestampedValue) - Constructor for class org.planx.xmlstore.routing.TimestampedEntry

TimestampedValue - class org.planx.xmlstore.routing.TimestampedValue.

A wrapper class that adds a timestamp to any serializable object.

TimestampedValue(Serializable, long) - Constructor for class org.planx.xmlstore.routing.TimestampedValue

TimestampedValue(DataInput) - Constructor for class org.planx.xmlstore.routing.TimestampedValue

timeout(int) - Method in interface org.planx.xmlstore.routing.messaging.Receiver

No reply received in MessageServer.TIMEOUT seconds for the message with communication id comm.

timeout(int) - Method in class org.planx.xmlstore.routing.operation.ConnectOperation

Resends a ConnectMessage to the boot strap node a maximum of MAX_ATTEMPTS times.

timeout(int) - Method in class org.planx.xmlstore.routing.operation.NodeLookupOperation

A node does not respond or a packet was lost.

timeout(int) - Method in class org.planx.xmlstore.routing.operation.OriginReceiver

Does nothing, can be overridden by subclasses to change timeout functionality.

timestamp() - Method in class org.planx.xmlstore.routing.TimestampedValue

toBinary() - Method in class org.planx.xmlstore.routing.Identifier

Returns a binary string representation of this identifier with IDSIZE bits.

toBinary(BigInteger) - Static method in class org.planx.xmlstore.routing.Identifier

Returns a binary string representation of the specified BigInteger with IDSIZE bits.

toByteArray() - Method in class org.planx.xmlstore.routing.Identifier

Returns the value of the identifier in a byte array of size IDSIZE/8 in big-endian order (most significant byte is in the zeroth element).

toStream(DataOutput) - Method in class org.planx.xmlstore.routing.Identifier

toStream(DataOutput) - Method in class org.planx.xmlstore.routing.Node

toStream(DataOutput) - Method in class org.planx.xmlstore.routing.TimestampedValue

toStream(DataOutput) - Method in interface org.planx.xmlstore.routing.messaging.Streamable

Writes the internal state of the Streamable object to the output stream in a format that can later be read by the same Streamble class using the Streamable.fromStream(java.io.DataInput) method.

toStream(DataOutput) - Method in class org.planx.xmlstore.routing.operation.DataMessage

toStream(DataOutput) - Method in class org.planx.xmlstore.routing.operation.HashMessage

toStream(DataOutput) - Method in class org.planx.xmlstore.routing.operation.LookupMessage

toStream(DataOutput) - Method in class org.planx.xmlstore.routing.operation.NodeReplyMessage

toStream(DataOutput) - Method in class org.planx.xmlstore.routing.operation.OriginMessage

toStream(DataOutput) - Method in class org.planx.xmlstore.routing.operation.RemoveMessage

toStream(DataOutput) - Method in class org.planx.xmlstore.routing.operation.StoreMessage

toStream(DataOutput) - Method in class org.planx.xmlstore.routing.operation.StoreRequestMessage

toString() - Method in class org.planx.xmlstore.routing.Identifier

toString() - Method in class org.planx.xmlstore.routing.Kademlia

For debugging purposes, returns the contents of the internal space.

toString() - Method in class org.planx.xmlstore.routing.Node

toString() - Method in class org.planx.xmlstore.routing.Space

For debugging purposes, returns a string containing an XML document representing the binary tree of spaces rooted at this space.

toString() - Method in class org.planx.xmlstore.routing.TimestampedEntry

toString() - Method in class org.planx.xmlstore.routing.TimestampedValue

toString() - Method in class org.planx.xmlstore.routing.operation.AcknowledgeMessage

toString() - Method in class org.planx.xmlstore.routing.operation.ConnectMessage

toString() - Method in class org.planx.xmlstore.routing.operation.DataLookupMessage

toString() - Method in class org.planx.xmlstore.routing.operation.DataMessage

toString() - Method in class org.planx.xmlstore.routing.operation.HashMessage

toString() - Method in class org.planx.xmlstore.routing.operation.HashRequestMessage

toString() - Method in class org.planx.xmlstore.routing.operation.NodeLookupMessage

toString() - Method in class org.planx.xmlstore.routing.operation.NodeReplyMessage

toString() - Method in class org.planx.xmlstore.routing.operation.RemoveMessage

toString() - Method in class org.planx.xmlstore.routing.operation.StoreMessage

toString() - Method in class org.planx.xmlstore.routing.operation.StoreRequestMessage

U

UNIT_INTERVAL - Static variable in class org.planx.xmlstore.routing.HashCalculator

UnknownMessageException - exception org.planx.xmlstore.routing.messaging.UnknownMessageException.

Thrown to indicate that a message type is unknown or a message with a given communication identifier is unexpected.

UnknownMessageException() - Constructor for class org.planx.xmlstore.routing.messaging.UnknownMessageException

UnknownMessageException(String) - Constructor for class org.planx.xmlstore.routing.messaging.UnknownMessageException

UnknownMessageException(Throwable) - Constructor for class org.planx.xmlstore.routing.messaging.UnknownMessageException

UnknownMessageException(String, Throwable) - Constructor for class org.planx.xmlstore.routing.messaging.UnknownMessageException

upd - Variable in class org.planx.xmlstore.routing.operation.StoreMessage

updateRequested() - Method in class org.planx.xmlstore.routing.operation.StoreMessage

V

value() - Method in class org.planx.xmlstore.routing.Identifier

value - Variable in class org.planx.xmlstore.routing.operation.DataLookupOperation

The found value or null if it has not been found.

value - Variable in class org.planx.xmlstore.routing.operation.DataMessage

A B C D E F G H I K L M N O P R S T U V