Fix coretests

Author: franzpoeschel

test/CoreTest.cpp

@@ -1144,8 +1144,10 @@ TEST_CASE("wrapper_test", "[core]")
     std::shared_ptr<double> storeData = std::make_shared<double>(44);
     o.iterations[5].meshes["E"]["y"].storeChunk(storeData, {0}, {1});
 #if openPMD_USE_INVASIVE_TESTS
-    REQUIRE(o.iterations[5].meshes["E"]["y"].get().m_chunks.size() == 1);
-    REQUIRE(mrc3.get().m_chunks.size() == 1);
+    size_t num_chunks = o.IOHandler()->m_flush_immediately ? 0 : 1;
+    REQUIRE(
+        o.iterations[5].meshes["E"]["y"].get().m_chunks.size() == num_chunks);
+    REQUIRE(mrc3.get().m_chunks.size() == num_chunks);
 #endif
     o.flush();
 #if openPMD_USE_INVASIVE_TESTS
@@ -1198,9 +1200,10 @@ TEST_CASE("wrapper_test", "[core]")
             .particles["electrons"]
             .particlePatches["numParticles"][RecordComponent::SCALAR]
             .get()
-            .m_chunks.size() == 1);
+            .m_chunks.size() == num_chunks);
     REQUIRE(
-        pp["numParticles"][RecordComponent::SCALAR].get().m_chunks.size() == 1);
+        pp["numParticles"][RecordComponent::SCALAR].get().m_chunks.size() ==
+        num_chunks);
 #endif
     std::stringstream u64str;
     u64str << determineDatatype<uint64_t>();
@@ -1222,9 +1225,10 @@ TEST_CASE("wrapper_test", "[core]")
             .particles["electrons"]
             .particlePatches["numParticles"][RecordComponent::SCALAR]
             .get()
-            .m_chunks.size() == 2);
+            .m_chunks.size() == num_chunks * 2);
     REQUIRE(
-        pp["numParticles"][RecordComponent::SCALAR].get().m_chunks.size() == 2);
+        pp["numParticles"][RecordComponent::SCALAR].get().m_chunks.size() ==
+        num_chunks * 2);
 #endif
     o.flush();
 #if openPMD_USE_INVASIVE_TESTS
@@ -1267,11 +1271,13 @@ TEST_CASE("use_count_test", "[core]")
     std::shared_ptr<uint16_t> storeData = std::make_shared<uint16_t>(44);
     REQUIRE(storeData.use_count() == 1);
     mrc.storeChunk(storeData, {0}, {1});
-    REQUIRE(storeData.use_count() == 2);
+#if openPMD_USE_INVASIVE_TESTS
+    long additional_internal_use_count =
+        o.IOHandler()->m_flush_immediately ? 0 : 1;
+    REQUIRE(storeData.use_count() == (1 + additional_internal_use_count));
     o.flush();
     REQUIRE(storeData.use_count() == 1);
 
-#if openPMD_USE_INVASIVE_TESTS
     PatchRecordComponent pprc =
         o.iterations[6]
             .particles["electrons"]
@@ -1285,12 +1291,19 @@ TEST_CASE("use_count_test", "[core]")
         .resetDataset(dset);
     pprc.resetDataset(Dataset(determineDatatype<uint64_t>(), {4}));
     pprc.store(0, static_cast<uint64_t>(1));
-    REQUIRE(
-        std::get<std::shared_ptr<void>>(
-            static_cast<Parameter<Operation::WRITE_DATASET> *>(
-                pprc.get().m_chunks.front().parameter.get())
-                ->data.as_variant<auxiliary::WriteBufferTypes>())
-            .use_count() == 1);
+    if (o.IOHandler()->m_flush_immediately)
+    {
+        REQUIRE(pprc.get().m_chunks.empty());
+    }
+    else
+    {
+        REQUIRE(
+                std::get<std::shared_ptr<void>>(
+                    static_cast<Parameter<Operation::WRITE_DATASET> *>(
+                        pprc.get().m_chunks.front().parameter.get())
+                        ->data.as_variant<auxiliary::WriteBufferTypes>())
+                    .use_count() == 1);
+    }
 #endif
 }