Also ensure all ranks flush in group/variable encoding

openPMD · Jun 7, 2024 · 0a05f10 · 0a05f10
1 parent d9c54f7
commit 0a05f10
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/src/Series.cpp b/src/Series.cpp
@@ -1403,6 +1403,7 @@ void Series::flushGorVBased(
     bool flushIOHandler)
 {
     auto &series = get();
+
     if (access::readOnly(IOHandler()->m_frontendAccess))
     {
         for (auto it = begin; it != end; ++it)
@@ -1432,6 +1433,8 @@ void Series::flushGorVBased(
             }
 
             // Phase 3
+            Parameter<Operation::TOUCH> touch;
+            IOHandler()->enqueue(IOTask(&writable(), touch));
             if (flushIOHandler)
             {
                 IOHandler()->flush(flushParams);
@@ -1510,6 +1513,8 @@ void Series::flushGorVBased(
         }
 
         flushAttributes(flushParams);
+        Parameter<Operation::TOUCH> touch;
+        IOHandler()->enqueue(IOTask(&writable(), touch));
         if (flushIOHandler)
         {
             IOHandler()->flush(flushParams);