Changeset 10688 for source/services/dht
- Timestamp:
- Aug 4, 2012, 3:12:04 AM (12 years ago)
- Location:
- source/services/dht
- Files:
-
- 2 edited
Legend:
- Unmodified
- Added
- Removed
-
source/services/dht/Dht.cpp
r10653 r10688 7 7 8 8 #include "Dht.h" 9 #include "messages/DhtMessage.h" 9 10 #include <boost/date_time/time_clock.hpp> 10 11 -
source/services/dht/Dht.h
r10653 r10688 12 12 #include "ariba/utility/system/SystemQueue.h" 13 13 #include "ariba/utility/logging/Logging.h" 14 #include "messages/DhtMessage.h"15 14 #include "DhtAnswerInterface.h" 16 15 #include <boost/date_time/posix_time/posix_time.hpp> … … 25 24 using ariba::utility::SystemEventType; 26 25 using ariba::utility::SystemEventListener; 26 27 // Forward declarations to avoid adding messages/*.h to the public interface 28 class DhtMessage; 27 29 28 30 #define MEET_REPUBLISH_INTERVAL 10 … … 135 137 136 138 137 virtual void handle_dht_message(const DhtMessage& message, const NodeID& source);138 139 139 /*** SystemEventListener interface ***/ 140 140 virtual void handleSystemEvent( const SystemEvent& event ); … … 173 173 174 174 private: 175 void handle_dht_message(const DhtMessage& message, const NodeID& source); 176 175 177 void answer_dht_request(const std::string& key, const NodeID& source); 176 178 void send_meet_message(const std::string& key, const std::string& value);
Note:
See TracChangeset
for help on using the changeset viewer.