Changeset 4866 for source/ariba/utility/bootstrap/modules/periodicbroadcast/PeriodicBroadcast.h

Timestamp:

Jul 13, 2009, 9:42:32 AM (15 years ago)

Author:

Christoph Mayer

Message:

periodic bootstrap vervollständigt

File:

• source/ariba/utility/bootstrap/modules/periodicbroadcast/PeriodicBroadcast.h (modified) (7 diffs)

source/ariba/utility/bootstrap/modules/periodicbroadcast/PeriodicBroadcast.h

@@ -44 +44 @@
 #include <map>
 #include <string>
+#include <ctime>
 #include <iostream>
 #include <boost/asio.hpp>
@@ -56 +57 @@
 using std::map;
 using std::string;
+using std::cout;
 using boost::asio::ip::udp;
 
@@ -83 +85 @@
         void updateRemoteServices();
 
-        static const long timerinterval;
+        static const long timerinterval; // used to send out updates on our services and check for new services
+        static const long servicetimeout; // timeout after that a service is dead when we did not receive updates
         static const unsigned int serverport_v4;
         static const unsigned int serverport_v6;
@@ -92 +95 @@
                 string info2;
                 string info3;
+                time_t lastseen;
+
+                _Service()
+                        : name(""), info1(""), info2(""), info3(""), lastseen(0){
+                }
         } Service;
 
@@ -133 +141 @@
                         Data data = data_serialize( msg, DEFAULT_V );
                         uint8_t* pnt = data.getBuffer();
-                        size_t len = data.getLength();
+                        size_t len = data.getLength() / 8;
                         boost::system::error_code ignored_error;
+
+                        cout << "-----------> sending out " << data << std::endl;
 
                         {
@@ -172 +182 @@
                                 data_deserialize( msg, data );
 
+                                cout << "-----------> received " << data << std::endl;
+
                                 { // insert new found service
                                         boost::mutex::scoped_lock( *servicesmutex );
@@ -182 +194 @@
                                         s.info2 = msg.getInfo2();
                                         s.info3 = msg.getInfo3();
+                                        s.lastseen = time(NULL);
                                         services->insert( std::make_pair(msg.getName(), s) );
                                 }