Access Router strategy. More...
#include <access-strategy.hpp>
Public Member Functions | |
AccessStrategy (Forwarder &forwarder, const Name &name=getStrategyName()) | |
void | afterReceiveInterest (const Interest &interest, const FaceEndpoint &ingress, const shared_ptr< pit::Entry > &pitEntry) override |
Trigger after an Interest is received. More... | |
void | beforeSatisfyInterest (const Data &data, const FaceEndpoint &ingress, const shared_ptr< pit::Entry > &pitEntry) override |
trigger before PIT entry is satisfied More... | |
Public Member Functions inherited from nfd::fw::Strategy | |
Strategy (Forwarder &forwarder) | |
Construct a strategy instance. More... | |
virtual | ~Strategy () |
const Name & | getInstanceName () const |
virtual void | afterReceiveLoopedInterest (const FaceEndpoint &ingress, const Interest &interest, pit::Entry &pitEntry) |
trigger after a looped Interest is received More... | |
virtual void | satisfyInterest (const shared_ptr< pit::Entry > &pitEntry, const FaceEndpoint &ingress, const Data &data, std::set< std::pair< Face *, EndpointId >> &satisfiedDownstreams, std::set< std::pair< Face *, EndpointId >> &unsatisfiedDownstreams) |
virtual void | afterContentStoreHit (const Data &data, const FaceEndpoint &ingress, const shared_ptr< pit::Entry > &pitEntry) |
trigger after a Data is matched in CS More... | |
virtual void | afterReceiveData (const Data &data, const FaceEndpoint &ingress, const shared_ptr< pit::Entry > &pitEntry) |
trigger after Data is received More... | |
virtual void | afterReceiveNack (const lp::Nack &nack, const FaceEndpoint &ingress, const shared_ptr< pit::Entry > &pitEntry) |
Trigger after a Nack is received. More... | |
virtual void | onDroppedInterest (const Interest &interest, Face &egress) |
Trigger after an Interest is dropped (e.g., for exceeding allowed retransmissions). More... | |
virtual void | afterNewNextHop (const fib::NextHop &nextHop, const shared_ptr< pit::Entry > &pitEntry) |
Trigger after a new nexthop is added. More... | |
Static Public Member Functions | |
static const Name & | getStrategyName () |
Static Public Member Functions inherited from nfd::fw::Strategy | |
template<typename S > | |
static void | registerType (const Name &strategyName=S::getStrategyName()) |
Register a strategy type. More... | |
static bool | canCreate (const Name &instanceName) |
static unique_ptr< Strategy > | create (const Name &instanceName, Forwarder &forwarder) |
static bool | areSameType (const Name &instanceNameA, const Name &instanceNameB) |
static std::set< Name > | listRegistered () |
static const Name & | getStrategyName () |
Additional Inherited Members | |
Protected Member Functions inherited from nfd::fw::Strategy | |
NFD_VIRTUAL_WITH_TESTS pit::OutRecord * | sendInterest (const Interest &interest, Face &egress, const shared_ptr< pit::Entry > &pitEntry) |
Send an Interest packet. More... | |
NFD_VIRTUAL_WITH_TESTS bool | sendData (const Data &data, Face &egress, const shared_ptr< pit::Entry > &pitEntry) |
Send a Data packet. More... | |
NFD_VIRTUAL_WITH_TESTS void | sendDataToAll (const Data &data, const shared_ptr< pit::Entry > &pitEntry, const Face &inFace) |
Send a Data packet to all matched and qualified faces. More... | |
NFD_VIRTUAL_WITH_TESTS void | rejectPendingInterest (const shared_ptr< pit::Entry > &pitEntry) |
Schedule the PIT entry for immediate deletion. More... | |
NFD_VIRTUAL_WITH_TESTS bool | sendNack (const lp::NackHeader &header, Face &egress, const shared_ptr< pit::Entry > &pitEntry) |
Send a Nack packet. More... | |
void | sendNacks (const lp::NackHeader &header, const shared_ptr< pit::Entry > &pitEntry, std::initializer_list< const Face *> exceptFaces={}) |
Send Nack to every face that has an in-record, except those in exceptFaces . More... | |
void | setExpiryTimer (const shared_ptr< pit::Entry > &pitEntry, time::milliseconds duration) |
Schedule the PIT entry to be erased after duration . More... | |
const fib::Entry & | lookupFib (const pit::Entry &pitEntry) const |
Performs a FIB lookup, considering Link object if present. More... | |
MeasurementsAccessor & | getMeasurements () |
Face * | getFace (FaceId id) const |
const FaceTable & | getFaceTable () const |
void | setInstanceName (const Name &name) |
Set strategy instance name. More... | |
Static Protected Member Functions inherited from nfd::fw::Strategy | |
static ParsedInstanceName | parseInstanceName (const Name &input) |
Parse a strategy instance name. More... | |
static Name | makeInstanceName (const Name &input, const Name &strategyName) |
Construct a strategy instance name. More... | |
Protected Attributes inherited from nfd::fw::Strategy | |
signal::Signal< FaceTable, Face > & | afterAddFace |
signal::Signal< FaceTable, Face > & | beforeRemoveFace |
Access Router strategy.
This strategy is designed for the last hop on the NDN testbed, where each nexthop connects to a laptop, links are lossy, and FIB is mostly correct.
Definition at line 48 of file access-strategy.hpp.
|
explicit |
Definition at line 37 of file access-strategy.cpp.
References getStrategyName(), nfd::fw::Strategy::makeInstanceName(), NDN_THROW, nfd::fw::Strategy::ParsedInstanceName::parameters, nfd::fw::Strategy::parseInstanceName(), nfd::fw::Strategy::setInstanceName(), ndn::to_string(), and nfd::fw::Strategy::ParsedInstanceName::version.
|
static |
Definition at line 53 of file access-strategy.cpp.
References ns3::ndn::Name.
Referenced by AccessStrategy().
|
overridevirtual |
Trigger after an Interest is received.
The Interest:
The PIT entry is set to expire after InterestLifetime has elapsed at each downstream.
The strategy should decide whether and where to forward this Interest.
pitEntry
shared_ptr after this function returns, otherwise undefined behavior may occur. However, the strategy is allowed to construct and keep a weak_ptr to pitEntry
. Implements nfd::fw::Strategy.
Definition at line 60 of file access-strategy.cpp.
References nfd::fw::RetxSuppressionFixed::decidePerPitEntry(), Face, nfd::FaceEndpoint::face, nfd::fw::FORWARD, nfd::fw::Strategy::getFace(), nfd::fib::Entry::getNextHops(), nfd::getScheduler(), nfd::fib::Entry::hasNextHop(), nfd::face::INVALID_FACEID, nfd::fw::Strategy::lookupFib(), nfd::fw::NEW, NFD_LOG_DEBUG, nfd::fw::Strategy::rejectPendingInterest(), nfd::fw::Strategy::sendInterest(), nfd::fw::SUPPRESS, and nfd::fw::wouldViolateScope().
|
overridevirtual |
trigger before PIT entry is satisfied
This trigger is invoked when an incoming Data satisfies more than one PIT entry. The strategy can collect measurements information, but cannot manipulate Data forwarding. When an incoming Data satisfies only one PIT entry, afterReceiveData
is invoked instead and given full control over Data forwarding. If a strategy does not override afterReceiveData
, the default implementation invokes beforeSatisfyInterest
.
Normally, PIT entries would be erased after receiving the first matching Data. If the strategy wishes to collect responses from additional upstream nodes, it should invoke setExpiryTimer
within this function to prolong the PIT entry lifetime. If a Data arrives from another upstream during the extended PIT entry lifetime, this trigger will be invoked again. At that time, this function must invoke setExpiryTimer
again to continue collecting more responses.
In this base class this method does nothing.
Reimplemented from nfd::fw::Strategy.
Definition at line 211 of file access-strategy.cpp.
References ndn::Name::empty(), nfd::measurements::MeasurementsAccessor::extendLifetime(), Face, nfd::FaceEndpoint::face, nfd::measurements::MeasurementsAccessor::findLongestPrefixMatch(), nfd::measurements::MeasurementsAccessor::get(), nfd::fw::Strategy::getMeasurements(), ndn::Data::getName(), ndn::Name::getPrefix(), nfd::StrategyInfoHost::insertStrategyInfo(), ns3::ndn::Name, NFD_LOG_DEBUG, and ndn::time::steady_clock::now().