Fixup channels test (#6265)

maxtropets · web-flow · commit b4afd5d123c0 · 2024-06-13T16:36:13.000Z
diff --git a/.snpcc_canary b/.snpcc_canary
@@ -3,4 +3,4 @@
    O     \     o      |    /
 /-xXx--//-----x=x--/-xXx--/---x---->>>--/
 ...
-/\/\
+/\/\(-_-)
diff --git a/src/node/test/channels.cpp b/src/node/test/channels.cpp
@@ -1554,14 +1554,14 @@ TEST_CASE_FIXTURE(IORingbuffersFixture, "Key rotation")
   constexpr int wait_finish_attempts = 100;
   for (int attempt = 0; attempt < wait_finish_attempts; attempt++)
   {
-    bool skip_waiting{false};
+    bool skip_waiting{true};
     {
       std::lock_guard<std::mutex> guard(sent_by_1.lock);
-      skip_waiting |= sent_by_1.to_send.empty();
+      skip_waiting &= sent_by_1.to_send.empty();
     }
     {
       std::lock_guard<std::mutex> guard(sent_by_2.lock);
-      skip_waiting |= sent_by_2.to_send.empty();
+      skip_waiting &= sent_by_2.to_send.empty();
     }
     if (skip_waiting)
     {

Original file line number	Diff line number	Diff line change
`@@ -1554,14 +1554,14 @@ TEST_CASE_FIXTURE(IORingbuffersFixture, "Key rotation")`
`1554`	`1554`	`constexpr int wait_finish_attempts = 100;`
`1555`	`1555`	`for (int attempt = 0; attempt < wait_finish_attempts; attempt++)`
`1556`	`1556`	`{`
`1557`		`- bool skip_waiting{false};`
	`1557`	`+ bool skip_waiting{true};`
`1558`	`1558`	`{`
`1559`	`1559`	`std::lock_guard<std::mutex> guard(sent_by_1.lock);`
`1560`		`- skip_waiting \|= sent_by_1.to_send.empty();`
	`1560`	`+ skip_waiting &= sent_by_1.to_send.empty();`
`1561`	`1561`	`}`
`1562`	`1562`	`{`
`1563`	`1563`	`std::lock_guard<std::mutex> guard(sent_by_2.lock);`
`1564`		`- skip_waiting \|= sent_by_2.to_send.empty();`
	`1564`	`+ skip_waiting &= sent_by_2.to_send.empty();`
`1565`	`1565`	`}`
`1566`	`1566`	`if (skip_waiting)`
`1567`	`1567`	`{`