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 <[email protected]> AuthorDate: Fri Jun 30 07:33:54 2023 +0200 MINIFICPP-2142 Fix occasional segfault in SwapTests Closes #1593 Signed-off-by: Marton Szasz <[email protected]> --- 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()); }
