source: source/ariba/overlay/OverlayBootstrap.h@ 5945

Last change on this file since 5945 was 5860, checked in by Christoph Mayer, 15 years ago

networkinfo fix wenn socket kaputt geht, erfolgreich verwendete bootstrap infos speichern und wenn overlay verbindungen alle weg sind diese infos ausprobieren

File size: 4.3 KB
Line 
1// [License]
2// The Ariba-Underlay Copyright
3//
4// Copyright (c) 2008-2009, Institute of Telematics, UniversitÀt Karlsruhe (TH)
5//
6// Institute of Telematics
7// UniversitÀt Karlsruhe (TH)
8// Zirkel 2, 76128 Karlsruhe
9// Germany
10//
11// Redistribution and use in source and binary forms, with or without
12// modification, are permitted provided that the following conditions are
13// met:
14//
15// 1. Redistributions of source code must retain the above copyright
16// notice, this list of conditions and the following disclaimer.
17// 2. Redistributions in binary form must reproduce the above copyright
18// notice, this list of conditions and the following disclaimer in the
19// documentation and/or other materials provided with the distribution.
20//
21// THIS SOFTWARE IS PROVIDED BY THE INSTITUTE OF TELEMATICS ``AS IS'' AND
22// ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
23// IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
24// PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE ARIBA PROJECT OR
25// CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL,
26// EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO,
27// PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR
28// PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF
29// LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING
30// NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
31// SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
32//
33// The views and conclusions contained in the software and documentation
34// are those of the authors and should not be interpreted as representing
35// official policies, either expressed or implied, of the Institute of
36// Telematics.
37// [License]
38
39#ifndef __OVERLAY_BOOTSTRAP_H
40#define __OVERLAY_BOOTSTRAP_H
41
42#include <string>
43#include <sstream>
44#include <ctime>
45#include <deque>
46#include <algorithm>
47#include <boost/thread/mutex.hpp>
48#include "ariba/utility/logging/Logging.h"
49#include "ariba/utility/types.h"
50#include "ariba/utility/system/Timer.h"
51#include "ariba/utility/bootstrap/BootstrapManager.h"
52#include "ariba/utility/bootstrap/BootstrapInformationCallback.h"
53#include "ariba/communication/EndpointDescriptor.h"
54#include "ariba/utility/system/SystemEventListener.h"
55#include "ariba/utility/system/SystemQueue.h"
56#include "ariba/utility/system/SystemEvent.h"
57#include "ariba/utility/system/SystemEventType.h"
58
59using std::swap;
60using std::deque;
61using std::string;
62using std::ostringstream;
63using ariba::utility::SpoVNetID;
64using ariba::utility::NodeID;
65using ariba::utility::BootstrapManager;
66using ariba::utility::BootstrapInformationCallback;
67using ariba::communication::EndpointDescriptor;
68using ariba::utility::SystemEventType;
69using ariba::utility::SystemEvent;
70using ariba::utility::SystemQueue;
71using ariba::utility::Timer;
72using ariba::utility::SystemEventListener;
73
74namespace ariba {
75namespace overlay {
76
77class BaseOverlay;
78
79class OverlayBootstrap : public BootstrapInformationCallback, public SystemEventListener {
80 use_logging_h(OverlayBootstrap);
81public:
82 OverlayBootstrap();
83 virtual ~OverlayBootstrap();
84
85 void start(BaseOverlay* _overlay, const SpoVNetID& _spovnetid, const NodeID& _nodeid);
86 void stop();
87
88 void publish( const EndpointDescriptor& _ep );
89 void revoke();
90
91 void recordJoin(const EndpointDescriptor& _ep);
92
93protected:
94 virtual void handleSystemEvent(const SystemEvent& event);
95 virtual void onBootstrapServiceFound(string name, string info1, string info2, string info);
96
97private:
98 class JoinData {
99 public:
100 JoinData() : spovnetid(), nodeid(), endpoint() {
101 }
102
103 JoinData& operator=( const JoinData& rhs) {
104 spovnetid = rhs.spovnetid;
105 nodeid = rhs.nodeid;
106 endpoint = rhs.endpoint;
107 }
108
109 SpoVNetID spovnetid;
110 NodeID nodeid;
111 EndpointDescriptor endpoint;
112 };
113
114 BootstrapManager& manager;
115 SpoVNetID spovnetid;
116 NodeID nodeid;
117 BaseOverlay* overlay;
118 string randname;
119
120 class WatchdogTimer : public Timer {
121 public:
122 WatchdogTimer(OverlayBootstrap* _obj);
123 void startWatchdog();
124 void stopWatchdog();
125 protected:
126 virtual void eventFunction();
127 private:
128 OverlayBootstrap* obj;
129 };
130
131 typedef deque<JoinData> JoinStack;
132 JoinStack lastJoines;
133 boost::mutex lastJoinesMutex;
134 WatchdogTimer watchtimer;
135 void checkOverlayStatus();
136};
137
138}} // namespace ariba, overlay
139
140#endif // __OVERLAY_BOOTSTRAP_H
Note: See TracBrowser for help on using the repository browser.