commit d1f7c7b776a7a5d408af87519a705089d7012c1e
author Alexander Afanasyev <alexander.afanasyev@ucla.edu> Thu Jan 31 13:34:37 2013 -0800
committer Alexander Afanasyev <alexander.afanasyev@ucla.edu> Thu Jan 31 13:41:59 2013 -0800
tree 153b7f755abf72d765da537f1c2745ce60abb8c0
parent fc8425cb4bf4444b62bd90673d3cf08cd534669c

apps: Add more configurability to ndn::ConsumerWindow

By default, it will zero out the window upon timeout

apps/ndn-consumer-window.cc

diff --git a/apps/ndn-consumer-window.cc b/apps/ndn-consumer-window.cc
index 165326b..bc42f67 100644
--- a/apps/ndn-consumer-window.cc
+++ b/apps/ndn-consumer-window.cc
@@ -57,6 +57,11 @@
                    MakeDoubleAccessor (&ConsumerWindow::GetMaxSize, &ConsumerWindow::SetMaxSize),
                    MakeDoubleChecker<double> ())
 
+    .AddAttribute ("InitialWindowOnTimeout", "Set window to initial value when timeout occurs",
+                   BooleanValue (true),
+                   MakeBooleanAccessor (&ConsumerWindow::m_setInitialWindowOnTimeout),
+                   MakeBooleanChecker ())
+
     .AddTraceSource ("WindowTrace",
                      "Window that controls how many outstanding interests are allowed",
                      MakeTraceSourceAccessor (&ConsumerWindow::m_window))
@@ -77,13 +82,14 @@
 void
 ConsumerWindow::SetWindow (uint32_t window)
 {
-  m_window = window;
+  m_initialWindow = window;
+  m_window = m_initialWindow;
 }
 
 uint32_t
 ConsumerWindow::GetWindow () const
 {
-  return m_window;
+  return m_initialWindow;
 }
 
 uint32_t
@@ -130,9 +136,9 @@
     {
       if (!m_sendEvent.IsRunning ())
         {
-          m_sendEvent = Simulator::Schedule (Seconds (m_rtt->RetransmitTimeout ().ToDouble (Time::S)),
+          m_sendEvent = Simulator::Schedule (Seconds (m_rtt->RetransmitTimeout ().ToDouble (Time::S) * 0.1),
                                              &Consumer::SendPacket, this);
-          m_rtt->IncreaseMultiplier ();
+          // m_rtt->IncreaseMultiplier ();
         }
     }
   else if (m_inFlight >= m_window)
@@ -189,10 +195,13 @@
 void
 ConsumerWindow::OnTimeout (uint32_t sequenceNumber)
 {
-  // NS_FATAL_ERROR ("No timeouts should happen: " << sequenceNumber);
   if (m_inFlight > static_cast<uint32_t> (0)) m_inFlight--;
-  // m_window = std::max<uint32_t> (0, m_window - 1);
-  m_window = 0;
+
+  if (m_setInitialWindowOnTimeout)
+    {
+      // m_window = std::max<uint32_t> (0, m_window - 1);
+      m_window = m_initialWindow;
+    }
   Consumer::OnTimeout (sequenceNumber);
 }