blob: c4e45e60fb81e2b1506c5d80d9d2d2273ed8b5e1 [file] [log] [blame]
Davide Pesavento9a8bae52016-02-24 20:33:08 +01001/* -*- Mode:C++; c-file-style:"gnu"; indent-tabs-mode:nil; -*- */
Davide Pesaventob2ae3362017-07-13 01:43:14 -04002/*
Davide Pesavento0f830802018-01-16 23:58:58 -05003 * Copyright (c) 2013-2018 Regents of the University of California.
Davide Pesavento9a8bae52016-02-24 20:33:08 +01004 *
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
Davide Pesavento9a8bae52016-02-24 20:33:08 +010053#include "network-monitor-impl-osx.hpp"
Davide Pesaventof0c827e2017-10-03 17:25:00 -040054
55#include "../network-address.hpp"
Alexander Afanasyev3b3355c2017-03-26 11:57:13 -050056#include "../../name.hpp"
Junxiao Shi25467942017-06-30 02:53:14 +000057#include "../../util/logger.hpp"
Alexander Afanasyev3b3355c2017-03-26 11:57:13 -050058
Davide Pesavento25203712017-10-09 23:50:03 -040059#include <ifaddrs.h> // for getifaddrs()
60#include <net/if.h> // for if_nametoindex()
61#include <net/if_dl.h> // for struct sockaddr_dl
62#include <net/if_types.h> // for IFT_* constants
63#include <netinet/in.h> // for struct sockaddr_in{,6}
Alexander Afanasyev3b3355c2017-03-26 11:57:13 -050064
Davide Pesaventof35c4272017-07-14 11:13:34 -040065#include <boost/asio/io_service.hpp>
66#include <boost/asio/ip/address.hpp>
67#include <boost/asio/ip/udp.hpp>
Davide Pesavento9a8bae52016-02-24 20:33:08 +010068
Davide Pesavento755f8a82018-08-24 00:06:45 -040069NDN_LOG_INIT(ndn.NetworkMonitor);
70
Davide Pesavento9a8bae52016-02-24 20:33:08 +010071namespace ndn {
Junxiao Shi25467942017-06-30 02:53:14 +000072namespace net {
Davide Pesavento9a8bae52016-02-24 20:33:08 +010073
Junxiao Shi0b1b4672017-07-02 22:02:31 -070074using util::CFReleaser;
75
Davide Pesaventoc0087982017-07-16 23:32:34 -040076class IfAddrs : noncopyable
77{
78public:
79 IfAddrs()
80 {
81 if (::getifaddrs(&m_ifaList) < 0) {
Davide Pesaventodb4da5e2018-06-15 11:37:52 -040082 BOOST_THROW_EXCEPTION(NetworkMonitorImplOsx::Error("getifaddrs() failed: "s + strerror(errno)));
Davide Pesaventoc0087982017-07-16 23:32:34 -040083 }
84 }
85
86 ~IfAddrs()
87 {
88 if (m_ifaList != nullptr) {
89 ::freeifaddrs(m_ifaList);
90 }
91 }
92
93 ifaddrs*
94 get() const noexcept
95 {
96 return m_ifaList;
97 }
98
99private:
100 ifaddrs* m_ifaList = nullptr;
101};
102
Junxiao Shi2dc416d2017-07-03 04:46:16 +0000103NetworkMonitorImplOsx::NetworkMonitorImplOsx(boost::asio::io_service& io)
104 : m_scheduler(io)
Davide Pesavento9a8bae52016-02-24 20:33:08 +0100105 , m_cfLoopEvent(m_scheduler)
Alexander Afanasyev3b3355c2017-03-26 11:57:13 -0500106 , m_context{0, this, nullptr, nullptr, nullptr}
107 , m_scStore(SCDynamicStoreCreate(nullptr, CFSTR("net.named-data.ndn-cxx.NetworkMonitor"),
Junxiao Shi2dc416d2017-07-03 04:46:16 +0000108 &NetworkMonitorImplOsx::onConfigChanged, &m_context))
Alexander Afanasyev3b3355c2017-03-26 11:57:13 -0500109 , m_loopSource(SCDynamicStoreCreateRunLoopSource(nullptr, m_scStore.get(), 0))
Davide Pesaventof0c827e2017-10-03 17:25:00 -0400110 , m_ioctlSocket(io, boost::asio::ip::udp::v4())
Davide Pesavento9a8bae52016-02-24 20:33:08 +0100111{
112 scheduleCfLoop();
113
Alexander Afanasyev3b3355c2017-03-26 11:57:13 -0500114 // Notifications from Darwin Notify Center:
Davide Pesavento9a8bae52016-02-24 20:33:08 +0100115 //
116 // com.apple.system.config.network_change
117 //
118 CFNotificationCenterAddObserver(CFNotificationCenterGetDarwinNotifyCenter(),
119 static_cast<void*>(this),
Junxiao Shi2dc416d2017-07-03 04:46:16 +0000120 &NetworkMonitorImplOsx::afterNotificationCenterEvent,
Davide Pesavento9a8bae52016-02-24 20:33:08 +0100121 CFSTR("com.apple.system.config.network_change"),
122 nullptr, // object to observe
123 CFNotificationSuspensionBehaviorDeliverImmediately);
Alexander Afanasyev3b3355c2017-03-26 11:57:13 -0500124
Alexander Afanasyev3b3355c2017-03-26 11:57:13 -0500125 CFRunLoopAddSource(CFRunLoopGetCurrent(), m_loopSource.get(), kCFRunLoopDefaultMode);
126
127 // Notifications from SystemConfiguration:
128 //
129 // State:/Network/Interface/.*/Link
130 // State:/Network/Interface/.*/IPv4
131 // State:/Network/Interface/.*/IPv6
Davide Pesaventof0c827e2017-10-03 17:25:00 -0400132 // State:/Network/Interface/.*/AirPort (not used)
133 //
134 // https://developer.apple.com/library/content/documentation/Networking/Conceptual/SystemConfigFrameworks/SC_UnderstandSchema/SC_UnderstandSchema.html
Alexander Afanasyev3b3355c2017-03-26 11:57:13 -0500135 //
136 auto patterns = CFArrayCreateMutable(nullptr, 0, &kCFTypeArrayCallBacks);
137 CFArrayAppendValue(patterns, CFSTR("State:/Network/Interface/.*/Link"));
138 CFArrayAppendValue(patterns, CFSTR("State:/Network/Interface/.*/IPv4"));
139 CFArrayAppendValue(patterns, CFSTR("State:/Network/Interface/.*/IPv6"));
Alexander Afanasyev3b3355c2017-03-26 11:57:13 -0500140
Davide Pesaventof0c827e2017-10-03 17:25:00 -0400141 if (!SCDynamicStoreSetNotificationKeys(m_scStore.get(), nullptr, patterns)) {
142 BOOST_THROW_EXCEPTION(Error("SCDynamicStoreSetNotificationKeys failed"));
143 }
Davide Pesaventoc0087982017-07-16 23:32:34 -0400144
145 io.post([this] { enumerateInterfaces(); });
Davide Pesavento9a8bae52016-02-24 20:33:08 +0100146}
147
Junxiao Shi2dc416d2017-07-03 04:46:16 +0000148NetworkMonitorImplOsx::~NetworkMonitorImplOsx()
Davide Pesavento9a8bae52016-02-24 20:33:08 +0100149{
Alexander Afanasyev3b3355c2017-03-26 11:57:13 -0500150 CFRunLoopRemoveSource(CFRunLoopGetCurrent(), m_loopSource.get(), kCFRunLoopDefaultMode);
151
Davide Pesavento9a8bae52016-02-24 20:33:08 +0100152 CFNotificationCenterRemoveEveryObserver(CFNotificationCenterGetDarwinNotifyCenter(),
153 static_cast<void*>(this));
154}
155
Junxiao Shi2dc416d2017-07-03 04:46:16 +0000156shared_ptr<const NetworkInterface>
157NetworkMonitorImplOsx::getNetworkInterface(const std::string& ifname) const
Davide Pesavento2bf35a62017-04-02 00:41:06 -0400158{
Alexander Afanasyev3b3355c2017-03-26 11:57:13 -0500159 auto it = m_interfaces.find(ifname);
Junxiao Shi2dc416d2017-07-03 04:46:16 +0000160 return it == m_interfaces.end() ? nullptr : it->second;
Davide Pesavento2bf35a62017-04-02 00:41:06 -0400161}
162
Junxiao Shi2dc416d2017-07-03 04:46:16 +0000163std::vector<shared_ptr<const NetworkInterface>>
164NetworkMonitorImplOsx::listNetworkInterfaces() const
Davide Pesavento2bf35a62017-04-02 00:41:06 -0400165{
Junxiao Shi2dc416d2017-07-03 04:46:16 +0000166 std::vector<shared_ptr<const NetworkInterface>> v;
Alexander Afanasyev3b3355c2017-03-26 11:57:13 -0500167 v.reserve(m_interfaces.size());
168
169 for (const auto& e : m_interfaces) {
170 v.push_back(e.second);
171 }
172 return v;
Davide Pesavento2bf35a62017-04-02 00:41:06 -0400173}
174
Davide Pesavento9a8bae52016-02-24 20:33:08 +0100175void
Junxiao Shi2dc416d2017-07-03 04:46:16 +0000176NetworkMonitorImplOsx::afterNotificationCenterEvent(CFNotificationCenterRef center,
177 void* observer,
178 CFStringRef name,
179 const void* object,
180 CFDictionaryRef userInfo)
Davide Pesavento9a8bae52016-02-24 20:33:08 +0100181{
Junxiao Shi2dc416d2017-07-03 04:46:16 +0000182 static_cast<NetworkMonitorImplOsx*>(observer)->emitSignal(onNetworkStateChanged);
Davide Pesavento9a8bae52016-02-24 20:33:08 +0100183}
184
185void
Junxiao Shi2dc416d2017-07-03 04:46:16 +0000186NetworkMonitorImplOsx::scheduleCfLoop()
Davide Pesavento9a8bae52016-02-24 20:33:08 +0100187{
188 // poll each second for new events
Davide Pesavento0f830802018-01-16 23:58:58 -0500189 m_cfLoopEvent = m_scheduler.scheduleEvent(1_s, [this] {
Davide Pesaventoc0087982017-07-16 23:32:34 -0400190 // this should dispatch ready events and exit
191 CFRunLoopRunInMode(kCFRunLoopDefaultMode, 0, true);
192 scheduleCfLoop();
193 });
Alexander Afanasyev3b3355c2017-03-26 11:57:13 -0500194}
195
196void
Junxiao Shi2dc416d2017-07-03 04:46:16 +0000197NetworkMonitorImplOsx::enumerateInterfaces()
Alexander Afanasyev3b3355c2017-03-26 11:57:13 -0500198{
Davide Pesaventoc0087982017-07-16 23:32:34 -0400199 IfAddrs ifaList;
Alexander Afanasyev3b3355c2017-03-26 11:57:13 -0500200 for (const auto& ifName : getInterfaceNames()) {
Davide Pesaventoc0087982017-07-16 23:32:34 -0400201 addNewInterface(ifName, ifaList);
Alexander Afanasyev3b3355c2017-03-26 11:57:13 -0500202 }
Junxiao Shi2dc416d2017-07-03 04:46:16 +0000203 this->emitSignal(onEnumerationCompleted);
Alexander Afanasyev3b3355c2017-03-26 11:57:13 -0500204}
205
206static std::string
Davide Pesaventof35c4272017-07-14 11:13:34 -0400207convertToStdString(CFStringRef cfStr)
Alexander Afanasyev3b3355c2017-03-26 11:57:13 -0500208{
Davide Pesaventof35c4272017-07-14 11:13:34 -0400209 const char* cStr = CFStringGetCStringPtr(cfStr, kCFStringEncodingASCII);
Alexander Afanasyev3b3355c2017-03-26 11:57:13 -0500210 if (cStr != nullptr) {
Davide Pesaventof35c4272017-07-14 11:13:34 -0400211 // fast path
Alexander Afanasyev3b3355c2017-03-26 11:57:13 -0500212 return cStr;
213 }
214
Davide Pesaventof35c4272017-07-14 11:13:34 -0400215 // reserve space for the string + null terminator
216 std::string str(CFStringGetLength(cfStr) + 1, '\0');
217 if (!CFStringGetCString(cfStr, &str.front(), str.size(), kCFStringEncodingASCII)) {
218 BOOST_THROW_EXCEPTION(NetworkMonitorImplOsx::Error("CFString conversion failed"));
219 }
220
221 // drop the null terminator, std::string doesn't need it
222 str.pop_back();
223 return str;
Alexander Afanasyev3b3355c2017-03-26 11:57:13 -0500224}
225
226std::set<std::string>
Davide Pesaventoc0087982017-07-16 23:32:34 -0400227NetworkMonitorImplOsx::getInterfaceNames() const
Alexander Afanasyev3b3355c2017-03-26 11:57:13 -0500228{
Junxiao Shi2dc416d2017-07-03 04:46:16 +0000229 CFReleaser<CFDictionaryRef> dict =
230 (CFDictionaryRef)SCDynamicStoreCopyValue(m_scStore.get(), CFSTR("State:/Network/Interface"));
Davide Pesaventof0c827e2017-10-03 17:25:00 -0400231 if (dict.get() == nullptr) {
232 return {};
233 }
234
Alexander Afanasyev3b3355c2017-03-26 11:57:13 -0500235 CFArrayRef interfaces = (CFArrayRef)CFDictionaryGetValue(dict.get(), CFSTR("Interfaces"));
Davide Pesaventof0c827e2017-10-03 17:25:00 -0400236 if (interfaces == nullptr) {
237 return {};
238 }
Alexander Afanasyev3b3355c2017-03-26 11:57:13 -0500239
240 std::set<std::string> ifNames;
241 size_t count = CFArrayGetCount(interfaces);
242 for (size_t i = 0; i != count; ++i) {
243 auto ifName = (CFStringRef)CFArrayGetValueAtIndex(interfaces, i);
244 ifNames.insert(convertToStdString(ifName));
245 }
246 return ifNames;
247}
248
Davide Pesaventoc0087982017-07-16 23:32:34 -0400249void
250NetworkMonitorImplOsx::addNewInterface(const std::string& ifName, const IfAddrs& ifaList)
251{
252 shared_ptr<NetworkInterface> interface = makeNetworkInterface();
253 interface->setName(ifName);
Davide Pesaventof0c827e2017-10-03 17:25:00 -0400254 interface->setState(getInterfaceState(*interface));
Davide Pesaventoc0087982017-07-16 23:32:34 -0400255 updateInterfaceInfo(*interface, ifaList);
256
257 if (interface->getType() == InterfaceType::UNKNOWN) {
258 NDN_LOG_DEBUG("ignoring " << ifName << " due to unhandled interface type");
259 return;
260 }
261
262 NDN_LOG_DEBUG("adding interface " << interface->getName());
263 m_interfaces[interface->getName()] = interface;
264 this->emitSignal(onInterfaceAdded, interface);
265}
266
Alexander Afanasyev3b3355c2017-03-26 11:57:13 -0500267InterfaceState
Davide Pesaventof0c827e2017-10-03 17:25:00 -0400268NetworkMonitorImplOsx::getInterfaceState(const NetworkInterface& netif) const
Alexander Afanasyev3b3355c2017-03-26 11:57:13 -0500269{
Junxiao Shi2dc416d2017-07-03 04:46:16 +0000270 CFReleaser<CFStringRef> linkName =
Davide Pesaventof0c827e2017-10-03 17:25:00 -0400271 CFStringCreateWithCString(kCFAllocatorDefault,
272 ("State:/Network/Interface/" + netif.getName() + "/Link").data(),
Junxiao Shi2dc416d2017-07-03 04:46:16 +0000273 kCFStringEncodingASCII);
Alexander Afanasyev3b3355c2017-03-26 11:57:13 -0500274
Davide Pesaventof0c827e2017-10-03 17:25:00 -0400275 CFReleaser<CFDictionaryRef> dict =
276 (CFDictionaryRef)SCDynamicStoreCopyValue(m_scStore.get(), linkName.get());
Alexander Afanasyev3b3355c2017-03-26 11:57:13 -0500277 if (dict.get() == nullptr) {
278 return InterfaceState::UNKNOWN;
279 }
280
281 CFBooleanRef isActive = (CFBooleanRef)CFDictionaryGetValue(dict.get(), CFSTR("Active"));
282 if (isActive == nullptr) {
283 return InterfaceState::UNKNOWN;
284 }
285
286 return CFBooleanGetValue(isActive) ? InterfaceState::RUNNING : InterfaceState::DOWN;
287}
288
Davide Pesaventoc0087982017-07-16 23:32:34 -0400289size_t
Davide Pesaventof0c827e2017-10-03 17:25:00 -0400290NetworkMonitorImplOsx::getInterfaceMtu(const NetworkInterface& netif)
Davide Pesaventoc0087982017-07-16 23:32:34 -0400291{
292 ifreq ifr{};
Davide Pesaventof0c827e2017-10-03 17:25:00 -0400293 std::strncpy(ifr.ifr_name, netif.getName().data(), sizeof(ifr.ifr_name) - 1);
Davide Pesaventoc0087982017-07-16 23:32:34 -0400294
Davide Pesaventof0c827e2017-10-03 17:25:00 -0400295 if (::ioctl(m_ioctlSocket.native_handle(), SIOCGIFMTU, &ifr) == 0) {
Davide Pesaventoc0087982017-07-16 23:32:34 -0400296 return static_cast<size_t>(ifr.ifr_mtu);
297 }
298
Davide Pesaventof0c827e2017-10-03 17:25:00 -0400299 NDN_LOG_WARN("failed to get MTU of " << netif.getName() << ": " << std::strerror(errno));
Davide Pesaventoc0087982017-07-16 23:32:34 -0400300 return ethernet::MAX_DATA_LEN;
301}
302
Junxiao Shi2dc416d2017-07-03 04:46:16 +0000303template<typename AddressBytes>
304static uint8_t
305computePrefixLength(const AddressBytes& mask)
306{
307 uint8_t prefixLength = 0;
308 for (auto byte : mask) {
309 while (byte != 0) {
310 ++prefixLength;
311 byte <<= 1;
312 }
313 }
314 return prefixLength;
315}
316
Alexander Afanasyev3b3355c2017-03-26 11:57:13 -0500317void
Davide Pesaventoc0087982017-07-16 23:32:34 -0400318NetworkMonitorImplOsx::updateInterfaceInfo(NetworkInterface& netif, const IfAddrs& ifaList)
Alexander Afanasyev3b3355c2017-03-26 11:57:13 -0500319{
Davide Pesaventof0c827e2017-10-03 17:25:00 -0400320 BOOST_ASSERT(!netif.getName().empty());
321
322 netif.setMtu(getInterfaceMtu(netif));
323
Davide Pesaventoc0087982017-07-16 23:32:34 -0400324 for (ifaddrs* ifa = ifaList.get(); ifa != nullptr; ifa = ifa->ifa_next) {
Davide Pesaventob2ae3362017-07-13 01:43:14 -0400325 if (ifa->ifa_name != netif.getName())
Alexander Afanasyev3b3355c2017-03-26 11:57:13 -0500326 continue;
Alexander Afanasyev3b3355c2017-03-26 11:57:13 -0500327
328 netif.setFlags(ifa->ifa_flags);
Alexander Afanasyev3b3355c2017-03-26 11:57:13 -0500329
330 if (ifa->ifa_addr == nullptr)
331 continue;
332
Junxiao Shi2dc416d2017-07-03 04:46:16 +0000333 namespace ip = boost::asio::ip;
Davide Pesaventob2ae3362017-07-13 01:43:14 -0400334 AddressFamily addrFamily = AddressFamily::UNSPECIFIED;
335 ip::address ipAddr, broadcastAddr;
Junxiao Shi2dc416d2017-07-03 04:46:16 +0000336 uint8_t prefixLength = 0;
337
Alexander Afanasyev3b3355c2017-03-26 11:57:13 -0500338 switch (ifa->ifa_addr->sa_family) {
339 case AF_INET: {
Davide Pesaventob2ae3362017-07-13 01:43:14 -0400340 addrFamily = AddressFamily::V4;
Alexander Afanasyev3b3355c2017-03-26 11:57:13 -0500341
342 const sockaddr_in* sin = reinterpret_cast<sockaddr_in*>(ifa->ifa_addr);
Junxiao Shi2dc416d2017-07-03 04:46:16 +0000343 ip::address_v4::bytes_type bytes;
Alexander Afanasyev3b3355c2017-03-26 11:57:13 -0500344 std::copy_n(reinterpret_cast<const unsigned char*>(&sin->sin_addr), bytes.size(), bytes.begin());
Junxiao Shi2dc416d2017-07-03 04:46:16 +0000345 ipAddr = ip::address_v4(bytes);
Alexander Afanasyev3b3355c2017-03-26 11:57:13 -0500346
347 const sockaddr_in* sinMask = reinterpret_cast<sockaddr_in*>(ifa->ifa_netmask);
348 std::copy_n(reinterpret_cast<const unsigned char*>(&sinMask->sin_addr), bytes.size(), bytes.begin());
Junxiao Shi2dc416d2017-07-03 04:46:16 +0000349 prefixLength = computePrefixLength(bytes);
Alexander Afanasyev3b3355c2017-03-26 11:57:13 -0500350 break;
351 }
352
353 case AF_INET6: {
Davide Pesaventob2ae3362017-07-13 01:43:14 -0400354 addrFamily = AddressFamily::V6;
Alexander Afanasyev3b3355c2017-03-26 11:57:13 -0500355
356 const sockaddr_in6* sin6 = reinterpret_cast<sockaddr_in6*>(ifa->ifa_addr);
Junxiao Shi2dc416d2017-07-03 04:46:16 +0000357 ip::address_v6::bytes_type bytes;
Alexander Afanasyev3b3355c2017-03-26 11:57:13 -0500358 std::copy_n(reinterpret_cast<const unsigned char*>(&sin6->sin6_addr), bytes.size(), bytes.begin());
Davide Pesavento25203712017-10-09 23:50:03 -0400359 ip::address_v6 v6Addr(bytes);
360 if (v6Addr.is_link_local())
361 v6Addr.scope_id(if_nametoindex(netif.getName().data()));
362 ipAddr = v6Addr;
Alexander Afanasyev3b3355c2017-03-26 11:57:13 -0500363
364 const sockaddr_in6* sinMask = reinterpret_cast<sockaddr_in6*>(ifa->ifa_netmask);
365 std::copy_n(reinterpret_cast<const unsigned char*>(&sinMask->sin6_addr), bytes.size(), bytes.begin());
Junxiao Shi2dc416d2017-07-03 04:46:16 +0000366 prefixLength = computePrefixLength(bytes);
Alexander Afanasyev3b3355c2017-03-26 11:57:13 -0500367 break;
368 }
369
370 case AF_LINK: {
371 const sockaddr_dl* sdl = reinterpret_cast<sockaddr_dl*>(ifa->ifa_addr);
372 netif.setIndex(sdl->sdl_index);
Davide Pesaventob2ae3362017-07-13 01:43:14 -0400373
Alexander Afanasyev3b3355c2017-03-26 11:57:13 -0500374 if (sdl->sdl_type == IFT_ETHER && sdl->sdl_alen == ethernet::ADDR_LEN) {
375 netif.setType(InterfaceType::ETHERNET);
376 netif.setEthernetAddress(ethernet::Address(reinterpret_cast<uint8_t*>(LLADDR(sdl))));
Davide Pesaventoc0087982017-07-16 23:32:34 -0400377 NDN_LOG_TRACE(netif.getName() << " has Ethernet address " << netif.getEthernetAddress());
Alexander Afanasyev3b3355c2017-03-26 11:57:13 -0500378 }
379 else if (sdl->sdl_type == IFT_LOOP) {
380 netif.setType(InterfaceType::LOOPBACK);
381 }
382 else {
383 netif.setType(InterfaceType::UNKNOWN);
384 }
385 break;
386 }
Alexander Afanasyev3b3355c2017-03-26 11:57:13 -0500387 }
388
389 if (netif.canBroadcast()) {
390 netif.setEthernetBroadcastAddress(ethernet::getBroadcastAddress());
Davide Pesaventob2ae3362017-07-13 01:43:14 -0400391
392 if (addrFamily == AddressFamily::V4 && ifa->ifa_broadaddr != nullptr) {
393 const sockaddr_in* sin = reinterpret_cast<sockaddr_in*>(ifa->ifa_broadaddr);
394 ip::address_v4::bytes_type bytes;
395 std::copy_n(reinterpret_cast<const unsigned char*>(&sin->sin_addr), bytes.size(), bytes.begin());
396 broadcastAddr = ip::address_v4(bytes);
Davide Pesaventob2ae3362017-07-13 01:43:14 -0400397 }
Alexander Afanasyev3b3355c2017-03-26 11:57:13 -0500398 }
399
Davide Pesaventof0c827e2017-10-03 17:25:00 -0400400 if (addrFamily == AddressFamily::UNSPECIFIED)
401 continue;
402
Davide Pesaventob2ae3362017-07-13 01:43:14 -0400403 AddressScope scope = AddressScope::GLOBAL;
404 if (ipAddr.is_loopback()) {
405 scope = AddressScope::HOST;
406 }
407 else if ((ipAddr.is_v4() && (ipAddr.to_v4().to_ulong() & 0xFFFF0000) == 0xA9FE0000) ||
408 (ipAddr.is_v6() && ipAddr.to_v6().is_link_local())) {
409 scope = AddressScope::LINK;
410 }
411
412 netif.addNetworkAddress(NetworkAddress(addrFamily, ipAddr, broadcastAddr, prefixLength, scope, 0));
Alexander Afanasyev3b3355c2017-03-26 11:57:13 -0500413 }
Alexander Afanasyev3b3355c2017-03-26 11:57:13 -0500414}
415
416void
Junxiao Shi2dc416d2017-07-03 04:46:16 +0000417NetworkMonitorImplOsx::onConfigChanged(SCDynamicStoreRef m_scStore, CFArrayRef changedKeys, void* context)
Alexander Afanasyev3b3355c2017-03-26 11:57:13 -0500418{
Junxiao Shi2dc416d2017-07-03 04:46:16 +0000419 static_cast<NetworkMonitorImplOsx*>(context)->onConfigChanged(changedKeys);
Alexander Afanasyev3b3355c2017-03-26 11:57:13 -0500420}
421
422void
Junxiao Shi2dc416d2017-07-03 04:46:16 +0000423NetworkMonitorImplOsx::onConfigChanged(CFArrayRef changedKeys)
Alexander Afanasyev3b3355c2017-03-26 11:57:13 -0500424{
Davide Pesaventoc0087982017-07-16 23:32:34 -0400425 IfAddrs ifaList;
426
Alexander Afanasyev3b3355c2017-03-26 11:57:13 -0500427 size_t count = CFArrayGetCount(changedKeys);
428 for (size_t i = 0; i != count; ++i) {
Davide Pesaventof0c827e2017-10-03 17:25:00 -0400429 Name key(convertToStdString((CFStringRef)CFArrayGetValueAtIndex(changedKeys, i)));
Alexander Afanasyev3b3355c2017-03-26 11:57:13 -0500430 std::string ifName = key.at(-2).toUri();
431
432 auto ifIt = m_interfaces.find(ifName);
433 if (ifIt == m_interfaces.end()) {
Davide Pesaventoc0087982017-07-16 23:32:34 -0400434 addNewInterface(ifName, ifaList);
Alexander Afanasyev3b3355c2017-03-26 11:57:13 -0500435 return;
436 }
437
Alexander Afanasyev3b3355c2017-03-26 11:57:13 -0500438 auto removeInterface = [&] {
439 NDN_LOG_DEBUG("removing interface " << ifName);
Davide Pesaventof0c827e2017-10-03 17:25:00 -0400440 shared_ptr<NetworkInterface> removedNetif = ifIt->second;
Alexander Afanasyev3b3355c2017-03-26 11:57:13 -0500441 m_interfaces.erase(ifIt);
Davide Pesaventof0c827e2017-10-03 17:25:00 -0400442 this->emitSignal(onInterfaceRemoved, removedNetif);
Alexander Afanasyev3b3355c2017-03-26 11:57:13 -0500443 };
444
Davide Pesaventof0c827e2017-10-03 17:25:00 -0400445 NetworkInterface& netif = *ifIt->second;
446 std::string changedItem = key.at(-1).toUri();
447 if (changedItem == "Link") {
448 auto newState = getInterfaceState(netif);
Alexander Afanasyev3b3355c2017-03-26 11:57:13 -0500449 if (newState == InterfaceState::UNKNOWN) {
450 // check if it is really unknown or interface removed
451 if (getInterfaceNames().count(ifName) == 0) {
Alexander Afanasyev3b3355c2017-03-26 11:57:13 -0500452 removeInterface();
453 return;
454 }
455 }
Davide Pesaventoc0087982017-07-16 23:32:34 -0400456 NDN_LOG_TRACE(ifName << " status changed from " << netif.getState() << " to " << newState);
Alexander Afanasyev3b3355c2017-03-26 11:57:13 -0500457 netif.setState(newState);
458 }
Davide Pesaventof0c827e2017-10-03 17:25:00 -0400459 else if (changedItem == "IPv4" || changedItem == "IPv6") {
460 auto updatedNetif = makeNetworkInterface();
461 updatedNetif->setName(ifName);
462 updateInterfaceInfo(*updatedNetif, ifaList);
463 if (updatedNetif->getType() == InterfaceType::UNKNOWN) {
Davide Pesaventoc0087982017-07-16 23:32:34 -0400464 NDN_LOG_DEBUG(ifName << " type changed to unknown");
Alexander Afanasyev3b3355c2017-03-26 11:57:13 -0500465 removeInterface();
466 return;
467 }
468
Davide Pesaventof0c827e2017-10-03 17:25:00 -0400469 const auto& newAddrs = updatedNetif->getNetworkAddresses();
Alexander Afanasyev3b3355c2017-03-26 11:57:13 -0500470 const auto& oldAddrs = netif.getNetworkAddresses();
Alexander Afanasyev3b3355c2017-03-26 11:57:13 -0500471 std::set<NetworkAddress> added;
472 std::set<NetworkAddress> removed;
Alexander Afanasyev3b3355c2017-03-26 11:57:13 -0500473 std::set_difference(newAddrs.begin(), newAddrs.end(),
474 oldAddrs.begin(), oldAddrs.end(), std::inserter(added, added.end()));
Alexander Afanasyev3b3355c2017-03-26 11:57:13 -0500475 std::set_difference(oldAddrs.begin(), oldAddrs.end(),
476 newAddrs.begin(), newAddrs.end(), std::inserter(removed, removed.end()));
477
478 for (const auto& addr : removed) {
479 netif.removeNetworkAddress(addr);
480 }
Alexander Afanasyev3b3355c2017-03-26 11:57:13 -0500481 for (const auto& addr : added) {
482 netif.addNetworkAddress(addr);
483 }
484 }
485 }
486}
487
Junxiao Shi25467942017-06-30 02:53:14 +0000488} // namespace net
Davide Pesavento9a8bae52016-02-24 20:33:08 +0100489} // namespace ndn