blob: db31f61f55702a7714d17ac5216b579121e73607 [file] [log] [blame]
Davide Pesavento9a8bae52016-02-24 20:33:08 +01001/* -*- Mode:C++; c-file-style:"gnu"; indent-tabs-mode:nil; -*- */
2/**
Davide Pesavento2bf35a62017-04-02 00:41:06 -04003 * Copyright (c) 2013-2017 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.
Davide Pesavento2bf35a62017-04-02 00:41:06 -040020 *
21 * @author Davide Pesavento <davide.pesavento@lip6.fr>
Davide Pesavento9a8bae52016-02-24 20:33:08 +010022 */
23
24#ifndef NDN_UTIL_NETWORK_MONITOR_IMPL_RTNL_HPP
25#define NDN_UTIL_NETWORK_MONITOR_IMPL_RTNL_HPP
26
Davide Pesavento2bf35a62017-04-02 00:41:06 -040027#include "ndn-cxx-config.hpp"
Davide Pesavento9a8bae52016-02-24 20:33:08 +010028#include "../network-monitor.hpp"
29
Davide Pesavento2bf35a62017-04-02 00:41:06 -040030#ifndef NDN_CXX_HAVE_RTNETLINK
31#error "This file should not be compiled ..."
32#endif
33
Davide Pesavento9a8bae52016-02-24 20:33:08 +010034#include <boost/asio/posix/stream_descriptor.hpp>
35
Davide Pesavento2bf35a62017-04-02 00:41:06 -040036#include <array>
37#include <map>
38
39#include <linux/netlink.h>
40#include <linux/rtnetlink.h>
41#include <linux/if_addr.h>
42#include <linux/if_link.h>
43
Davide Pesavento9a8bae52016-02-24 20:33:08 +010044namespace ndn {
45namespace util {
46
Davide Pesavento9a8bae52016-02-24 20:33:08 +010047class NetworkMonitor::Impl
48{
49public:
Davide Pesavento2bf35a62017-04-02 00:41:06 -040050 /** \brief initialize netlink socket and start enumerating interfaces
51 */
Davide Pesavento9a8bae52016-02-24 20:33:08 +010052 Impl(NetworkMonitor& nm, boost::asio::io_service& io);
53
Davide Pesavento2bf35a62017-04-02 00:41:06 -040054 ~Impl();
55
Junxiao Shif4c1eb32017-05-30 17:05:10 +000056 uint32_t
57 getCapabilities() const
58 {
59 return NetworkMonitor::CAP_ENUM |
60 NetworkMonitor::CAP_IF_ADD_REMOVE |
61 NetworkMonitor::CAP_STATE_CHANGE |
62 NetworkMonitor::CAP_MTU_CHANGE |
63 NetworkMonitor::CAP_ADDR_ADD_REMOVE;
64 }
65
Davide Pesavento2bf35a62017-04-02 00:41:06 -040066 shared_ptr<NetworkInterface>
67 getNetworkInterface(const std::string& ifname) const;
68
69 std::vector<shared_ptr<NetworkInterface>>
70 listNetworkInterfaces() const;
71
Davide Pesavento9a8bae52016-02-24 20:33:08 +010072private:
Davide Pesavento2bf35a62017-04-02 00:41:06 -040073 struct RtnlRequest
74 {
75 nlmsghdr nlh;
76 ifinfomsg ifi;
77 rtattr rta __attribute__((aligned(NLMSG_ALIGNTO))); // rtattr has to be aligned
78 uint32_t rtext; // space for IFLA_EXT_MASK
79 };
80
81 bool
82 isEnumerating() const;
83
Davide Pesavento9a8bae52016-02-24 20:33:08 +010084 void
Davide Pesavento2bf35a62017-04-02 00:41:06 -040085 initSocket();
86
87 void
88 sendDumpRequest(uint16_t nlmsgType);
89
90 void
91 asyncRead();
92
93 void
94 handleRead(const boost::system::error_code& error, size_t nBytesReceived,
95 const shared_ptr<boost::asio::posix::stream_descriptor>& socket);
96
97 void
98 parseNetlinkMessage(const nlmsghdr* nlh, size_t len);
99
100 void
101 parseLinkMessage(const nlmsghdr* nlh, const ifinfomsg* ifi);
102
103 void
104 parseAddressMessage(const nlmsghdr* nlh, const ifaddrmsg* ifa);
105
106 void
107 parseRouteMessage(const nlmsghdr* nlh, const rtmsg* rtm);
108
109 static void
110 updateInterfaceState(NetworkInterface& interface, uint8_t operState);
Davide Pesavento9a8bae52016-02-24 20:33:08 +0100111
112private:
113 NetworkMonitor& m_nm;
Davide Pesavento2bf35a62017-04-02 00:41:06 -0400114 std::map<int /*ifindex*/, shared_ptr<NetworkInterface>> m_interfaces; ///< interface map
115 std::array<uint8_t, 16384> m_buffer; ///< holds netlink messages received from the kernel
116 shared_ptr<boost::asio::posix::stream_descriptor> m_socket; ///< the netlink socket
117 uint32_t m_pid; ///< our port ID (unicast address for netlink sockets)
118 uint32_t m_sequenceNo; ///< sequence number of the last netlink request sent to the kernel
119 bool m_isEnumeratingLinks; ///< true if a dump of all links is in progress
120 bool m_isEnumeratingAddresses; ///< true if a dump of all addresses is in progress
Davide Pesavento9a8bae52016-02-24 20:33:08 +0100121};
122
123} // namespace util
124} // namespace ndn
125
126#endif // NDN_UTIL_NETWORK_MONITOR_IMPL_RTNL_HPP