Access Router Strategy version 1. More...
#include <access-strategy.hpp>
Public Member Functions | |
AccessStrategy (Forwarder &forwarder, const Name &name=getStrategyName()) | |
void | afterReceiveInterest (const FaceEndpoint &ingress, const Interest &interest, const shared_ptr< pit::Entry > &pitEntry) override |
trigger after Interest is received More... | |
void | beforeSatisfyInterest (const shared_ptr< pit::Entry > &pitEntry, const FaceEndpoint &ingress, const Data &data) 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 |
bool | wantNewNextHopTrigger () const |
virtual void | afterReceiveLoopedInterest (const FaceEndpoint &ingress, const Interest &interest, pit::Entry &pitEntry) |
trigger after a looped Interest is received More... | |
virtual void | afterContentStoreHit (const shared_ptr< pit::Entry > &pitEntry, const FaceEndpoint &ingress, const Data &data) |
trigger after a Data is matched in CS More... | |
virtual void | afterReceiveData (const shared_ptr< pit::Entry > &pitEntry, const FaceEndpoint &ingress, const Data &data) |
trigger after Data is received More... | |
virtual void | afterReceiveNack (const FaceEndpoint &ingress, const lp::Nack &nack, const shared_ptr< pit::Entry > &pitEntry) |
trigger after Nack is received More... | |
virtual void | onDroppedInterest (const FaceEndpoint &egress, const Interest &interest) |
trigger after Interest dropped for exceeding allowed retransmissions More... | |
virtual void | afterNewNextHop (const fib::NextHop &nextHop, const shared_ptr< pit::Entry > &pitEntry) |
trigger after 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 | |
void | sendInterest (const shared_ptr< pit::Entry > &pitEntry, const FaceEndpoint &egress, const Interest &interest) |
send Interest to egress More... | |
void | sendData (const shared_ptr< pit::Entry > &pitEntry, const Data &data, const FaceEndpoint &egress) |
send data to egress More... | |
void | sendDataToAll (const shared_ptr< pit::Entry > &pitEntry, const FaceEndpoint &ingress, const Data &data) |
send data to all matched and qualified face-endpoint pairs More... | |
void | rejectPendingInterest (const shared_ptr< pit::Entry > &pitEntry) |
schedule the PIT entry for immediate deletion More... | |
void | sendNack (const shared_ptr< pit::Entry > &pitEntry, const FaceEndpoint &egress, const lp::NackHeader &header) |
send Nack to egress More... | |
void | sendNacks (const shared_ptr< pit::Entry > &pitEntry, const lp::NackHeader &header, std::initializer_list< FaceEndpoint > exceptFaceEndpoints={}) |
send Nack to every face-endpoint pair that has an in-record, except those in exceptFaceEndpoints 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... | |
void | enableNewNextHopTrigger (bool enabled) |
set whether the afterNewNextHop trigger should be invoked for this strategy 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 version 1.
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 50 of file access-strategy.hpp.
|
explicit |
Definition at line 37 of file access-strategy.cpp.
|
static |
Definition at line 53 of file access-strategy.cpp.
|
overridevirtual |
trigger after 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.
sendInterest
for each upstream, either now or shortly after via a scheduler event, but before PIT entry expires. Optionally, the strategy can invoke setExpiryTimer
to adjust how long it would wait for a response.setExpiryTimer
to adjust how long it would wait for a response.rejectPendingInterest
to erase the PIT entry.Implements nfd::fw::Strategy.
Definition at line 60 of file access-strategy.cpp.
References nfd::fw::RetxSuppressionFixed::decidePerPitEntry(), nfd::fw::FORWARD, nfd::fw::NEW, NFD_LOG_DEBUG, and nfd::fw::SUPPRESS.
|
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 209 of file access-strategy.cpp.
References nfd::FaceEndpoint::face, NFD_LOG_DEBUG, and ndn::time::steady_clock::now().