Best Route strategy version 4. More...
#include <best-route-strategy2.hpp>
Public Member Functions | |
BestRouteStrategy2 (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 | afterReceiveNack (const FaceEndpoint &ingress, const lp::Nack &nack, const shared_ptr< pit::Entry > &pitEntry) override |
trigger after Nack is received 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 | beforeSatisfyInterest (const shared_ptr< pit::Entry > &pitEntry, const FaceEndpoint &ingress, const Data &data) |
trigger before PIT entry is satisfied 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 | 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... | |
Protected Member Functions inherited from nfd::fw::ProcessNackTraits< BestRouteStrategy2 > | |
ProcessNackTraits (BestRouteStrategy2 *strategy) | |
Protected Member Functions inherited from nfd::fw::ProcessNackTraitsBase | |
virtual | ~ProcessNackTraitsBase ()=default |
void | processNack (const Face &inFace, const lp::Nack &nack, const shared_ptr< pit::Entry > &pitEntry) |
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 |
Best Route strategy version 4.
This strategy forwards a new Interest to the lowest-cost nexthop (except downstream). After that, if consumer retransmits the Interest (and is not suppressed according to exponential backoff algorithm), the strategy forwards the Interest again to the lowest-cost nexthop (except downstream) that is not previously used. If all nexthops have been used, the strategy starts over with the first nexthop.
This strategy returns Nack to all downstreams with reason NoRoute if there is no usable nexthop, which may be caused by: (a) the FIB entry contains no nexthop; (b) the FIB nexthop happens to be the sole downstream; (c) the FIB nexthops violate scope.
This strategy returns Nack to all downstreams if all upstreams have returned Nacks. The reason of the sent Nack equals the least severe reason among received Nacks.
Definition at line 55 of file best-route-strategy2.hpp.
|
explicit |
Definition at line 39 of file best-route-strategy2.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 58 of file best-route-strategy2.cpp.
Referenced by BestRouteStrategy2(), and nfd::getDefaultStrategyName().
|
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 65 of file best-route-strategy2.cpp.
References nfd::fw::RetxSuppressionExponential::decidePerPitEntry(), nfd::FaceEndpoint::face, nfd::fw::findEligibleNextHopWithEarliestOutRecord(), nfd::fib::Entry::getNextHops(), nfd::fw::Strategy::lookupFib(), nfd::fw::NEW, NFD_LOG_DEBUG, nfd::fw::Strategy::rejectPendingInterest(), nfd::fw::Strategy::sendInterest(), nfd::fw::Strategy::sendNack(), ndn::lp::NackHeader::setReason(), and nfd::fw::SUPPRESS.
|
overridevirtual |
trigger after Nack is received
This trigger is invoked when an incoming Nack is received in response to an forwarded Interest. The Nack has been confirmed to be a response to the last Interest forwarded to that upstream, i.e. the PIT out-record exists and has a matching Nonce. The NackHeader has been recorded in the PIT out-record.
If the PIT entry is not yet satisfied, its expiry timer remains unchanged. Otherwise, the PIT entry normally would expire immediately after this function returns.
If the strategy wishes to collect responses from additional upstream nodes, it should invoke setExpiryTimer
within this function to retain the PIT entry. If a Nack 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 the base class this method does nothing.
Reimplemented from nfd::fw::Strategy.
Definition at line 126 of file best-route-strategy2.cpp.
References nfd::FaceEndpoint::face, and nfd::fw::ProcessNackTraitsBase::processNack().