Changeset 639 for XIOS/trunk/src/filter/store_filter.cpp

Timestamp:

07/17/15 13:58:12 (9 years ago)

Author:

rlacroix

Message:

Add a basic garbage collector to ensure no packets linger in the filter graph.

File:

• XIOS/trunk/src/filter/store_filter.cpp (modified) (2 diffs)

XIOS/trunk/src/filter/store_filter.cpp

@@ -6 +6 @@
 namespace xios
 {
-  CStoreFilter::CStoreFilter(CContext* context, CGrid* grid)
-    : CInputPin(1)
+  CStoreFilter::CStoreFilter(CGarbageCollector& gc, CContext* context, CGrid* grid)
+    : CInputPin(gc, 1)
     , context(context)
     , grid(grid)
@@ -63 +63 @@
   {
     packets.insert(std::make_pair(data[0]->timestamp, data[0]));
+    // The packet is always destroyed by the garbage collector
+    // so we register but never unregister
+    gc.registerFilter(this, data[0]->timestamp);
+  }
+
+  void CStoreFilter::invalidate(Time timestamp)
+  {
+    CInputPin::invalidate(timestamp);
+    packets.erase(packets.begin(), packets.lower_bound(timestamp));
   }
 } // namespace xios