rib: ReadvertiseDestination
refs: #3818 Change-Id: I453d69c4a100ede9065756fe16cb60c19aea33db
This commit is contained in:
Nick Gordon
committed by
Alex Afanasyev
Alex Afanasyev
parent
2a00194316
commit
947192570d
@@ -0,0 +1,67 @@
|
||||
/* -*- Mode:C++; c-file-style:"gnu"; indent-tabs-mode:nil; -*- */
|
||||
/**
|
||||
* Copyright (c) 2014-2016, 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 "nfd-rib-readvertise-destination.hpp"
|
||||
|
||||
namespace nfd {
|
||||
namespace rib {
|
||||
|
||||
using ndn::nfd::ControlParameters;
|
||||
using ndn::nfd::ControlResponse;
|
||||
|
||||
NfdRibReadvertiseDestination::NfdRibReadvertiseDestination(ndn::nfd::Controller& controller,
|
||||
//ndn::KeyChain& keyChain,
|
||||
const ndn::Name& commandPrefix)
|
||||
: m_controller(controller)
|
||||
, m_commandPrefix(commandPrefix)
|
||||
{
|
||||
}
|
||||
|
||||
void
|
||||
NfdRibReadvertiseDestination::advertise(nfd::rib::ReadvertisedRoute& rr,
|
||||
std::function<void()> successCb,
|
||||
std::function<void(const std::string&)> failureCb)
|
||||
{
|
||||
m_controller.start<ndn::nfd::RibRegisterCommand>(ControlParameters()
|
||||
.setName(rr.getPrefix())
|
||||
.setOrigin(ndn::nfd::ROUTE_ORIGIN_CLIENT),
|
||||
[=] (const ControlParameters& cp) { successCb(); },
|
||||
[=] (const ControlResponse& cr) { failureCb(cr.getText()); });
|
||||
}
|
||||
|
||||
void
|
||||
NfdRibReadvertiseDestination::withdraw(nfd::rib::ReadvertisedRoute& rr,
|
||||
std::function<void()> successCb,
|
||||
std::function<void(const std::string&)> failureCb)
|
||||
{
|
||||
m_controller.start<ndn::nfd::RibUnregisterCommand>(ControlParameters()
|
||||
.setName(rr.getPrefix())
|
||||
.setOrigin(ndn::nfd::ROUTE_ORIGIN_CLIENT),
|
||||
[=] (const ControlParameters& cp) { successCb(); },
|
||||
[=] (const ControlResponse& cr) { failureCb(cr.getText()); });
|
||||
}
|
||||
|
||||
} // namespace rib
|
||||
} // namespace nfd
|
||||
@@ -0,0 +1,71 @@
|
||||
/* -*- Mode:C++; c-file-style:"gnu"; indent-tabs-mode:nil; -*- */
|
||||
/**
|
||||
* Copyright (c) 2014-2016, 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/>.
|
||||
*/
|
||||
|
||||
#ifndef NFD_RIB_READVERTISE_NFD_RIB_READVERTISE_DESTINATION_HPP
|
||||
#define NFD_RIB_READVERTISE_NFD_RIB_READVERTISE_DESTINATION_HPP
|
||||
|
||||
#include "readvertised-route.hpp"
|
||||
#include "readvertise-destination.hpp"
|
||||
|
||||
#include <ndn-cxx/mgmt/nfd/command-options.hpp>
|
||||
#include <ndn-cxx/mgmt/nfd/controller.hpp>
|
||||
#include <ndn-cxx/mgmt/nfd/control-command.hpp>
|
||||
#include <ndn-cxx/mgmt/nfd/control-parameters.hpp>
|
||||
#include <ndn-cxx/mgmt/nfd/control-response.hpp>
|
||||
|
||||
namespace nfd {
|
||||
namespace rib {
|
||||
|
||||
/** \brief a readvertise destination using NFD RIB management protocol
|
||||
*/
|
||||
class NfdRibReadvertiseDestination : public ReadvertiseDestination
|
||||
{
|
||||
public:
|
||||
NfdRibReadvertiseDestination(ndn::nfd::Controller& controller,
|
||||
const ndn::Name& commandPrefix);
|
||||
|
||||
/** \brief add a name prefix into NFD RIB
|
||||
*/
|
||||
void
|
||||
advertise(nfd::rib::ReadvertisedRoute& rr,
|
||||
std::function<void()> successCb,
|
||||
std::function<void(const std::string&)> failureCb) override;
|
||||
|
||||
/** \brief remove a name prefix from NFD RIB
|
||||
*/
|
||||
void
|
||||
withdraw(nfd::rib::ReadvertisedRoute& rr,
|
||||
std::function<void()> successCb,
|
||||
std::function<void(const std::string&)> failureCb) override;
|
||||
|
||||
private:
|
||||
ndn::nfd::Controller& m_controller;
|
||||
Name m_commandPrefix;
|
||||
};
|
||||
|
||||
} // namespace rib
|
||||
} // namespace nfd
|
||||
|
||||
#endif // NFD_RIB_READVERTISE_NFD_RIB_READVERTISE_DESTINATION_HPP
|
||||
@@ -0,0 +1,58 @@
|
||||
/* -*- Mode:C++; c-file-style:"gnu"; indent-tabs-mode:nil; -*- */
|
||||
/**
|
||||
* Copyright (c) 2014-2016, 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/>.
|
||||
*/
|
||||
|
||||
#ifndef NFD_RIB_READVERTISE_READVERTISE_DESTINATION_HPP
|
||||
#define NFD_RIB_READVERTISE_READVERTISE_DESTINATION_HPP
|
||||
|
||||
#include "readvertised-route.hpp"
|
||||
|
||||
#include <ndn-cxx/mgmt/nfd/controller.hpp>
|
||||
|
||||
namespace nfd {
|
||||
namespace rib {
|
||||
|
||||
/** \brief a destination to readvertise into
|
||||
*/
|
||||
class ReadvertiseDestination : noncopyable
|
||||
{
|
||||
public:
|
||||
virtual
|
||||
~ReadvertiseDestination() = default;
|
||||
|
||||
virtual void
|
||||
advertise(nfd::rib::ReadvertisedRoute& rr,
|
||||
std::function<void()> successCb,
|
||||
std::function<void(const std::string&)> failureCb) = 0;
|
||||
|
||||
virtual void
|
||||
withdraw(nfd::rib::ReadvertisedRoute& rr,
|
||||
std::function<void()> successCb,
|
||||
std::function<void(const std::string&)> failureCb) = 0;
|
||||
};
|
||||
|
||||
} // namespace rib
|
||||
} // namespace nfd
|
||||
|
||||
#endif // NFD_RIB_READVERTISE_READVERTISE_DESTINATION_HPP
|
||||
@@ -0,0 +1,46 @@
|
||||
/* -*- Mode:C++; c-file-style:"gnu"; indent-tabs-mode:nil; -*- */
|
||||
/**
|
||||
* Copyright (c) 2014-2016, 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 "readvertised-route.hpp"
|
||||
|
||||
namespace nfd {
|
||||
namespace rib {
|
||||
|
||||
ReadvertisedRoute::ReadvertisedRoute(const ndn::Name& prefix, const ndn::security::SigningInfo& signer,
|
||||
const std::vector<RibRouteRef>& routes)
|
||||
: m_prefix(prefix)
|
||||
, m_signer(signer)
|
||||
, m_ribRoutes(routes)
|
||||
{
|
||||
}
|
||||
|
||||
bool
|
||||
operator<(const ReadvertisedRoute& lhs, const ReadvertisedRoute& rhs)
|
||||
{
|
||||
return lhs.getPrefix() < rhs.getPrefix();
|
||||
}
|
||||
|
||||
} // namespace rib
|
||||
} // namespace nfd
|
||||
@@ -0,0 +1,82 @@
|
||||
/* -*- Mode:C++; c-file-style:"gnu"; indent-tabs-mode:nil; -*- */
|
||||
/**
|
||||
* Copyright (c) 2014-2016, 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/>.
|
||||
*/
|
||||
|
||||
#ifndef NFD_RIB_READVERTISE_READVERTISED_ROUTE_HPP
|
||||
#define NFD_RIB_READVERTISE_READVERTISED_ROUTE_HPP
|
||||
|
||||
#include "../rib.hpp"
|
||||
#include <ndn-cxx/security/signing-info.hpp>
|
||||
|
||||
namespace nfd {
|
||||
namespace rib {
|
||||
|
||||
/** \brief a readvertised route
|
||||
*/
|
||||
class ReadvertisedRoute
|
||||
{
|
||||
public:
|
||||
/** \brief standard constructor
|
||||
*/
|
||||
ReadvertisedRoute(const ndn::Name& prefix, const ndn::security::SigningInfo& signer,
|
||||
const std::vector<RibRouteRef>& routes);
|
||||
|
||||
/** \return name prefix being advertised
|
||||
*/
|
||||
const Name&
|
||||
getPrefix() const
|
||||
{
|
||||
return m_prefix;
|
||||
}
|
||||
|
||||
/** \return signer
|
||||
*/
|
||||
const ndn::security::SigningInfo&
|
||||
getSigner() const
|
||||
{
|
||||
return m_signer;
|
||||
}
|
||||
|
||||
/** \return routes that caused the creation of this readvertised route
|
||||
*/
|
||||
const std::vector<RibRouteRef>&
|
||||
getRibRoutes() const
|
||||
{
|
||||
return m_ribRoutes;
|
||||
}
|
||||
|
||||
|
||||
private:
|
||||
Name m_prefix;
|
||||
ndn::security::SigningInfo m_signer;
|
||||
std::vector<RibRouteRef> m_ribRoutes;
|
||||
};
|
||||
|
||||
bool
|
||||
operator<(const ReadvertisedRoute& lhs, const ReadvertisedRoute& rhs);
|
||||
|
||||
} // namespace rib
|
||||
} // namespace nfd
|
||||
|
||||
#endif // NFD_RIB_READVERTISE_READVERTISED_ROUTE_HPP
|
||||
@@ -0,0 +1,238 @@
|
||||
/* -*- Mode:C++; c-file-style:"gnu"; indent-tabs-mode:nil; -*- */
|
||||
/**
|
||||
* Copyright (c) 2014-2016, 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 "tests/test-common.hpp"
|
||||
|
||||
#include "rib/readvertise/nfd-rib-readvertise-destination.hpp"
|
||||
|
||||
#include <ndn-cxx/util/dummy-client-face.hpp>
|
||||
#include <ndn-cxx/security/signing-info.hpp>
|
||||
|
||||
#include "tests/identity-management-fixture.hpp"
|
||||
|
||||
namespace nfd {
|
||||
namespace rib {
|
||||
namespace tests {
|
||||
|
||||
using namespace nfd::tests;
|
||||
|
||||
class NfdRibReadvertiseDestinationFixture : public IdentityManagementTimeFixture
|
||||
{
|
||||
public:
|
||||
NfdRibReadvertiseDestinationFixture()
|
||||
: nSuccessCallbacks(0)
|
||||
, nFailureCallbacks(0)
|
||||
, face(getGlobalIoService(), m_keyChain, {true, false})
|
||||
, controller(face, m_keyChain)
|
||||
, dest(controller, Name("/localhop/nfd/rib/readvertise"))
|
||||
, successCallback([this] () {
|
||||
nSuccessCallbacks++;
|
||||
})
|
||||
, failureCallback([this] (const std::string& str) {
|
||||
nFailureCallbacks++;
|
||||
})
|
||||
{
|
||||
}
|
||||
|
||||
public:
|
||||
uint32_t nSuccessCallbacks;
|
||||
uint32_t nFailureCallbacks;
|
||||
|
||||
protected:
|
||||
ndn::util::DummyClientFace face;
|
||||
ndn::nfd::Controller controller;
|
||||
NfdRibReadvertiseDestination dest;
|
||||
std::function<void()> successCallback;
|
||||
std::function<void(const std::string&)> failureCallback;
|
||||
};
|
||||
|
||||
BOOST_FIXTURE_TEST_SUITE(TestNfdRibReadvertiseDestination, NfdRibReadvertiseDestinationFixture)
|
||||
|
||||
class AdvertiseSuccessScenario
|
||||
{
|
||||
public:
|
||||
ndn::nfd::ControlResponse
|
||||
makeResponse(const ControlParameters& sentCp)
|
||||
{
|
||||
ControlParameters response;
|
||||
|
||||
response.setFaceId(1)
|
||||
.setName(sentCp.getName())
|
||||
.setOrigin(ndn::nfd::ROUTE_ORIGIN_CLIENT)
|
||||
.setCost(0)
|
||||
.setFlags(ndn::nfd::ROUTE_FLAG_CHILD_INHERIT);
|
||||
|
||||
ndn::nfd::ControlResponse responsePayload;
|
||||
responsePayload.setCode(200)
|
||||
.setText("Successfully registered.")
|
||||
.setBody(response.wireEncode());
|
||||
return responsePayload;
|
||||
}
|
||||
|
||||
void
|
||||
checkCommandOutcome(NfdRibReadvertiseDestinationFixture* fixture)
|
||||
{
|
||||
BOOST_CHECK_EQUAL(fixture->nSuccessCallbacks, 1);
|
||||
BOOST_CHECK_EQUAL(fixture->nFailureCallbacks, 0);
|
||||
}
|
||||
};
|
||||
|
||||
class AdvertiseFailureScenario
|
||||
{
|
||||
public:
|
||||
ndn::nfd::ControlResponse
|
||||
makeResponse(ControlParameters sentCp)
|
||||
{
|
||||
ndn::nfd::ControlResponse responsePayload(403, "Not Authenticated");
|
||||
return responsePayload;
|
||||
}
|
||||
|
||||
void
|
||||
checkCommandOutcome(NfdRibReadvertiseDestinationFixture* fixture)
|
||||
{
|
||||
BOOST_CHECK_EQUAL(fixture->nFailureCallbacks, 1);
|
||||
BOOST_CHECK_EQUAL(fixture->nSuccessCallbacks, 0);
|
||||
}
|
||||
};
|
||||
|
||||
typedef boost::mpl::vector<AdvertiseSuccessScenario, AdvertiseFailureScenario> AdvertiseScenarios;
|
||||
|
||||
BOOST_AUTO_TEST_CASE_TEMPLATE(Advertise, Scenario, AdvertiseScenarios)
|
||||
{
|
||||
Scenario scenario;
|
||||
Name prefix("/ndn/memphis/test");
|
||||
ndn::security::SigningInfo secInfo;
|
||||
std::vector<RibRouteRef> routes;
|
||||
ReadvertisedRoute rr(prefix, secInfo, routes);
|
||||
const Name RIB_REGISTER_COMMAND_PREFIX("/localhost/nfd/rib/register");
|
||||
|
||||
dest.advertise(rr, successCallback, failureCallback);
|
||||
advanceClocks(time::milliseconds(100));
|
||||
|
||||
// Retrieve the sent Interest to build the response
|
||||
BOOST_REQUIRE_EQUAL(face.sentInterests.size(), 1);
|
||||
const Interest& sentInterest = face.sentInterests[0];
|
||||
BOOST_CHECK(RIB_REGISTER_COMMAND_PREFIX.isPrefixOf(sentInterest.getName()));
|
||||
|
||||
// Parse the sent command Interest to check correctness.
|
||||
ControlParameters sentCp;
|
||||
BOOST_CHECK_NO_THROW(sentCp.wireDecode(sentInterest.getName().get(RIB_REGISTER_COMMAND_PREFIX.size()).blockFromValue()));
|
||||
BOOST_CHECK_EQUAL(sentCp.getOrigin(), ndn::nfd::ROUTE_ORIGIN_CLIENT);
|
||||
BOOST_CHECK_EQUAL(sentCp.getName(), prefix);
|
||||
|
||||
ndn::nfd::ControlResponse responsePayload = scenario.makeResponse(sentCp);
|
||||
auto responseData = makeData(sentInterest.getName());
|
||||
responseData->setContent(responsePayload.wireEncode());
|
||||
face.receive(*responseData);
|
||||
this->advanceClocks(time::milliseconds(10));
|
||||
|
||||
scenario.checkCommandOutcome(this);
|
||||
}
|
||||
|
||||
class WithdrawSuccessScenario
|
||||
{
|
||||
public:
|
||||
ndn::nfd::ControlResponse
|
||||
makeResponse(const ControlParameters& sentCp)
|
||||
{
|
||||
ControlParameters response;
|
||||
|
||||
response.setFaceId(1)
|
||||
.setName(sentCp.getName())
|
||||
.setOrigin(ndn::nfd::ROUTE_ORIGIN_CLIENT);
|
||||
|
||||
ndn::nfd::ControlResponse responsePayload;
|
||||
responsePayload.setCode(200)
|
||||
.setText("Successfully removed")
|
||||
.setBody(response.wireEncode());
|
||||
|
||||
return responsePayload;
|
||||
}
|
||||
|
||||
void
|
||||
checkCommandOutcome(NfdRibReadvertiseDestinationFixture* fixture)
|
||||
{
|
||||
BOOST_CHECK_EQUAL(fixture->nSuccessCallbacks, 1);
|
||||
BOOST_CHECK_EQUAL(fixture->nFailureCallbacks, 0);
|
||||
}
|
||||
};
|
||||
|
||||
class WithdrawFailureScenario
|
||||
{
|
||||
public:
|
||||
ndn::nfd::ControlResponse
|
||||
makeResponse(ControlParameters sentCp)
|
||||
{
|
||||
ndn::nfd::ControlResponse responsePayload(403, "Not authenticated");
|
||||
return responsePayload;
|
||||
}
|
||||
|
||||
void
|
||||
checkCommandOutcome(NfdRibReadvertiseDestinationFixture* fixture)
|
||||
{
|
||||
BOOST_CHECK_EQUAL(fixture->nFailureCallbacks, 1);
|
||||
BOOST_CHECK_EQUAL(fixture->nSuccessCallbacks, 0);
|
||||
}
|
||||
};
|
||||
|
||||
typedef boost::mpl::vector<WithdrawSuccessScenario, WithdrawFailureScenario> WithdrawScenarios;
|
||||
|
||||
BOOST_AUTO_TEST_CASE_TEMPLATE(Withdraw, Scenario, WithdrawScenarios)
|
||||
{
|
||||
Scenario scenario;
|
||||
Name prefix("/ndn/memphis/test");
|
||||
ndn::security::SigningInfo secInfo;
|
||||
std::vector<RibRouteRef> routes;
|
||||
ReadvertisedRoute rr(prefix, secInfo, routes);
|
||||
const Name RIB_UNREGISTER_COMMAND_PREFIX("/localhost/nfd/rib/unregister");
|
||||
|
||||
dest.withdraw(rr, successCallback, failureCallback);
|
||||
this->advanceClocks(time::milliseconds(10));
|
||||
|
||||
// Retrieve the sent Interest to build the response
|
||||
BOOST_REQUIRE_EQUAL(face.sentInterests.size(), 1);
|
||||
const Interest& sentInterest = face.sentInterests[0];
|
||||
BOOST_CHECK(RIB_UNREGISTER_COMMAND_PREFIX.isPrefixOf(sentInterest.getName()));
|
||||
|
||||
ControlParameters sentCp;
|
||||
BOOST_CHECK_NO_THROW(sentCp.wireDecode(sentInterest.getName().get(RIB_UNREGISTER_COMMAND_PREFIX.size()).blockFromValue()));
|
||||
BOOST_CHECK_EQUAL(sentCp.getOrigin(), ndn::nfd::ROUTE_ORIGIN_CLIENT);
|
||||
BOOST_CHECK_EQUAL(sentCp.getName(), prefix);
|
||||
|
||||
ndn::nfd::ControlResponse responsePayload = scenario.makeResponse(sentCp);
|
||||
auto responseData = makeData(sentInterest.getName());
|
||||
responseData->setContent(responsePayload.wireEncode());
|
||||
|
||||
face.receive(*responseData);
|
||||
this->advanceClocks(time::milliseconds(1));
|
||||
|
||||
scenario.checkCommandOutcome(this);
|
||||
}
|
||||
|
||||
BOOST_AUTO_TEST_SUITE_END() // TestNfdRibReadvertiseDestination
|
||||
|
||||
} // namespace tests
|
||||
} // namespace rib
|
||||
} // namespace nfd
|
||||
Reference in New Issue
Block a user