a forwarding strategy similar to CCNx 0.7.2 More...
#include <ncc-strategy.hpp>
Classes | |
class | MeasurementsEntryInfo |
StrategyInfo on measurements::Entry. More... | |
class | PitEntryInfo |
StrategyInfo on pit::Entry. More... | |
Public Member Functions | |
NccStrategy (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... | |
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... | |
virtual void | afterReceiveNack (const Face &inFace, const lp::Nack &nack, const shared_ptr< pit::Entry > &pitEntry) |
trigger after Nack is received 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 () |
Protected Member Functions | |
MeasurementsEntryInfo & | getMeasurementsEntryInfo (measurements::Entry *entry) |
MeasurementsEntryInfo & | getMeasurementsEntryInfo (const shared_ptr< pit::Entry > &entry) |
void | doPropagate (FaceId inFaceId, weak_ptr< pit::Entry > pitEntryWeak) |
propagate to another upstream More... | |
void | timeoutOnBestFace (weak_ptr< pit::Entry > pitEntryWeak) |
best face did not reply within prediction More... | |
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 Attributes | |
static const time::microseconds | DEFER_FIRST_WITHOUT_BEST_FACE = time::microseconds(4000) |
static const time::microseconds | DEFER_RANGE_WITHOUT_BEST_FACE = time::microseconds(75000) |
static const int | UPDATE_MEASUREMENTS_N_LEVELS = 2 |
static const time::nanoseconds | MEASUREMENTS_LIFETIME = time::seconds(16) |
Additional Inherited Members | |
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 similar to CCNx 0.7.2
Definition at line 36 of file ncc-strategy.hpp.
|
explicit |
Definition at line 39 of file ncc-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 54 of file ncc-strategy.cpp.
Referenced by NccStrategy().
|
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 61 of file ncc-strategy.cpp.
References nfd::fw::NccStrategy::PitEntryInfo::bestFaceTimeout, nfd::fw::canForwardToLegacy(), DEFER_FIRST_WITHOUT_BEST_FACE, DEFER_RANGE_WITHOUT_BEST_FACE, doPropagate(), Face, nfd::fw::NccStrategy::MeasurementsEntryInfo::getBestFace(), getMeasurementsEntryInfo(), nfd::fib::Entry::getNextHops(), nfd::fib::Entry::hasNextHop(), nfd::fw::hasPendingOutRecords(), nfd::fw::Strategy::lookupFib(), nfd::fw::NccStrategy::PitEntryInfo::maxInterval, nfd::fw::NccStrategy::MeasurementsEntryInfo::prediction, nfd::fw::NccStrategy::MeasurementsEntryInfo::previousFace, nfd::fw::NccStrategy::PitEntryInfo::propagateTimer, nfd::fw::Strategy::rejectPendingInterest(), nfd::scheduler::schedule(), nfd::fw::Strategy::sendInterest(), timeoutOnBestFace(), and nfd::fw::wouldViolateScope().
|
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 210 of file ncc-strategy.cpp.
References nfd::fw::NccStrategy::PitEntryInfo::bestFaceTimeout, nfd::scheduler::cancel(), nfd::fw::NccStrategy::MeasurementsEntryInfo::getBestFace(), nfd::fw::Strategy::getMeasurements(), getMeasurementsEntryInfo(), MEASUREMENTS_LIFETIME, nfd::fw::NccStrategy::PitEntryInfo::propagateTimer, UPDATE_MEASUREMENTS_N_LEVELS, and nfd::fw::NccStrategy::MeasurementsEntryInfo::updateBestFace().
|
protected |
Definition at line 255 of file ncc-strategy.cpp.
References nfd::fw::Strategy::getMeasurements(), nfd::fw::NccStrategy::MeasurementsEntryInfo::inheritFrom(), nfd::fw::NccStrategy::MeasurementsEntryInfo::INITIAL_PREDICTION, nfd::StrategyInfoHost::insertStrategyInfo(), nfd::fw::NccStrategy::MeasurementsEntryInfo::MAX_PREDICTION, websocketpp::lib::asio::milliseconds(), and nfd::fw::NccStrategy::MeasurementsEntryInfo::MIN_PREDICTION.
Referenced by afterReceiveInterest(), beforeSatisfyInterest(), doPropagate(), getMeasurementsEntryInfo(), and timeoutOnBestFace().
|
protected |
Definition at line 248 of file ncc-strategy.cpp.
References nfd::fw::Strategy::getMeasurements(), and getMeasurementsEntryInfo().
|
protected |
propagate to another upstream
Definition at line 135 of file ncc-strategy.cpp.
References nfd::fw::canForwardToLegacy(), Face, nfd::fw::Strategy::getFace(), nfd::getGlobalRng(), getMeasurementsEntryInfo(), nfd::fib::Entry::getNextHops(), nfd::fib::Entry::hasNextHop(), nfd::fw::Strategy::lookupFib(), nfd::fw::NccStrategy::PitEntryInfo::maxInterval, nfd::fw::NccStrategy::MeasurementsEntryInfo::previousFace, nfd::fw::NccStrategy::PitEntryInfo::propagateTimer, nfd::scheduler::schedule(), nfd::fw::Strategy::sendInterest(), and nfd::fw::wouldViolateScope().
Referenced by afterReceiveInterest().
|
protected |
best face did not reply within prediction
Definition at line 187 of file ncc-strategy.cpp.
References nfd::fw::NccStrategy::MeasurementsEntryInfo::adjustPredictUp(), nfd::fw::Strategy::getMeasurements(), getMeasurementsEntryInfo(), MEASUREMENTS_LIFETIME, and UPDATE_MEASUREMENTS_N_LEVELS.
Referenced by afterReceiveInterest().
|
staticprotected |
Definition at line 135 of file ncc-strategy.hpp.
Referenced by afterReceiveInterest().
|
staticprotected |
Definition at line 136 of file ncc-strategy.hpp.
Referenced by afterReceiveInterest().
|
staticprotected |
Definition at line 137 of file ncc-strategy.hpp.
Referenced by beforeSatisfyInterest(), and timeoutOnBestFace().
|
staticprotected |
Definition at line 138 of file ncc-strategy.hpp.
Referenced by beforeSatisfyInterest(), and timeoutOnBestFace().