org.planx.routing.kademlia.operation
Class StoreReceiver

java.lang.Object
  org.planx.routing.kademlia.operation.OriginReceiver
      org.planx.routing.kademlia.operation.StoreReceiver

All Implemented Interfaces:

Receiver

public class StoreReceiver
extends OriginReceiver

Receives a StoreMessage and stores the mapping if a mapping with the same key and a newer timestamp does not exist. If requested, sends a StoreMessage is sent if this node has a mapping with the same key that is newer.

Constructor Summary

StoreReceiver(MessageServer server, Node local, Space space, Map<Identifier,TimestampedValue> localMap)

Method Summary

void	receive(Message incoming, int comm) Updates the local space by inserting the origin node.

Methods inherited from class org.planx.routing.kademlia.operation.OriginReceiver

timeout

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

StoreReceiver

public StoreReceiver(MessageServer server,
                     Node local,
                     Space space,
                     Map<Identifier,TimestampedValue> localMap)

Method Detail

receive

public void receive(Message incoming,
                    int comm)
             throws IOException

Description copied from class: OriginReceiver

Updates the local space by inserting the origin node. Note that if the node already exists in the local space, it's time last seen is updated instead.

Specified by:

receive in interface Receiver

Overrides:

receive in class OriginReceiver

Throws:

IOException - if an I/O error occurs