Changeset 5838 for source/ariba/overlay/OverlayBootstrap.h

Timestamp:

Aug 11, 2009, 8:39:47 AM (15 years ago)

Author:

Christoph Mayer

Message:

watchdog bootstrapping und kleine relay fixes

File:

• source/ariba/overlay/OverlayBootstrap.h (modified) (6 diffs)

source/ariba/overlay/OverlayBootstrap.h

@@ -42 +42 @@
 #include <string>
 #include <sstream>
+#include <ctime>
+#include <deque>
+#include <boost/thread/mutex.hpp>
 #include "ariba/utility/logging/Logging.h"
 #include "ariba/utility/types.h"
+#include "ariba/utility/system/Timer.h"
 #include "ariba/utility/bootstrap/BootstrapManager.h"
 #include "ariba/utility/bootstrap/BootstrapInformationCallback.h"
@@ -52 +56 @@
 #include "ariba/utility/system/SystemEventType.h"
 
+using std::deque;
 using std::string;
 using std::ostringstream;
@@ -62 +67 @@
 using ariba::utility::SystemEvent;
 using ariba::utility::SystemQueue;
+using ariba::utility::Timer;
 using ariba::utility::SystemEventListener;
 
@@ -81 +87 @@
         void revoke();
 
+        void recordJoin(const EndpointDescriptor& _ep);
+
 protected:
         virtual void handleSystemEvent(const SystemEvent& event);
@@ -86 +94 @@
 
 private:
-        typedef struct _EventData {
+        class EventData {
+        public:
                 SpoVNetID spovnetid;
                 NodeID nodeid;
                 EndpointDescriptor endpoint;
-        } EventData;
+        };
 
         BootstrapManager& manager;
@@ -98 +107 @@
         string randname;
 
+        class JoinData {
+        public:
+                time_t timestamp;
+                EventData data;
+
+                JoinData(const EventData& _data){
+                        timestamp = time(NULL);
+                        data = _data;
+                }
+
+                JoinData(){
+                        timestamp = time(NULL);
+                }
+        };
+
+        class WatchdogTimer : public Timer {
+        public:
+                WatchdogTimer(OverlayBootstrap* _obj);
+                void startWatchdog();
+                void stopWatchdog();
+        protected:
+                virtual void eventFunction();
+        private:
+                OverlayBootstrap* obj;
+        };
+
+        typedef deque<JoinData> JoinStack;
+        JoinStack lastJoines;
+        boost::mutex lastJoinesMutex;
+        WatchdogTimer watchtimer;
+        void checkOverlayStatus();
 };