blob: 5e942d2c6987816fc0cf25dd50f67b2722e97872 [file] [log] [blame]
/* -*- Mode:C++; c-file-style:"gnu"; indent-tabs-mode:nil; -*- */
/*
* Copyright (c) 2014-2017, Regents of the University of California,
* Arizona Board of Regents,
* Colorado State University,
* University Pierre & Marie Curie, Sorbonne University,
* Washington University in St. Louis,
* Beijing Institute of Technology,
* The University of Memphis.
*
* This file is part of NFD (Named Data Networking Forwarding Daemon).
* See AUTHORS.md for complete list of NFD authors and contributors.
*
* NFD is free software: you can redistribute it and/or modify it under the terms
* of the GNU General Public License as published by the Free Software Foundation,
* either version 3 of the License, or (at your option) any later version.
*
* NFD is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY;
* without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR
* PURPOSE. See the GNU General Public License for more details.
*
* You should have received a copy of the GNU General Public License along with
* NFD, e.g., in COPYING.md file. If not, see <http://www.gnu.org/licenses/>.
*/
#include "face/ethernet-factory.hpp"
#include "face/face.hpp"
#include "ethernet-fixture.hpp"
#include "face-system-fixture.hpp"
#include "factory-test-common.hpp"
#include <boost/algorithm/string/replace.hpp>
#include <boost/range/algorithm/count_if.hpp>
namespace nfd {
namespace face {
namespace tests {
class EthernetFactoryFixture : public EthernetFixture
, public FaceSystemFactoryFixture<EthernetFactory>
{
protected:
EthernetFactoryFixture()
{
this->copyRealNetifsToNetmon();
}
std::set<std::string>
listUrisOfAvailableNetifs() const
{
std::set<std::string> uris;
std::transform(netifs.begin(), netifs.end(), std::inserter(uris, uris.end()),
[] (const shared_ptr<const ndn::net::NetworkInterface>& ni) {
return FaceUri::fromDev(ni->getName()).toString();
});
return uris;
}
std::vector<const Face*>
listEtherMcastFaces(ndn::nfd::LinkType linkType = ndn::nfd::LINK_TYPE_MULTI_ACCESS) const
{
return this->listFacesByScheme("ether", linkType);
}
size_t
countEtherMcastFaces(ndn::nfd::LinkType linkType = ndn::nfd::LINK_TYPE_MULTI_ACCESS) const
{
return this->listEtherMcastFaces(linkType).size();
}
};
BOOST_AUTO_TEST_SUITE(Face)
BOOST_FIXTURE_TEST_SUITE(TestEthernetFactory, EthernetFactoryFixture)
using nfd::Face;
BOOST_AUTO_TEST_SUITE(ProcessConfig)
BOOST_AUTO_TEST_CASE(ListeningChannels)
{
SKIP_IF_ETHERNET_NETIF_COUNT_LT(1);
const std::string CONFIG = R"CONFIG(
face_system
{
ether
{
listen yes
idle_timeout 60
mcast no
}
}
)CONFIG";
parseConfig(CONFIG, true);
parseConfig(CONFIG, false);
auto& factory = this->getFactoryById<EthernetFactory>("ether");
checkChannelListEqual(factory, this->listUrisOfAvailableNetifs());
for (const auto& channel : factory.getChannels()) {
BOOST_CHECK_EQUAL(channel->isListening(), true);
}
BOOST_CHECK_EQUAL(this->countEtherMcastFaces(), 0);
}
BOOST_AUTO_TEST_CASE(NonListeningChannels)
{
SKIP_IF_ETHERNET_NETIF_COUNT_LT(1);
const std::string CONFIG = R"CONFIG(
face_system
{
ether
{
listen no
idle_timeout 60
mcast no
}
}
)CONFIG";
parseConfig(CONFIG, true);
parseConfig(CONFIG, false);
auto& factory = this->getFactoryById<EthernetFactory>("ether");
checkChannelListEqual(factory, this->listUrisOfAvailableNetifs());
for (const auto& channel : factory.getChannels()) {
BOOST_CHECK_EQUAL(channel->isListening(), false);
}
BOOST_CHECK_EQUAL(this->countEtherMcastFaces(), 0);
}
BOOST_AUTO_TEST_CASE(BadListen)
{
const std::string CONFIG = R"CONFIG(
face_system
{
ether
{
listen hello
}
}
)CONFIG";
BOOST_CHECK_THROW(parseConfig(CONFIG, true), ConfigFile::Error);
BOOST_CHECK_THROW(parseConfig(CONFIG, false), ConfigFile::Error);
}
BOOST_AUTO_TEST_CASE(McastNormal)
{
SKIP_IF_ETHERNET_NETIF_COUNT_LT(1);
const std::string CONFIG = R"CONFIG(
face_system
{
ether
{
listen no
mcast yes
mcast_group 01:00:5E:00:17:AA
mcast_ad_hoc no
whitelist
{
*
}
blacklist
{
}
}
}
)CONFIG";
parseConfig(CONFIG, true);
parseConfig(CONFIG, false);
BOOST_CHECK_EQUAL(this->countEtherMcastFaces(), netifs.size());
}
BOOST_AUTO_TEST_CASE(EnableDisableMcast)
{
const std::string CONFIG_WITH_MCAST = R"CONFIG(
face_system
{
ether
{
listen no
mcast yes
}
}
)CONFIG";
const std::string CONFIG_WITHOUT_MCAST = R"CONFIG(
face_system
{
ether
{
listen no
mcast no
}
}
)CONFIG";
parseConfig(CONFIG_WITHOUT_MCAST, false);
BOOST_CHECK_EQUAL(this->countEtherMcastFaces(), 0);
SKIP_IF_ETHERNET_NETIF_COUNT_LT(1);
parseConfig(CONFIG_WITH_MCAST, false);
g_io.poll();
BOOST_CHECK_EQUAL(this->countEtherMcastFaces(), netifs.size());
parseConfig(CONFIG_WITHOUT_MCAST, false);
g_io.poll();
BOOST_CHECK_EQUAL(this->countEtherMcastFaces(), 0);
}
BOOST_AUTO_TEST_CASE(McastAdHoc)
{
SKIP_IF_ETHERNET_NETIF_COUNT_LT(1);
const std::string CONFIG = R"CONFIG(
face_system
{
ether
{
listen no
mcast yes
mcast_ad_hoc yes
}
}
)CONFIG";
parseConfig(CONFIG, false);
BOOST_CHECK_EQUAL(this->countEtherMcastFaces(ndn::nfd::LINK_TYPE_MULTI_ACCESS), 0);
BOOST_CHECK_EQUAL(this->countEtherMcastFaces(ndn::nfd::LINK_TYPE_AD_HOC), netifs.size());
}
BOOST_AUTO_TEST_CASE(ChangeMcastGroup)
{
SKIP_IF_ETHERNET_NETIF_COUNT_LT(1);
const std::string CONFIG1 = R"CONFIG(
face_system
{
ether
{
mcast_group 01:00:5e:90:10:01
}
}
)CONFIG";
const std::string CONFIG2 = R"CONFIG(
face_system
{
ether
{
mcast_group 01:00:5e:90:10:02
}
}
)CONFIG";
parseConfig(CONFIG1, false);
auto etherMcastFaces = this->listEtherMcastFaces();
BOOST_REQUIRE_EQUAL(etherMcastFaces.size(), netifs.size());
BOOST_CHECK_EQUAL(etherMcastFaces.front()->getRemoteUri(),
FaceUri(ethernet::Address{0x01, 0x00, 0x5e, 0x90, 0x10, 0x01}));
parseConfig(CONFIG2, false);
g_io.poll();
etherMcastFaces = this->listEtherMcastFaces();
BOOST_REQUIRE_EQUAL(etherMcastFaces.size(), netifs.size());
BOOST_CHECK_EQUAL(etherMcastFaces.front()->getRemoteUri(),
FaceUri(ethernet::Address{0x01, 0x00, 0x5e, 0x90, 0x10, 0x02}));
}
BOOST_AUTO_TEST_CASE(Whitelist)
{
SKIP_IF_ETHERNET_NETIF_COUNT_LT(1);
std::string CONFIG = R"CONFIG(
face_system
{
ether
{
whitelist
{
ifname %ifname
}
}
}
)CONFIG";
auto ifname = netifs.front()->getName();
boost::replace_first(CONFIG, "%ifname", ifname);
parseConfig(CONFIG, false);
auto etherMcastFaces = this->listEtherMcastFaces();
BOOST_REQUIRE_EQUAL(etherMcastFaces.size(), 1);
BOOST_CHECK_EQUAL(etherMcastFaces.front()->getLocalUri(), FaceUri::fromDev(ifname));
}
BOOST_AUTO_TEST_CASE(Blacklist)
{
SKIP_IF_ETHERNET_NETIF_COUNT_LT(1);
std::string CONFIG = R"CONFIG(
face_system
{
ether
{
blacklist
{
ifname %ifname
}
}
}
)CONFIG";
auto ifname = netifs.front()->getName();
boost::replace_first(CONFIG, "%ifname", ifname);
parseConfig(CONFIG, false);
auto etherMcastFaces = this->listEtherMcastFaces();
BOOST_CHECK_EQUAL(etherMcastFaces.size(), netifs.size() - 1);
BOOST_CHECK_EQUAL(boost::count_if(etherMcastFaces, [ifname] (const Face* face) {
return face->getLocalUri() == FaceUri::fromDev(ifname);
}), 0);
}
BOOST_AUTO_TEST_CASE(Omitted)
{
const std::string CONFIG = R"CONFIG(
face_system
{
}
)CONFIG";
parseConfig(CONFIG, true);
parseConfig(CONFIG, false);
BOOST_CHECK_EQUAL(this->countEtherMcastFaces(), 0);
}
BOOST_AUTO_TEST_CASE(BadMcast)
{
const std::string CONFIG = R"CONFIG(
face_system
{
ether
{
mcast hello
}
}
)CONFIG";
BOOST_CHECK_THROW(parseConfig(CONFIG, true), ConfigFile::Error);
BOOST_CHECK_THROW(parseConfig(CONFIG, false), ConfigFile::Error);
}
BOOST_AUTO_TEST_CASE(BadMcastGroup)
{
const std::string CONFIG = R"CONFIG(
face_system
{
ether
{
mcast yes
mcast_group hello
}
}
)CONFIG";
BOOST_CHECK_THROW(parseConfig(CONFIG, true), ConfigFile::Error);
BOOST_CHECK_THROW(parseConfig(CONFIG, false), ConfigFile::Error);
}
BOOST_AUTO_TEST_CASE(UnicastMcastGroup)
{
const std::string CONFIG = R"CONFIG(
face_system
{
ether
{
mcast yes
mcast_group 00:00:5e:00:53:5e
}
}
)CONFIG";
BOOST_CHECK_THROW(parseConfig(CONFIG, true), ConfigFile::Error);
BOOST_CHECK_THROW(parseConfig(CONFIG, false), ConfigFile::Error);
}
BOOST_AUTO_TEST_CASE(UnknownOption)
{
const std::string CONFIG = R"CONFIG(
face_system
{
ether
{
hello
}
}
)CONFIG";
BOOST_CHECK_THROW(parseConfig(CONFIG, true), ConfigFile::Error);
BOOST_CHECK_THROW(parseConfig(CONFIG, false), ConfigFile::Error);
}
BOOST_AUTO_TEST_SUITE_END() // ProcessConfig
BOOST_AUTO_TEST_CASE(GetChannels)
{
BOOST_CHECK_EQUAL(factory.getChannels().empty(), true);
SKIP_IF_ETHERNET_NETIF_COUNT_LT(1);
factory.createChannel(netifs.front(), time::minutes(1));
checkChannelListEqual(factory, {FaceUri::fromDev(netifs.front()->getName()).toString()});
}
BOOST_AUTO_TEST_CASE(CreateChannel)
{
SKIP_IF_ETHERNET_NETIF_COUNT_LT(1);
auto channel1 = factory.createChannel(netifs.front(), time::minutes(1));
auto channel1a = factory.createChannel(netifs.front(), time::minutes(5));
BOOST_CHECK_EQUAL(channel1, channel1a);
BOOST_CHECK_EQUAL(channel1->getUri().toString(), "dev://" + netifs.front()->getName());
SKIP_IF_ETHERNET_NETIF_COUNT_LT(2);
auto channel2 = factory.createChannel(netifs.back(), time::minutes(1));
BOOST_CHECK_NE(channel1, channel2);
}
BOOST_AUTO_TEST_CASE(CreateFace)
{
createFace(factory,
FaceUri("ether://[00:00:5e:00:53:5e]"),
FaceUri("dev://eth0"),
ndn::nfd::FACE_PERSISTENCY_PERSISTENT,
false,
{CreateFaceExpectedResult::FAILURE, 504, "No channels available to connect"});
SKIP_IF_ETHERNET_NETIF_COUNT_LT(1);
auto localUri = factory.createChannel(netifs.front(), time::minutes(1))->getUri();
createFace(factory,
FaceUri("ether://[00:00:5e:00:53:5e]"),
localUri,
ndn::nfd::FACE_PERSISTENCY_PERSISTENT,
false,
{CreateFaceExpectedResult::SUCCESS, 0, ""});
createFace(factory,
FaceUri("ether://[00:00:5e:00:53:5e]"),
localUri,
ndn::nfd::FACE_PERSISTENCY_PERMANENT,
false,
{CreateFaceExpectedResult::SUCCESS, 0, ""});
createFace(factory,
FaceUri("ether://[00:00:5e:00:53:53]"),
localUri,
ndn::nfd::FACE_PERSISTENCY_PERMANENT,
false,
{CreateFaceExpectedResult::SUCCESS, 0, ""});
}
BOOST_AUTO_TEST_CASE(UnsupportedCreateFace)
{
createFace(factory,
FaceUri("ether://[00:00:5e:00:53:5e]"),
{},
ndn::nfd::FACE_PERSISTENCY_PERSISTENT,
false,
{CreateFaceExpectedResult::FAILURE, 406,
"Creation of unicast Ethernet faces requires a LocalUri with dev:// scheme"});
createFace(factory,
FaceUri("ether://[00:00:5e:00:53:5e]"),
FaceUri("udp4://127.0.0.1:20071"),
ndn::nfd::FACE_PERSISTENCY_PERSISTENT,
false,
{CreateFaceExpectedResult::FAILURE, 406,
"Creation of unicast Ethernet faces requires a LocalUri with dev:// scheme"});
createFace(factory,
FaceUri("ether://[00:00:5e:00:53:5e]"),
FaceUri("dev://eth0"),
ndn::nfd::FACE_PERSISTENCY_ON_DEMAND,
false,
{CreateFaceExpectedResult::FAILURE, 406,
"Outgoing Ethernet faces do not support on-demand persistency"});
createFace(factory,
FaceUri("ether://[01:00:5e:90:10:5e]"),
FaceUri("dev://eth0"),
ndn::nfd::FACE_PERSISTENCY_PERSISTENT,
false,
{CreateFaceExpectedResult::FAILURE, 406,
"Cannot create multicast Ethernet faces"});
createFace(factory,
FaceUri("ether://[00:00:5e:00:53:5e]"),
FaceUri("dev://eth0"),
ndn::nfd::FACE_PERSISTENCY_PERSISTENT,
true,
{CreateFaceExpectedResult::FAILURE, 406,
"Local fields can only be enabled on faces with local scope"});
}
BOOST_AUTO_TEST_SUITE_END() // TestEthernetFactory
BOOST_AUTO_TEST_SUITE_END() // Face
} // namespace tests
} // namespace face
} // namespace nfd