commit e1b2a2d990dea82b03226be014ded4c66e16be08
author Alexander Afanasyev <alexander.afanasyev@ucla.edu> Fri Nov 16 11:53:42 2012 -0800
committer Alexander Afanasyev <alexander.afanasyev@ucla.edu> Fri Nov 16 11:53:42 2012 -0800
tree fb3fb4e06cc5bf82e1a862289eca7ce266fe256c
parent 042b4a766e4171e3e23ec8c4851484702c8c6116

apps: Correcting behavior of ndn::ConsumerWindow.

It was erroneously suppressing transmission of new packets

apps/ndn-consumer-window.cc

diff --git a/apps/ndn-consumer-window.cc b/apps/ndn-consumer-window.cc
index 86457c8..4ae30dd 100644
--- a/apps/ndn-consumer-window.cc
+++ b/apps/ndn-consumer-window.cc
@@ -129,13 +129,19 @@
   if (m_window == static_cast<uint32_t> (0) || m_inFlight >= m_window)
     {
       if (!m_sendEvent.IsRunning ())
-        m_sendEvent = Simulator::Schedule (Seconds (m_rtt->RetransmitTimeout ().ToDouble (Time::S) * 0.1), &Consumer::SendPacket, this);
-      return;
+        {
+          m_sendEvent = Simulator::Schedule (Seconds (m_rtt->RetransmitTimeout ().ToDouble (Time::S) * 0.1),
+                                             &Consumer::SendPacket, this);
+        }
     }
-  
-  // std::cout << "Window: " << m_window << ", InFlight: " << m_inFlight << "\n";
-  if (!m_sendEvent.IsRunning ())
+  else
     {
+      if (m_sendEvent.IsRunning ())
+        {
+          Simulator::Remove (m_sendEvent);
+        }
+
+      NS_LOG_DEBUG ("Window: " << m_window << ", InFlight: " << m_inFlight);
       m_inFlight++;
       m_sendEvent = Simulator::ScheduleNow (&Consumer::SendPacket, this);
     }
@@ -154,6 +160,8 @@
   m_window = m_window + 1;
 
   if (m_inFlight > static_cast<uint32_t> (0)) m_inFlight--;
+  NS_LOG_DEBUG ("Window: " << m_window << ", InFlight: " << m_inFlight);
+
   ScheduleNextPacket ();
 }
 
@@ -161,6 +169,7 @@
 ConsumerWindow::OnNack (const Ptr<const InterestHeader> &interest, Ptr<Packet> payload)
 {
   Consumer::OnNack (interest, payload);
+  
   if (m_inFlight > static_cast<uint32_t> (0)) m_inFlight--;
 
   if (m_window > static_cast<uint32_t> (0))
@@ -168,6 +177,8 @@
       // m_window = 0.5 * m_window;//m_window - 1;
       m_window = m_window - 1;
     }
+  
+  // NS_LOG_DEBUG ("Window: " << m_window);
 }
 
 void