From 9700ea33406b7965bd2bb3678fbbb04fc33c68d4 Mon Sep 17 00:00:00 2001 From: evgeny Date: Tue, 3 Nov 2026 16:36:18 +0100 Subject: [PATCH] Allow membership closure to finish before releasing restored stream handle --- tests/test_stream_service.c | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/tests/test_stream_service.c b/tests/test_stream_service.c index 0a80e3ca7..aa9f69909 100644 --- a/tests/test_stream_service.c +++ b/tests/test_stream_service.c @@ -2036,10 +2036,10 @@ static void test_member_lifecycle(void) { CHECK(stream_get_info(other, &restarted) == STREAM_OK && restarted.buffer.blocks > 0); CHECK(member_owner_update(1, 1, 1001, 0, 0) >= 0); CHECK(!stream_handle_active(reader)); - stream_close(reader); reader = NULL; 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)); + 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, " "higher owner version restores new open");