Changeset 6266 for source/ariba/overlay/BaseOverlay.h

Timestamp:

Sep 25, 2009, 2:30:33 PM (15 years ago)

Author:

mies

Message:

added basic DHT functionality (untested)

File:

• source/ariba/overlay/BaseOverlay.h (modified) (5 diffs)

source/ariba/overlay/BaseOverlay.h

@@ -122 +122 @@
 class LinkDescriptor;
 class OverlayMsg;
+class DHT;
 
 class BaseOverlay: public MessageReceiver,
@@ -284 +285 @@
         void leaveSpoVNet();
 
+        /// put a value to the DHT with a ttl given in seconds
+        void dhtPut( const Data& key, const Data& value, int ttl = 0);
+
+        /// removes a key value pair from the DHT
+        void dhtRemove( const Data& key, const Data& value );
+
+        /// removes all data stored at the given key
+        void dhtRemove( const Data& key );
+
+        /// requests data stored using key
+        void dhtGet( const Data& key, const ServiceID& service );
+
 protected:
-
         /**
          * @see ariba::communication::CommunicationEvents.h
@@ -397 +409 @@
         bool handleJoinReply( OverlayMsg* msg, const LinkID& bcLink );
 
+        // handle DHT messages
+        bool handleDHTMessage( OverlayMsg* msg );
+
         // handle link messages
         bool handleLinkRequest( OverlayMsg* msg, LinkDescriptor* ld );
@@ -403 +418 @@
         bool handleLinkDirect( OverlayMsg* msg, LinkDescriptor* ld );
         bool handleLinkAlive( OverlayMsg* msg, LinkDescriptor* ld );
+
 
         // link state handling -----------------------------------------------------
@@ -487 +503 @@
                 bool ignore_down = false );
 
+        // distributed hashtable handling ------------------------------------------
+
+        DHT* dht;
+
+        void stabilizeDHT();
+
         // misc --------------------------------------------------------------------