blob: 02cc041b116e39f0d6c80cef6b9e19e11f6d7d62 [file] [log] [blame]
Davide Pesavento44deacc2014-02-19 10:48:07 +01001/* -*- Mode:C++; c-file-style:"gnu"; indent-tabs-mode:nil; -*- */
2/**
Alexander Afanasyev9bcbc7c2014-04-06 19:37:37 -07003 * Copyright (c) 2014 Regents of the University of California,
4 * Arizona Board of Regents,
5 * Colorado State University,
6 * University Pierre & Marie Curie, Sorbonne University,
7 * Washington University in St. Louis,
8 * Beijing Institute of Technology
9 *
10 * This file is part of NFD (Named Data Networking Forwarding Daemon).
11 * See AUTHORS.md for complete list of NFD authors and contributors.
12 *
13 * NFD is free software: you can redistribute it and/or modify it under the terms
14 * of the GNU General Public License as published by the Free Software Foundation,
15 * either version 3 of the License, or (at your option) any later version.
16 *
17 * NFD is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY;
18 * without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR
19 * PURPOSE. See the GNU General Public License for more details.
20 *
21 * You should have received a copy of the GNU General Public License along with
22 * NFD, e.g., in COPYING.md file. If not, see <http://www.gnu.org/licenses/>.
23 **/
Davide Pesavento44deacc2014-02-19 10:48:07 +010024
25#include "ethernet-face.hpp"
Steve DiBenedettobf6a93d2014-03-21 14:03:02 -060026#include "core/logger.hpp"
Davide Pesaventob60cc122014-03-19 19:26:02 +010027#include "core/network-interface.hpp"
Davide Pesavento44deacc2014-02-19 10:48:07 +010028
29#include <pcap/pcap.h>
30
Davide Pesaventob60cc122014-03-19 19:26:02 +010031#include <cstring> // for std::strncpy()
Davide Pesavento44deacc2014-02-19 10:48:07 +010032#include <arpa/inet.h> // for htons() and ntohs()
33#include <net/ethernet.h> // for struct ether_header
34#include <net/if.h> // for struct ifreq
35#include <stdio.h> // for snprintf()
36#include <sys/ioctl.h> // for ioctl()
37#include <unistd.h> // for dup()
38
Davide Pesavento44deacc2014-02-19 10:48:07 +010039namespace nfd {
40
41NFD_LOG_INIT("EthernetFace")
42
Davide Pesavento44deacc2014-02-19 10:48:07 +010043EthernetFace::EthernetFace(const shared_ptr<boost::asio::posix::stream_descriptor>& socket,
Davide Pesaventob60cc122014-03-19 19:26:02 +010044 const shared_ptr<NetworkInterfaceInfo>& interface,
Davide Pesavento44deacc2014-02-19 10:48:07 +010045 const ethernet::Address& address)
Junxiao Shi79494162014-04-02 18:25:11 -070046 : Face(FaceUri(address), FaceUri::fromDev(interface->name))
Alexander Afanasyeva39b90b2014-03-05 15:31:00 +000047 , m_socket(socket)
Davide Pesaventob60cc122014-03-19 19:26:02 +010048 , m_interfaceName(interface->name)
49 , m_srcAddress(interface->etherAddress)
Davide Pesavento44deacc2014-02-19 10:48:07 +010050 , m_destAddress(address)
51{
Davide Pesaventob60cc122014-03-19 19:26:02 +010052 NFD_LOG_INFO("Creating ethernet face on " << m_interfaceName << ": "
53 << m_srcAddress << " <--> " << m_destAddress);
Davide Pesavento44deacc2014-02-19 10:48:07 +010054 pcapInit();
55
56 int fd = pcap_get_selectable_fd(m_pcap);
57 if (fd < 0)
58 throw Error("pcap_get_selectable_fd() failed");
59
60 // need to duplicate the fd, otherwise both pcap_close()
61 // and stream_descriptor::close() will try to close the
62 // same fd and one of them will fail
63 m_socket->assign(::dup(fd));
64
Davide Pesavento44deacc2014-02-19 10:48:07 +010065 m_interfaceMtu = getInterfaceMtu();
Davide Pesaventob60cc122014-03-19 19:26:02 +010066 NFD_LOG_DEBUG("[id:" << getId() << ",endpoint:" << m_interfaceName
Davide Pesavento44deacc2014-02-19 10:48:07 +010067 << "] Interface MTU is: " << m_interfaceMtu);
68
69 char filter[100];
70 ::snprintf(filter, sizeof(filter),
71 "(ether proto 0x%x) && (ether dst %s) && (not ether src %s)",
72 ETHERTYPE_NDN,
Davide Pesaventoedae3532014-04-09 03:07:11 +020073 m_destAddress.toString().c_str(),
74 m_srcAddress.toString().c_str());
Davide Pesavento44deacc2014-02-19 10:48:07 +010075 setPacketFilter(filter);
76
77 m_socket->async_read_some(boost::asio::null_buffers(),
78 bind(&EthernetFace::handleRead, this,
79 boost::asio::placeholders::error,
80 boost::asio::placeholders::bytes_transferred));
81}
82
83EthernetFace::~EthernetFace()
84{
85 close();
86}
87
88void
89EthernetFace::sendInterest(const Interest& interest)
90{
Alexander Afanasyev7e698e62014-03-07 16:48:35 +000091 onSendInterest(interest);
Davide Pesavento44deacc2014-02-19 10:48:07 +010092 sendPacket(interest.wireEncode());
93}
94
95void
96EthernetFace::sendData(const Data& data)
97{
Alexander Afanasyev7e698e62014-03-07 16:48:35 +000098 onSendData(data);
Davide Pesavento44deacc2014-02-19 10:48:07 +010099 sendPacket(data.wireEncode());
100}
101
102void
103EthernetFace::close()
104{
105 if (m_pcap)
106 {
107 boost::system::error_code error;
108 m_socket->close(error); // ignore errors
109 pcap_close(m_pcap);
110 m_pcap = 0;
111 }
112}
113
114void
115EthernetFace::pcapInit()
116{
Davide Pesavento44deacc2014-02-19 10:48:07 +0100117 char errbuf[PCAP_ERRBUF_SIZE];
118 errbuf[0] = '\0';
Davide Pesaventob60cc122014-03-19 19:26:02 +0100119 m_pcap = pcap_create(m_interfaceName.c_str(), errbuf);
Davide Pesavento44deacc2014-02-19 10:48:07 +0100120 if (!m_pcap)
121 throw Error("pcap_create(): " + std::string(errbuf));
122
Davide Pesavento9eaeac72014-03-15 05:03:42 +0100123 /// \todo Do not rely on promisc mode, see task #1278
124 if (!m_destAddress.isBroadcast())
125 pcap_set_promisc(m_pcap, 1);
126
Davide Pesavento44deacc2014-02-19 10:48:07 +0100127 if (pcap_activate(m_pcap) < 0)
128 throw Error("pcap_activate() failed");
129
Davide Pesavento44deacc2014-02-19 10:48:07 +0100130 if (pcap_set_datalink(m_pcap, DLT_EN10MB) < 0)
131 throw Error("pcap_set_datalink(): " + std::string(pcap_geterr(m_pcap)));
Davide Pesavento9eaeac72014-03-15 05:03:42 +0100132
133 if (pcap_setdirection(m_pcap, PCAP_D_IN) < 0)
134 // no need to throw on failure, BPF will filter unwanted packets anyway
135 NFD_LOG_WARN("pcap_setdirection(): " << pcap_geterr(m_pcap));
Davide Pesavento44deacc2014-02-19 10:48:07 +0100136}
137
138void
139EthernetFace::setPacketFilter(const char* filterString)
140{
141 bpf_program filter;
142 if (pcap_compile(m_pcap, &filter, filterString, 1, PCAP_NETMASK_UNKNOWN) < 0)
143 throw Error("pcap_compile(): " + std::string(pcap_geterr(m_pcap)));
144
145 int ret = pcap_setfilter(m_pcap, &filter);
146 pcap_freecode(&filter);
147 if (ret < 0)
148 throw Error("pcap_setfilter(): " + std::string(pcap_geterr(m_pcap)));
149}
150
151void
152EthernetFace::sendPacket(const ndn::Block& block)
153{
154 if (!m_pcap)
155 {
Davide Pesaventob60cc122014-03-19 19:26:02 +0100156 NFD_LOG_WARN("[id:" << getId() << ",endpoint:" << m_interfaceName
Davide Pesavento44deacc2014-02-19 10:48:07 +0100157 << "] Trying to send on closed face");
158 onFail("Face closed");
159 return;
160 }
161
Davide Pesavento9eaeac72014-03-15 05:03:42 +0100162 /// \todo Fragmentation
Davide Pesavento44deacc2014-02-19 10:48:07 +0100163 if (block.size() > m_interfaceMtu)
Davide Pesavento9eaeac72014-03-15 05:03:42 +0100164 {
Davide Pesaventob60cc122014-03-19 19:26:02 +0100165 NFD_LOG_ERROR("[id:" << getId() << ",endpoint:" << m_interfaceName
166 << "] Fragmentation not implemented: dropping packet larger than MTU");
Davide Pesavento9eaeac72014-03-15 05:03:42 +0100167 return;
168 }
Davide Pesavento44deacc2014-02-19 10:48:07 +0100169
170 /// \todo Right now there is no reserve when packet is received, but
171 /// we should reserve some space at the beginning and at the end
172 ndn::EncodingBuffer buffer(block);
173
Davide Pesaventoe4631002014-03-21 20:55:36 +0100174 // pad with zeroes if the payload is too short
Davide Pesavento44deacc2014-02-19 10:48:07 +0100175 if (block.size() < ethernet::MIN_DATA_LEN)
176 {
Davide Pesaventob60cc122014-03-19 19:26:02 +0100177 static const uint8_t padding[ethernet::MIN_DATA_LEN] = {0};
178 buffer.appendByteArray(padding, ethernet::MIN_DATA_LEN - block.size());
Davide Pesavento44deacc2014-02-19 10:48:07 +0100179 }
180
181 // construct and prepend the ethernet header
182 static uint16_t ethertype = htons(ETHERTYPE_NDN);
183 buffer.prependByteArray(reinterpret_cast<const uint8_t*>(&ethertype), ethernet::TYPE_LEN);
Davide Pesaventob60cc122014-03-19 19:26:02 +0100184 buffer.prependByteArray(m_srcAddress.data(), m_srcAddress.size());
Davide Pesavento44deacc2014-02-19 10:48:07 +0100185 buffer.prependByteArray(m_destAddress.data(), m_destAddress.size());
186
187 // send the packet
188 int sent = pcap_inject(m_pcap, buffer.buf(), buffer.size());
189 if (sent < 0)
190 {
191 throw Error("pcap_inject(): " + std::string(pcap_geterr(m_pcap)));
192 }
193 else if (static_cast<size_t>(sent) < buffer.size())
194 {
195 throw Error("Failed to send packet");
196 }
197
Davide Pesaventob60cc122014-03-19 19:26:02 +0100198 NFD_LOG_TRACE("[id:" << getId() << ",endpoint:" << m_interfaceName
Davide Pesavento44deacc2014-02-19 10:48:07 +0100199 << "] Successfully sent: " << buffer.size() << " bytes");
200}
201
202void
203EthernetFace::handleRead(const boost::system::error_code& error, size_t)
204{
205 if (error)
206 return processErrorCode(error);
207
208 pcap_pkthdr* pktHeader;
209 const uint8_t* packet;
210 int ret = pcap_next_ex(m_pcap, &pktHeader, &packet);
211 if (ret < 0)
212 {
213 throw Error("pcap_next_ex(): " + std::string(pcap_geterr(m_pcap)));
214 }
215 else if (ret == 0)
216 {
Davide Pesaventob60cc122014-03-19 19:26:02 +0100217 NFD_LOG_WARN("[id:" << getId() << ",endpoint:" << m_interfaceName
Davide Pesavento44deacc2014-02-19 10:48:07 +0100218 << "] pcap_next_ex() timed out");
219 }
220 else
221 {
222 size_t length = pktHeader->caplen;
223 if (length < ethernet::HDR_LEN + ethernet::MIN_DATA_LEN)
224 throw Error("Received packet is too short");
225
226 const ether_header* eh = reinterpret_cast<const ether_header*>(packet);
227 if (ntohs(eh->ether_type) != ETHERTYPE_NDN)
228 throw Error("Unrecognized ethertype");
229
230 packet += ethernet::HDR_LEN;
231 length -= ethernet::HDR_LEN;
Davide Pesaventob60cc122014-03-19 19:26:02 +0100232 NFD_LOG_TRACE("[id:" << getId() << ",endpoint:" << m_interfaceName
Davide Pesavento44deacc2014-02-19 10:48:07 +0100233 << "] Received: " << length << " bytes");
234
Alexander Afanasyev5a8d8d82014-03-21 14:08:41 -0700235 /// \todo Reserve space in front and at the back
236 /// of the underlying buffer
237 Block element;
238 bool isOk = Block::fromBuffer(packet, length, element);
239 if (isOk)
240 {
241 if (!decodeAndDispatchInput(element))
242 {
243 NFD_LOG_WARN("[id:" << getId() << ",endpoint:" << m_interfaceName
244 << "] Received unrecognized block of type " << element.type());
245 // ignore unknown packet
246 }
247 }
248 else
249 {
250 NFD_LOG_WARN("[id:" << getId() << ",endpoint:" << m_interfaceName
251 << "] Received block is invalid or too large to process");
252 }
Davide Pesavento44deacc2014-02-19 10:48:07 +0100253 }
254
255 m_socket->async_read_some(boost::asio::null_buffers(),
256 bind(&EthernetFace::handleRead, this,
257 boost::asio::placeholders::error,
258 boost::asio::placeholders::bytes_transferred));
259}
260
261void
262EthernetFace::processErrorCode(const boost::system::error_code& error)
263{
264 if (error == boost::system::errc::operation_canceled)
265 // when socket is closed by someone
266 return;
267
268 if (!m_pcap)
269 {
270 onFail("Face closed");
271 return;
272 }
273
274 std::string msg;
275 if (error == boost::asio::error::eof)
276 {
277 msg = "Face closed";
Davide Pesaventob60cc122014-03-19 19:26:02 +0100278 NFD_LOG_INFO("[id:" << getId() << ",endpoint:" << m_interfaceName << "] " << msg);
Davide Pesavento44deacc2014-02-19 10:48:07 +0100279 }
280 else
281 {
Davide Pesaventob60cc122014-03-19 19:26:02 +0100282 msg = "Receive operation failed, closing face: " + error.category().message(error.value());
283 NFD_LOG_WARN("[id:" << getId() << ",endpoint:" << m_interfaceName << "] " << msg);
Davide Pesavento44deacc2014-02-19 10:48:07 +0100284 }
285
286 close();
287 onFail(msg);
288}
289
Davide Pesavento44deacc2014-02-19 10:48:07 +0100290size_t
291EthernetFace::getInterfaceMtu() const
292{
293 size_t mtu = ethernet::MAX_DATA_LEN;
294
295#ifdef SIOCGIFMTU
Davide Pesaventoe4631002014-03-21 20:55:36 +0100296 ifreq ifr = {};
Davide Pesaventob60cc122014-03-19 19:26:02 +0100297 std::strncpy(ifr.ifr_name, m_interfaceName.c_str(), sizeof(ifr.ifr_name) - 1);
Davide Pesavento44deacc2014-02-19 10:48:07 +0100298
299 if (::ioctl(m_socket->native_handle(), SIOCGIFMTU, &ifr) < 0)
300 {
Davide Pesaventob60cc122014-03-19 19:26:02 +0100301 NFD_LOG_WARN("[id:" << getId() << ",endpoint:" << m_interfaceName
Davide Pesavento44deacc2014-02-19 10:48:07 +0100302 << "] Failed to get interface MTU, assuming " << mtu);
303 }
304 else
305 {
306 mtu = std::min(mtu, static_cast<size_t>(ifr.ifr_mtu));
307 }
308#endif
309
310 return mtu;
311}
312
313} // namespace nfd