wip: debugging state

Author: franzpoeschel

src/RecordComponent.cpp

@@ -238,15 +238,15 @@ namespace
 RecordComponent &RecordComponent::resetDataset(Dataset d)
 {
     auto &rc = get();
-    auto cleanup = defer([&rc, this]() {
-        if (rc.m_dataset.has_value() &&
-            rc.m_dataset->dtype != Datatype::UNDEFINED &&
-            IOHandler()->m_seriesStatus != internal::SeriesStatus::Parsing)
-        {
-            seriesFlush_impl</* flush_entire_series = */ false>(
-                {FlushLevel::SkeletonOnly}, /* flush_io_handler = */ true);
-        }
-    });
+    // auto cleanup = defer([&rc, this]() {
+    //     if (rc.m_dataset.has_value() &&
+    //         rc.m_dataset->dtype != Datatype::UNDEFINED &&
+    //         IOHandler()->m_seriesStatus != internal::SeriesStatus::Parsing)
+    //     {
+    //         seriesFlush_impl</* flush_entire_series = */ false>(
+    //             {FlushLevel::SkeletonOnly}, /* flush_io_handler = */ true);
+    //     }
+    // });
     if (written())
     {
         if (!rc.m_dataset.has_value())

src/auxiliary/Mpi.cpp

@@ -94,6 +94,8 @@ std::vector<std::string> distributeStringsToAllRanks(
     int *sizesBuffer = new int[size];
     int *displs = new int[size];
 
+    MPI_Barrier(communicator);
+
     MPI_Allgather(
         &sendLength, 1, MPI_INT, sizesBuffer, 1, MPI_INT, communicator);
 

test/CatchRunner.cpp

@@ -29,8 +29,9 @@ int main(int argc, char *argv[])
 
     Catch::Session session;
     // session.configData().runOrder = Catch::TestRunOrder::Declared;
-    MPI_Bcast(
-        &session.configData().rngSeed, 1, MPI_UINT32_T, 0, MPI_COMM_WORLD);
+    session.configData().rngSeed = 3036063643;
+    // MPI_Bcast(
+    //     &session.configData().rngSeed, 1, MPI_UINT32_T, 0, MPI_COMM_WORLD);
     int result = session.applyCommandLine(argc, argv);
     if (result == 0)
     {

test/ParallelIOTest.cpp

@@ -2559,10 +2559,13 @@ void run_test()
         E_x.storeChunk(data, {unsigned(mpi_rank * 2), 0}, {1, 10});
         E_x.storeChunk(data, {unsigned(mpi_rank * 2 + 1), 0}, {1, 10});
         series.flush();
+        series.close();
     }
+    MPI_Barrier(MPI_COMM_WORLD);
 
     {
-        Series series(filename, openPMD::Access::READ_ONLY, MPI_COMM_WORLD);
+        Series series(
+            filename, openPMD::Access::READ_ONLY /* , MPI_COMM_WORLD */);
         /*
          * Inquire the writing application's "MPI rank -> hostname" mapping.
          * The reading application needs to know about its own mapping.