[nifi-minifi-cpp] 05/08: MINIFICPP-2142 Fix occasional segfault in SwapTests

[sz...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

szaszm pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/nifi-minifi-cpp.git

commit 2d606cc62595530e327bcc1f051a41c31ed7a012
Author: Ferenc Gerlits <fg...@gmail.com>
AuthorDate: Fri Jun 30 07:33:54 2023 +0200

    MINIFICPP-2142 Fix occasional segfault in SwapTests
    
    Closes #1593
    Signed-off-by: Marton Szasz <sz...@apache.org>
---
 libminifi/test/rocksdb-tests/SwapTests.cpp | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/libminifi/test/rocksdb-tests/SwapTests.cpp b/libminifi/test/rocksdb-tests/SwapTests.cpp
index 8da38679f..07d0219df 100644
--- a/libminifi/test/rocksdb-tests/SwapTests.cpp
+++ b/libminifi/test/rocksdb-tests/SwapTests.cpp
@@ -126,10 +126,11 @@ TEST_CASE("Connection will on-demand swap flow files") {
   std::set<std::shared_ptr<core::FlowFile>> expired;
   for (size_t i = 0; i < 200; ++i) {
     std::shared_ptr<core::FlowFile> ff;
-    minifi::utils::verifyEventHappenedInPollTime(std::chrono::seconds{1}, [&] {
+    bool got_non_null_flow_file = minifi::utils::verifyEventHappenedInPollTime(std::chrono::seconds{5}, [&] {
       ff = connection->poll(expired);
       return static_cast<bool>(ff);
     });
+    REQUIRE(got_non_null_flow_file);
     REQUIRE(ff->getAttribute("index") == std::to_string(i));
     REQUIRE(ff->getResourceClaim()->getContentFullPath() == processor->flow_files_[i]->getResourceClaim()->getContentFullPath());
   }