36 const double RttStats::ALPHA = 0.125;
39 : m_srtt(RTT_NO_MEASUREMENT)
40 , m_rtt(RTT_NO_MEASUREMENT)
51 m_srtt = computeSrtt(m_srtt, m_rtt);
55 RttStats::computeSrtt(
Rtt previousSrtt,
Rtt currentRtt)
61 return Rtt(ALPHA * currentRtt + (1 - ALPHA) * previousSrtt);
68 : m_isTimeoutScheduled(false)
69 , m_nSilentTimeouts(0)
82 if (!m_isTimeoutScheduled) {
83 m_timeoutEventId = id;
84 m_isTimeoutScheduled =
true;
85 m_lastInterestName = interestName;
88 BOOST_THROW_EXCEPTION(
FaceInfo::Error(
"Tried to schedule a timeout for a face that already has a timeout scheduled."));
93 FaceInfo::cancelTimeoutEvent()
96 m_isTimeoutScheduled =
false;
100 FaceInfo::cancelTimeoutEvent(
const Name& prefix)
108 FaceInfo::doesNameMatchLastInterest(
const Name& name)
110 return m_lastInterestName.isPrefixOf(name);
117 pit::OutRecordCollection::const_iterator outRecord = pitEntry->getOutRecord(inFace);
119 if (outRecord == pitEntry->out_end()) {
120 NFD_LOG_TRACE(pitEntry->getInterest() <<
" dataFrom inFace=" << inFace.getId() <<
" no-out-record");
124 time::steady_clock::Duration steadyRtt = time::steady_clock::now() - outRecord->getLastRenewed();
130 <<
" RTT: " << m_rttStats.
getRtt()
131 <<
" SRTT: " << m_rttStats.
getSrtt());
145 : m_isProbingDue(false)
146 , m_hasFirstProbeBeenScheduled(false)
155 if (it != m_fit.end()) {
170 if (it == m_fit.end()) {
171 const auto& pair = m_fit.emplace(faceId,
FaceInfo());
172 info = &pair.first->second;
206 : m_measurements(measurements)
237 BOOST_ASSERT(info !=
nullptr);
248 for (
size_t prefixLen = fibEntry.
getPrefix().size() + 1;
249 me ==
nullptr && prefixLen <= interest.
getName().size(); ++prefixLen) {
250 me = m_measurements.get(interest.getName().getPrefix(prefixLen));
254 BOOST_ASSERT(me !=
nullptr);
260 BOOST_ASSERT(info !=
nullptr);
FaceInfo * getFaceInfo(const fib::Entry &fibEntry, const Interest &interest, FaceId faceId)
const Name & getName() const
void extendFaceInfoLifetime(FaceInfo &info, FaceId faceId)
represents a Measurements entry
NamespaceInfo * getNamespaceInfo(const Name &prefix)
void addRttMeasurement(RttEstimator::Duration &durationRtt)
FaceInfo & getOrCreateFaceInfo(const fib::Entry &fibEntry, const Interest &interest, FaceId faceId)
time::duration< double, boost::micro > Rtt
std::pair< T *, bool > insertStrategyInfo(A &&...args)
insert a StrategyInfo item
time::microseconds Duration
Table::const_iterator iterator
void cancelTimeoutEvent(const Name &prefix)
FaceInfo & getOrCreateFaceInfo(const fib::Entry &fibEntry, FaceId faceId)
void expireFaceInfo(FaceId faceId)
void cancel(EventId eventId)
Cancel a scheduled event.
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)
const scheduler::EventId & getMeasurementExpirationEventId()
bool isTimeoutScheduled() const
void recordRtt(const shared_ptr< pit::Entry > &pitEntry, const Face &inFace)
stores stategy information about each face in this namespace
void recordTimeout(const Name &interestName)
FaceInfo * getFaceInfo(const fib::Entry &fibEntry, FaceId faceId)
void setTimeoutEvent(const scheduler::EventId &id, const Name &interestName)
#define NFD_LOG_INIT(name)
static const Rtt RTT_TIMEOUT
EventId schedule(time::nanoseconds after, const EventCallback &event)
Schedule an event.
uint64_t FaceId
identifies a face
AsfMeasurements(MeasurementsAccessor &measurements)
void setMeasurementExpirationEventId(const scheduler::EventId &id)
void addMeasurement(Duration measure)
Strategy information for each face in a namespace.
Helper class to retrieve and create strategy measurements.
static const Rtt RTT_NO_MEASUREMENT