retx-suppression-fixed.cpp

Go to the documentation of this file.

/* -*- Mode:C++; c-file-style:"gnu"; indent-tabs-mode:nil; -*- */
#include "retx-suppression-fixed.hpp"
#include "algorithm.hpp"

namespace nfd {
namespace fw {

const time::milliseconds RetxSuppressionFixed::DEFAULT_MIN_RETX_INTERVAL(100);

RetxSuppressionFixed::RetxSuppressionFixed(const time::milliseconds& minRetxInterval)
  : m_minRetxInterval(minRetxInterval)
{
  BOOST_ASSERT(minRetxInterval > time::milliseconds::zero());
}

RetxSuppression::Result
RetxSuppressionFixed::decide(const Face& inFace, const Interest& interest,
                             pit::Entry& pitEntry) const
{
  bool isNewPitEntry = !hasPendingOutRecords(pitEntry);
  if (isNewPitEntry) {
    return NEW;
  }

  time::steady_clock::TimePoint lastOutgoing = this->getLastOutgoing(pitEntry);
  time::steady_clock::TimePoint now = time::steady_clock::now();
  time::steady_clock::Duration sinceLastOutgoing = now - lastOutgoing;
  bool shouldSuppress = sinceLastOutgoing < m_minRetxInterval;
  return shouldSuppress ? SUPPRESS : FORWARD;
}

} // namespace fw
} // namespace nfd