Adaptive SRTT-based Forwarding Strategy. More...
#include <asf-strategy.hpp>
Public Member Functions | |
AsfStrategy (Forwarder &forwarder, const Name &name=getStrategyName()) | |
virtual void | afterReceiveInterest (const Face &inFace, const Interest &interest, const shared_ptr< pit::Entry > &pitEntry) override |
trigger after Interest is received More... | |
virtual void | beforeSatisfyInterest (const shared_ptr< pit::Entry > &pitEntry, const Face &inFace, const Data &data) override |
trigger before PIT entry is satisfied More... | |
virtual 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 | beforeExpirePendingInterest (const shared_ptr< pit::Entry > &pitEntry) |
trigger before PIT entry expires 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 | rejectPendingInterest (const shared_ptr< pit::Entry > &pitEntry) |
decide that a pending Interest cannot be forwarded 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... | |
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 |
Adaptive SRTT-based Forwarding Strategy.
Definition at line 44 of file asf-strategy.hpp.
|
explicit |
Definition at line 41 of file asf-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 61 of file asf-strategy.cpp.
Referenced by AsfStrategy().
|
overridevirtual |
trigger after Interest is received
The Interest:
The strategy should decide whether and where to forward this Interest.
Implements nfd::fw::Strategy.
Definition at line 68 of file asf-strategy.cpp.
References nfd::fw::asf::ProbingModule::afterForwardingProbe(), nfd::fw::RetxSuppressionExponential::decidePerPitEntry(), Face, nfd::fw::FORWARD, nfd::fw::asf::ProbingModule::getFaceToProbe(), nfd::fib::Entry::getNextHops(), nfd::fw::asf::ProbingModule::isProbingNeeded(), nfd::fw::Strategy::lookupFib(), nfd::fw::NEW, NFD_LOG_DEBUG, NFD_LOG_TRACE, nfd::fw::Strategy::rejectPendingInterest(), and nfd::fw::SUPPRESS.
|
overridevirtual |
trigger before PIT entry is satisfied
This trigger is invoked when an incoming Data satisfies the PIT entry. It can be invoked even if the PIT entry has already been satisfied.
In this base class this method does nothing.
Reimplemented from nfd::fw::Strategy.
Definition at line 117 of file asf-strategy.cpp.
References nfd::fw::asf::FaceInfo::cancelTimeoutEvent(), nfd::fw::asf::NamespaceInfo::extendFaceInfoLifetime(), nfd::fw::asf::NamespaceInfo::get(), ndn::Data::getName(), nfd::fw::asf::AsfMeasurements::getNamespaceInfo(), nfd::fw::asf::FaceInfo::isTimeoutScheduled(), NFD_LOG_TRACE, and nfd::fw::asf::FaceInfo::recordRtt().
|
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.
In this base class this method does nothing.
Reimplemented from nfd::fw::Strategy.
Definition at line 143 of file asf-strategy.cpp.
References nfd::fw::asf::FaceInfo::computeRto(), nfd::fw::asf::NamespaceInfo::extendFaceInfoLifetime(), Face, ndn::lp::Nack::getInterest(), ndn::Interest::getName(), ndn::Interest::getNonce(), nfd::fw::asf::AsfMeasurements::getOrCreateFaceInfo(), nfd::fw::asf::AsfMeasurements::getOrCreateNamespaceInfo(), nfd::fib::Entry::getPrefix(), ndn::lp::Nack::getReason(), nfd::fw::asf::FaceInfo::isTimeoutScheduled(), websocketpp::lib::asio::milliseconds(), NFD_LOG_DEBUG, NFD_LOG_TRACE, ndn::Interest::refreshNonce(), nfd::scheduler::schedule(), nfd::fw::Strategy::sendInterest(), nfd::fw::asf::FaceInfo::setTimeoutEvent(), and websocketpp::transport::error::timeout.