Fix flushing logic

Author: franzpoeschel

include/openPMD/RecordComponent.tpp

@@ -134,7 +134,7 @@ RecordComponent::storeChunk(Offset o, Extent e, F &&createBuffer)
             dCreate.name = Attributable::get().m_writable.ownKeyWithinParent;
             IOHandler()->enqueue(IOTask(this, dCreate));
 
-            setWritten(true, EnqueueAsynchronously::Yes);
+            setWritten(true, EnqueueAsynchronously::OnlyAsync);
         }
 
         IOHandler()->enqueue(IOTask(this, getBufferView));

include/openPMD/backend/Attributable.hpp

@@ -589,9 +589,10 @@ OPENPMD_protected
     {
         return writable().written;
     }
-    enum class EnqueueAsynchronously : bool
+    enum class EnqueueAsynchronously : uint8_t
     {
-        Yes,
+        OnlyAsync,
+        Both,
         No
     };
     /*

src/Iteration.cpp

@@ -256,7 +256,7 @@ void Iteration::flushFileBased(
          * If it was written before, then in the context of another iteration.
          */
         auto &attr = s.get().m_rankTable.m_attributable;
-        attr.setWritten(false, Attributable::EnqueueAsynchronously::Yes);
+        attr.setWritten(false, Attributable::EnqueueAsynchronously::Both);
         s.get()
             .m_rankTable.m_attributable.get()
             .m_writable.abstractFilePosition.reset();
@@ -853,7 +853,7 @@ auto Iteration::beginStep(
     {
         bool previous = series.iterations.written();
         series.iterations.setWritten(
-            false, Attributable::EnqueueAsynchronously::Yes);
+            false, Attributable::EnqueueAsynchronously::Both);
         auto oldStatus = IOHandl->m_seriesStatus;
         IOHandl->m_seriesStatus = internal::SeriesStatus::Parsing;
         try
@@ -870,7 +870,7 @@ auto Iteration::beginStep(
         }
         IOHandl->m_seriesStatus = oldStatus;
         series.iterations.setWritten(
-            previous, Attributable::EnqueueAsynchronously::Yes);
+            previous, Attributable::EnqueueAsynchronously::Both);
     }
     else if (thisObject.has_value())
     {

src/Series.cpp

@@ -1503,9 +1503,9 @@ void Series::flushFileBased(
                  * current iteration by the backend)
                  */
                 this->setWritten(
-                    false, Attributable::EnqueueAsynchronously::Yes);
+                    false, Attributable::EnqueueAsynchronously::Both);
                 series.iterations.setWritten(
-                    false, Attributable::EnqueueAsynchronously::Yes);
+                    false, Attributable::EnqueueAsynchronously::Both);
 
                 setDirty(dirty() || it->second.dirty());
                 std::string filename = iterationFilename(it->first);
@@ -1996,7 +1996,7 @@ void Series::readOneIterationFileBased(std::string const &filePath)
         setWritten(false, Attributable::EnqueueAsynchronously::No);
         setIterationEncoding_internal(
             encoding_out, internal::default_or_explicit::explicit_);
-        setWritten(old_written, Attributable::EnqueueAsynchronously::Yes);
+        setWritten(old_written, Attributable::EnqueueAsynchronously::Both);
     }
     else
         throw std::runtime_error(

src/backend/Attributable.cpp

@@ -524,12 +524,18 @@ void Attributable::setWritten(bool val, EnqueueAsynchronously ea)
     switch (ea)
     {
 
-    case EnqueueAsynchronously::Yes: {
+    case EnqueueAsynchronously::OnlyAsync: {
         Parameter<Operation::SET_WRITTEN> param;
         param.target_status = val;
         IOHandler()->enqueue(IOTask(this, param));
+        return;
+    }
+    case EnqueueAsynchronously::Both: {
+        Parameter<Operation::SET_WRITTEN> param;
+        param.target_status = val;
+        IOHandler()->enqueue(IOTask(this, param));
+        break;
     }
-    break;
     case EnqueueAsynchronously::No:
         break;
     }