commit 041be4f75f401e6e6d94b2c039d89143e88d6edd
author Alexander Afanasyev <aa@cs.fiu.edu> Thu Nov 19 18:35:45 2020 -0500
committer Alexander Afanasyev <aa@cs.fiu.edu> Thu May 05 11:04:16 2022 -0400
tree 7a9d16bcd7c6bb3ce4cbd5c57655a34ee5918a12
parent 0e97f173cd2e37695eb155a7580f10323c63075b

[experimental] Allow strategy to expire PIT entry

This somewhat duplicates logic in the Forwarder, but may be needed in
certain cases.

Change-Id: I05bceb86024579153d72bf0e41ca48e89790a209

daemon/fw/strategy.cpp

diff --git a/daemon/fw/strategy.cpp b/daemon/fw/strategy.cpp
index 7cf73ad..27ca68c 100644
--- a/daemon/fw/strategy.cpp
+++ b/daemon/fw/strategy.cpp
@@ -272,7 +272,15 @@
     data2.setTag(pitToken);
     return m_forwarder.onOutgoingData(data2, egress);
   }
-  return m_forwarder.onOutgoingData(data, egress);
+  m_forwarder.onOutgoingData(data, egress);
+
+  if (pitEntry->getInRecords().empty()) { // if nothing left, "closing down" the entry
+    // set PIT expiry timer to now
+    m_forwarder.setExpiryTimer(pitEntry, 0_ms);
+
+    // mark PIT satisfied
+    pitEntry->isSatisfied = true;
+  }
 }
 
 void
@@ -295,6 +303,14 @@
   for (const auto& pendingDownstream : pendingDownstreams) {
     this->sendData(data, *pendingDownstream, pitEntry);
   }
+
+  pitEntry->clearInRecords();
+
+  // set PIT expiry timer to now
+  m_forwarder.setExpiryTimer(pitEntry, 0_ms);
+
+  // mark PIT satisfied
+  pitEntry->isSatisfied = true;
 }
 
 void