a forwarding strategy that forwards Interest to all FIB nexthops More...
#include <multicast-strategy.hpp>
Public Member Functions | |
MulticastStrategy (Forwarder &forwarder, const Name &name=getStrategyName()) | |
void | afterReceiveInterest (const Face &inFace, const Interest &interest, const shared_ptr< pit::Entry > &pitEntry) override |
trigger after Interest is received More... | |
void | afterReceiveNack (const Face &inFace, 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 |
virtual void | beforeSatisfyInterest (const shared_ptr< pit::Entry > &pitEntry, const Face &inFace, const Data &data) |
trigger before PIT entry is satisfied More... | |
virtual void | afterContentStoreHit (const shared_ptr< pit::Entry > &pitEntry, const Face &inFace, const Data &data) |
trigger after a Data is matched in CS More... | |
virtual void | afterReceiveData (const shared_ptr< pit::Entry > &pitEntry, const Face &inFace, const Data &data) |
trigger after Data is received More... | |
virtual void | onDroppedInterest (const Face &outFace, const Interest &interest) |
trigger after Interest dropped for exceeding allowed retransmissions 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, Face &outFace, const Interest &interest) |
send Interest to outFace More... | |
void | sendData (const shared_ptr< pit::Entry > &pitEntry, const Data &data, const Face &outFace) |
send data to outFace More... | |
void | sendDataToAll (const shared_ptr< pit::Entry > &pitEntry, const Face &inFace, const Data &data) |
send data to all matched and qualified faces 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 Face &outFace, const lp::NackHeader &header) |
send Nack to outFace More... | |
void | sendNacks (const shared_ptr< pit::Entry > &pitEntry, const lp::NackHeader &header, std::initializer_list< const Face * > exceptFaces=std::initializer_list< const Face * >()) |
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... | |
Protected Member Functions inherited from nfd::fw::ProcessNackTraits< MulticastStrategy > | |
ProcessNackTraits (MulticastStrategy *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 |
a forwarding strategy that forwards Interest to all FIB nexthops
Definition at line 38 of file multicast-strategy.hpp.
|
explicit |
Definition at line 40 of file multicast-strategy.cpp.
References getStrategyName(), nfd::fw::Strategy::makeInstanceName(), 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 59 of file multicast-strategy.cpp.
Referenced by MulticastStrategy().
|
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 66 of file multicast-strategy.cpp.
References nfd::fw::RetxSuppressionExponential::decidePerUpstream(), nfd::fw::FORWARD, nfd::face::Face::getId(), nfd::face::Face::getLinkType(), nfd::fib::Entry::getNextHops(), nfd::fw::RetxSuppressionExponential::incrementIntervalForOutRecord(), ndn::nfd::LINK_TYPE_AD_HOC, nfd::fw::Strategy::lookupFib(), NFD_LOG_DEBUG, nfd::fw::Strategy::rejectPendingInterest(), nfd::fw::Strategy::sendInterest(), nfd::fw::Strategy::sendNack(), ndn::lp::NackHeader::setReason(), nfd::fw::SUPPRESS, and nfd::fw::wouldViolateScope().
|
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 115 of file multicast-strategy.cpp.
References nfd::fw::ProcessNackTraitsBase::processNack().