|  | 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 __NETWORK_CHANGE_DETECTION_H | 
|---|
|  | 40 | #define __NETWORK_CHANGE_DETECTION_H | 
|---|
|  | 41 |  | 
|---|
|  | 42 | #include <cerrno> | 
|---|
|  | 43 | #include <csignal> | 
|---|
|  | 44 | #include <vector> | 
|---|
|  | 45 | #include <algorithm> | 
|---|
|  | 46 | #include <string> | 
|---|
|  | 47 | #include <net/if.h> | 
|---|
|  | 48 | #include <arpa/inet.h> | 
|---|
|  | 49 | #include <linux/types.h> | 
|---|
|  | 50 | #include <linux/netlink.h> | 
|---|
|  | 51 | #include <linux/rtnetlink.h> | 
|---|
|  | 52 | #include <sys/types.h> | 
|---|
|  | 53 | #include <sys/socket.h> | 
|---|
|  | 54 | #include <sys/ioctl.h> | 
|---|
|  | 55 | #include <boost/thread/mutex.hpp> | 
|---|
|  | 56 | #include <boost/thread/thread.hpp> | 
|---|
|  | 57 | #include <boost/utility.hpp> | 
|---|
|  | 58 | #include <boost/bind.hpp> | 
|---|
|  | 59 | #include "ariba/communication/networkinfo/NetworkChangeInterface.h" | 
|---|
|  | 60 | #include "ariba/communication/networkinfo/NetworkInformation.h" | 
|---|
|  | 61 | #include "ariba/utility/system/SystemQueue.h" | 
|---|
|  | 62 | #include "ariba/utility/logging/Logging.h" | 
|---|
|  | 63 |  | 
|---|
|  | 64 | using std::string; | 
|---|
|  | 65 | using std::vector; | 
|---|
|  | 66 | using std::find; | 
|---|
|  | 67 | using ariba::utility::SystemQueue; | 
|---|
|  | 68 | using ariba::utility::SystemEvent; | 
|---|
|  | 69 | using ariba::utility::SystemEventType; | 
|---|
|  | 70 | using ariba::utility::SystemEventListener; | 
|---|
|  | 71 | using ariba::communication::NetworkInformation; | 
|---|
|  | 72 |  | 
|---|
|  | 73 | namespace ariba { | 
|---|
|  | 74 | namespace communication { | 
|---|
|  | 75 |  | 
|---|
|  | 76 | class NetworkChangeDetection : public SystemEventListener { | 
|---|
|  | 77 | use_logging_h(NetworkChangeDetection); | 
|---|
|  | 78 | public: | 
|---|
|  | 79 | NetworkChangeDetection(); | 
|---|
|  | 80 | virtual ~NetworkChangeDetection(); | 
|---|
|  | 81 |  | 
|---|
|  | 82 | void registerNotification( NetworkChangeInterface* callback ); | 
|---|
|  | 83 | void unregisterNotification( NetworkChangeInterface* callback ); | 
|---|
|  | 84 |  | 
|---|
|  | 85 | protected: | 
|---|
|  | 86 | void handleSystemEvent( const SystemEvent& event ); | 
|---|
|  | 87 |  | 
|---|
|  | 88 | private: | 
|---|
|  | 89 | typedef vector<NetworkChangeInterface*> RegistrationList; | 
|---|
|  | 90 | RegistrationList registrations; | 
|---|
|  | 91 |  | 
|---|
|  | 92 | void startMonitoring(); | 
|---|
|  | 93 | void stopMonitoring(); | 
|---|
|  | 94 |  | 
|---|
|  | 95 | volatile bool running; | 
|---|
|  | 96 | boost::thread* monitoringThread; | 
|---|
|  | 97 | static void monitoringThreadFunc( NetworkChangeDetection* obj ); | 
|---|
|  | 98 |  | 
|---|
|  | 99 | int routingSocket; | 
|---|
|  | 100 | NetworkInformation networkInformation; | 
|---|
|  | 101 |  | 
|---|
|  | 102 | NetworkChangeInterface::NetworkChangeInfo extractInterfaceEvent( struct nlmsghdr* header ); | 
|---|
|  | 103 | NetworkChangeInterface::NetworkChangeInfo extractAddressEvent( struct nlmsghdr* header ); | 
|---|
|  | 104 | }; | 
|---|
|  | 105 |  | 
|---|
|  | 106 | }} // namespace ariba, communication | 
|---|
|  | 107 |  | 
|---|
|  | 108 | #endif // __NETWORK_CHANGE_DETECTION_H | 
|---|