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

@@ -2416,6 +2416,9 @@ void verifyHostnameAssignment(
     }
 }
 
+static void breakpoint()
+{}
+
 void run_test()
 {
     /*
@@ -2541,6 +2544,7 @@ void run_test()
          * (Some other options like setting all at once or reading from a file
          * exist as well.)
          */
+        breakpoint();
         series.setRankTable(writingRanksHostnames.at(mpi_rank));
 
         auto E_x = series.iterations[0].meshes["E"]["x"];
@@ -2552,10 +2556,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.
@@ -2565,6 +2572,7 @@ void run_test()
          */
         auto rankMetaIn = series.rankTable(/* collective = */ true);
         OPENPMD_REQUIRE_GUARD_WINDOWS(rankMetaIn == writingRanksHostnames);
+        std::abort();
 
         auto E_x = series.iterations[0].meshes["E"]["x"];
         /*