blob: 8f7b1f9654e132819b96f91c53887991c30755ec [file] [log] [blame]
Alexander Afanasyeve6c65e22015-01-28 19:56:03 -08001/* -*- Mode:C++; c-file-style:"gnu"; indent-tabs-mode:nil; -*- */
2/**
3 * Copyright (c) 2013-2015 Regents of the University of California.
4 *
5 * This file is part of ndn-cxx library (NDN C++ library with eXperimental eXtensions).
6 *
7 * ndn-cxx library is free software: you can redistribute it and/or modify it under the
8 * terms of the GNU Lesser General Public License as published by the Free Software
9 * Foundation, either version 3 of the License, or (at your option) any later version.
10 *
11 * ndn-cxx library is distributed in the hope that it will be useful, but WITHOUT ANY
12 * WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR A
13 * PARTICULAR PURPOSE. See the GNU Lesser General Public License for more details.
14 *
15 * You should have received copies of the GNU General Public License and GNU Lesser
16 * General Public License along with ndn-cxx, e.g., in COPYING.md file. If not, see
17 * <http://www.gnu.org/licenses/>.
18 *
19 * See AUTHORS.md for complete list of ndn-cxx authors and contributors.
20 *
21 *
22 * Parts of this implementation is based on daemondo command of MacPorts
23 * (https://www.macports.org/):
24 *
25 * Copyright (c) 2005-2007 James Berry <jberry@macports.org>
26 * All rights reserved.
27 *
28 * Redistribution and use in source and binary forms, with or without
29 * modification, are permitted provided that the following conditions
30 * are met:
31 * 1. Redistributions of source code must retain the above copyright
32 * notice, this list of conditions and the following disclaimer.
33 * 2. Redistributions in binary form must reproduce the above copyright
34 * notice, this list of conditions and the following disclaimer in the
35 * documentation and/or other materials provided with the distribution.
36 * 3. Neither the name of The MacPorts Project nor the names of its contributors
37 * may be used to endorse or promote products derived from this software
38 * without specific prior written permission.
39 *
40 * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"
41 * AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
42 * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
43 * ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS BE
44 * LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
45 * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
46 * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
47 * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
48 * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
49 * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
50 * POSSIBILITY OF SUCH DAMAGE.
51 */
52
53#include "ndn-cxx-config.hpp"
54
55#include "network-monitor.hpp"
56#include "scheduler.hpp"
57#include "scheduler-scoped-event-id.hpp"
58
59#if defined(NDN_CXX_HAVE_COREFOUNDATION_COREFOUNDATION_H)
60
61#include <CoreFoundation/CoreFoundation.h>
62#include <SystemConfiguration/SystemConfiguration.h>
63
64namespace ndn {
65namespace util {
66
67class NetworkMonitor::Impl
68{
69public:
70 Impl(boost::asio::io_service& io)
71 : scheduler(io)
72 , cfLoopEvent(scheduler)
73 {
74 }
75
76 void
77 scheduleCfLoop()
78 {
79 // poll each second for new events
80 cfLoopEvent = scheduler.scheduleEvent(time::seconds(1), bind(&Impl::pollCfLoop, this));
81 }
82
83 static void
84 afterNotificationCenterEvent(CFNotificationCenterRef center, void *observer, CFStringRef name,
85 const void *object, CFDictionaryRef userInfo)
86 {
87 static_cast<NetworkMonitor*>(observer)->onNetworkStateChanged();
88 }
89
90private:
91
92 void
93 pollCfLoop()
94 {
95 // this should dispatch ready events and exit
96 CFRunLoopRunInMode(kCFRunLoopDefaultMode, 0, true);
97 scheduleCfLoop();
98 }
99
100private:
101 Scheduler scheduler;
102 scheduler::ScopedEventId cfLoopEvent;
103};
104
105NetworkMonitor::NetworkMonitor(boost::asio::io_service& io)
106 : m_impl(new Impl(io))
107{
108 m_impl->scheduleCfLoop();
109
110 // Potentially useful System Configuration regex patterns:
111 //
112 // State:/Network/Interface/.*/Link
113 // State:/Network/Interface/.*/IPv4
114 // State:/Network/Interface/.*/IPv6
115 //
116 // State:/Network/Global/DNS
117 // State:/Network/Global/IPv4
118 //
119 // Potentially useful notifications from Darwin Notify Center:
120 //
121 // com.apple.system.config.network_change
122
123 // network change observations
124 CFNotificationCenterAddObserver(CFNotificationCenterGetDarwinNotifyCenter(),
125 static_cast<void*>(this),
126 &NetworkMonitor::Impl::afterNotificationCenterEvent,
127 CFSTR("com.apple.system.config.network_change"),
128 nullptr, // object to observe
129 CFNotificationSuspensionBehaviorDeliverImmediately);
130}
131
132NetworkMonitor::~NetworkMonitor()
133{
134 CFNotificationCenterRemoveEveryObserver(CFNotificationCenterGetDarwinNotifyCenter(),
135 static_cast<void*>(this));
136}
137
138} // namespace util
139} // namespace ndn
140
141// done with defined(NDN_CXX_HAVE_COREFOUNDATION_COREFOUNDATION_H)
Alexander Afanasyev7b3080f2015-01-28 21:21:01 -0800142#elif defined(NDN_CXX_HAVE_RTNETLINK)
143
144#include <boost/asio.hpp>
145
146#include <netinet/in.h>
147#include <linux/netlink.h>
148#include <linux/rtnetlink.h>
149#include <net/if.h>
150
151#include <cerrno>
152#include <cstring>
Alexander Afanasyeve6c65e22015-01-28 19:56:03 -0800153
154namespace ndn {
155namespace util {
156
Alexander Afanasyev7b3080f2015-01-28 21:21:01 -0800157const size_t NETLINK_BUFFER_SIZE = 4096;
158
159class NetworkMonitor::Impl
Alexander Afanasyeve6c65e22015-01-28 19:56:03 -0800160{
Alexander Afanasyev7b3080f2015-01-28 21:21:01 -0800161public:
162 Impl(NetworkMonitor& nm, boost::asio::io_service& io)
163 : m_nm(nm)
164 , m_socket(io)
165 {
166 int fd = ::socket(AF_NETLINK, SOCK_RAW, NETLINK_ROUTE);
167 if (fd < 0)
Spyridon Mastorakis0d2ed2e2015-07-27 19:09:12 -0700168 BOOST_THROW_EXCEPTION(Error(std::string("Cannot create netlink socket (") +
169 std::strerror(errno) + ")"));
Alexander Afanasyev7b3080f2015-01-28 21:21:01 -0800170
171 sockaddr_nl addr{};
172 addr.nl_family = AF_NETLINK;
173 addr.nl_groups = RTMGRP_LINK |
174 RTMGRP_IPV4_IFADDR | RTMGRP_IPV4_ROUTE |
175 RTMGRP_IPV6_IFADDR | RTMGRP_IPV6_ROUTE;
176
177 if (::bind(fd, reinterpret_cast<sockaddr*>(&addr), sizeof(addr)) == -1) {
Spyridon Mastorakis0d2ed2e2015-07-27 19:09:12 -0700178 BOOST_THROW_EXCEPTION(Error(std::string("Cannot bind on netlink socket (") +
179 std::strerror(errno) + ")"));
Alexander Afanasyev7b3080f2015-01-28 21:21:01 -0800180 }
181
182 m_socket.assign(fd);
183
184 m_socket.async_read_some(boost::asio::buffer(m_buffer, NETLINK_BUFFER_SIZE),
185 bind(&Impl::onReceiveRtNetlink, this, _1, _2));
186 }
187
188private:
189 void
190 onReceiveRtNetlink(const boost::system::error_code& error, size_t nBytesReceived)
191 {
192 if (error) {
193 return;
194 }
195
196 const nlmsghdr* nlh = reinterpret_cast<const nlmsghdr*>(m_buffer);
197 while ((NLMSG_OK(nlh, nBytesReceived)) && (nlh->nlmsg_type != NLMSG_DONE)) {
198 if (nlh->nlmsg_type == RTM_NEWADDR || nlh->nlmsg_type == RTM_DELADDR ||
199 nlh->nlmsg_type == RTM_NEWLINK || nlh->nlmsg_type == RTM_DELLINK ||
200 nlh->nlmsg_type == RTM_NEWROUTE || nlh->nlmsg_type == RTM_DELROUTE) {
201 m_nm.onNetworkStateChanged();
202 break;
203 }
204 nlh = NLMSG_NEXT(nlh, nBytesReceived);
205 }
206
207 m_socket.async_read_some(boost::asio::buffer(m_buffer, NETLINK_BUFFER_SIZE),
208 bind(&Impl::onReceiveRtNetlink, this, _1, _2));
209 }
210
211private:
212 NetworkMonitor& m_nm;
213 uint8_t m_buffer[NETLINK_BUFFER_SIZE];
214
215 boost::asio::posix::stream_descriptor m_socket;
216};
217
218
219
220NetworkMonitor::NetworkMonitor(boost::asio::io_service& io)
221 : m_impl(new Impl(*this, io))
222{
Alexander Afanasyeve6c65e22015-01-28 19:56:03 -0800223}
224
225NetworkMonitor::~NetworkMonitor()
226{
227}
228
229} // namespace util
230} // namespace ndn
231
Alexander Afanasyev7b3080f2015-01-28 21:21:01 -0800232// done with defined(NDN_CXX_HAVE_RTNETLINK)
Alexander Afanasyeve6c65e22015-01-28 19:56:03 -0800233#else // do not support network monitoring operations
234
235namespace ndn {
236namespace util {
237
238class NetworkMonitor::Impl
239{
Alexander Afanasyeve6c65e22015-01-28 19:56:03 -0800240};
241
242NetworkMonitor::NetworkMonitor(boost::asio::io_service&)
243{
Spyridon Mastorakis0d2ed2e2015-07-27 19:09:12 -0700244 BOOST_THROW_EXCEPTION(Error("Network monitoring is not supported on this platform"));
Alexander Afanasyeve6c65e22015-01-28 19:56:03 -0800245}
246
247NetworkMonitor::~NetworkMonitor()
248{
249}
250
251} // namespace util
252} // namespace ndn
253
254#endif // do not support network monitoring operations