jeka/utun2
1
0 Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Wait for complete group exchange before stream recovery assertions

Browse Source
This commit is contained in:
evgeny committed 2026-11-03 16:40:56 +01:00
1 parent ebba859223
commit a6e8bde6f8
1 file changed
+3 -2
Download Patch File Download Diff File Expand all files Collapse all files
tests/test_stream_service.c
+3 -2
View File
@@ -2037,8 +2037,9 @@ static void test_member_lifecycle(void) {
CHECK(member_owner_update(1, 1, 1001, 0, 0) >= 0);
CHECK(!stream_handle_active(reader));
uint64_t ready_deadline = get_time_tb() + 100000;
while (!stream_member_online(nodes[1], GROUP1, nodes[0]->node_id) && get_time_tb() < ready_deadline) test_clock_poll(ua, 100);
CHECK(stream_member_online(nodes[1], GROUP1, nodes[0]->node_id));
struct TOPO_GROUP* restored_group = topo_groups_find(nodes[1]->topo_groups, GROUP1);
while (!topo_group_peer_ready(restored_group, nodes[0]->node_id) && get_time_tb() < ready_deadline) test_clock_poll(ua, 100);
CHECK(topo_group_peer_ready(restored_group, nodes[0]->node_id));
stream_close(reader); reader = NULL;
CHECK(stream_subscribe_manual_open(nodes[1], GROUP1, nodes[0]->node_id, &reader) == STREAM_OK);
DEBUG_INFO(DEBUG_CATEGORY_STREAM, "[PASS] own removal: channel closes/new open denied, other channel writes, "