33 time::milliseconds(1);
36 time::milliseconds(250);
38 class RetxSuppressionExponential::PitInfo :
public StrategyInfo
48 PitInfo(
const Duration& initialInterval)
49 : suppressionInterval(initialInterval)
63 : m_initialInterval(initialInterval)
64 , m_multiplier(multiplier)
65 , m_maxInterval(maxInterval)
67 BOOST_ASSERT(initialInterval > time::milliseconds::zero());
68 BOOST_ASSERT(multiplier >= 1.0);
69 BOOST_ASSERT(maxInterval >= initialInterval);
81 time::steady_clock::TimePoint lastOutgoing = this->
getLastOutgoing(pitEntry);
82 time::steady_clock::TimePoint now = time::steady_clock::now();
83 time::steady_clock::Duration sinceLastOutgoing = now - lastOutgoing;
86 bool shouldSuppress = sinceLastOutgoing < pi->suppressionInterval;
92 pi->suppressionInterval = std::min(m_maxInterval,
93 time::duration_cast<Duration>(pi->suppressionInterval * m_multiplier));
static const float DEFAULT_MULTIPLIER
Copyright (c) 2014-2016, Regents of the University of California, Arizona Board of Regents...
Interest is retransmission and should be suppressed.
std::pair< T *, bool > insertStrategyInfo(A &&...args)
insert a StrategyInfo item
time::steady_clock::TimePoint getLastOutgoing(const pit::Entry &pitEntry) const
static const Duration DEFAULT_INITIAL_INTERVAL
Copyright (c) 2014-2015, Regents of the University of California, Arizona Board of Regents...
virtual Result decide(const Face &inFace, const Interest &interest, pit::Entry &pitEntry) const override
determines whether Interest is a retransmission, and if so, whether it shall be forwarded or suppress...
RetxSuppressionExponential(const Duration &initialInterval=DEFAULT_INITIAL_INTERVAL, float multiplier=DEFAULT_MULTIPLIER, const Duration &maxInterval=DEFAULT_MAX_INTERVAL)
bool hasPendingOutRecords(const pit::Entry &pitEntry)
determine whether pitEntry has any pending out-records
Interest is retransmission and should be forwarded.
static const Duration DEFAULT_MAX_INTERVAL
Interest is new (not a retransmission)
time::microseconds Duration
time granularity