38 "ProbingModule::DEFAULT_PROBING_INTERVAL must be less than AsfMeasurements::MEASUREMENTS_LIFETIME");
41 : m_probingInterval(DEFAULT_PROBING_INTERVAL)
42 , m_measurements(measurements)
55 if (info ==
nullptr) {
68 const Interest& interest,
72 FaceInfoFacePairSet rankedFaces(
73 [] (FaceInfoFacePair pairLhs, FaceInfoFacePair pairRhs) ->
bool {
86 Face& hopFace = hop.getFace();
90 if (hopFace.getId() == inFace.getId() || hopFace.getId() == faceUsed.getId() ||
103 rankedFaces.insert(std::make_pair(info, &hopFace));
106 if (rankedFaces.empty()) {
111 return getFaceBasedOnProbability(rankedFaces);
123 uint64_t interval = getRandomNumber(0, 5000);
144 ProbingModule::getFaceBasedOnProbability(
const FaceInfoFacePairSet& rankedFaces)
146 double randomNumber = getRandomNumber(0, 1);
147 uint64_t rankSum = ((rankedFaces.size() + 1) * rankedFaces.size()) / 2;
152 for (
const FaceInfoFacePair pair : rankedFaces) {
153 double probability = getProbingProbability(rank++, rankSum, rankedFaces.size());
164 if (randomNumber <= offset + probability) {
169 offset += probability;
178 ProbingModule::getProbingProbability(uint64_t rank, uint64_t rankSum, uint64_t nFaces)
183 return static_cast<double>(nFaces + 1 - rank) / rankSum;
187 ProbingModule::getRandomNumber(
double start,
double end)
189 std::uniform_real_distribution<double> dist(start, end);
197 m_probingInterval = time::milliseconds(probingInterval);
200 BOOST_THROW_EXCEPTION(std::invalid_argument(
"Probing interval should be >= " FaceInfo * getFaceInfo(const fib::Entry &fibEntry, const Interest &interest, FaceId faceId)
void scheduleProbe(const fib::Entry &fibEntry, const time::milliseconds &interval)
void afterForwardingProbe(const fib::Entry &fibEntry, const Interest &interest)
bool hasSrttMeasurement() const
ProbingModule(AsfMeasurements &measurements)
NamespaceInfo * getNamespaceInfo(const Name &prefix)
RttStats::Rtt getSrtt() const
static constexpr time::milliseconds DEFAULT_PROBING_INTERVAL
void setIsProbingDue(bool isProbingDue)
const Name & getPrefix() const
static constexpr time::microseconds MEASUREMENTS_LIFETIME
Copyright (c) 2014-2015, Regents of the University of California, Arizona Board of Regents...
NamespaceInfo & getOrCreateNamespaceInfo(const fib::Entry &fibEntry, const Interest &interest)
void setHasFirstProbeBeenScheduled(bool hasBeenScheduled)
bool isProbingNeeded(const fib::Entry &fibEntry, const Interest &interest)
std::mt19937 & getGlobalRng()
stores stategy information about each face in this namespace
This file contains common algorithms used by forwarding strategies.
static constexpr time::milliseconds MIN_PROBING_INTERVAL
Declares the global pseudorandom number generator (PRNG) for NFD.
EventId schedule(time::nanoseconds after, const EventCallback &event)
schedule an event
void setProbingInterval(size_t probingInterval)
bool isFirstProbeScheduled() const
Face * getFaceToProbe(const Face &inFace, const Interest &interest, const fib::Entry &fibEntry, const Face &faceUsed)
represents a nexthop record in FIB entry
bool wouldViolateScope(const Face &inFace, const Interest &interest, const Face &outFace)
determine whether forwarding the Interest in pitEntry to outFace would violate scope ...
const NextHopList & getNextHops() const
Strategy information for each face in a namespace.
Helper class to retrieve and create strategy measurements.
bool isProbingDue() const