From 1ee51b7e27457a9aba63e21bf1be5fc18f53b582 Mon Sep 17 00:00:00 2001 From: Phillip Whelan Date: Fri, 31 Jan 2025 14:31:48 -0300 Subject: [PATCH] tests: in_kubernetes_events: backport flake test fix from #9877. Signed-off-by: Phillip Whelan --- tests/runtime/in_kubernetes_events.c | 21 +++++++++++++++------ 1 file changed, 15 insertions(+), 6 deletions(-) diff --git a/tests/runtime/in_kubernetes_events.c b/tests/runtime/in_kubernetes_events.c index f8169efe5f8..d17707057f2 100644 --- a/tests/runtime/in_kubernetes_events.c +++ b/tests/runtime/in_kubernetes_events.c @@ -328,6 +328,7 @@ void flb_test_events_v1_with_lastTimestamp() int ret; int num; const char *filename = "eventlist_v1_with_lastTimestamp"; + int trys; clear_output_num(); @@ -347,8 +348,10 @@ void flb_test_events_v1_with_lastTimestamp() ret = flb_start(ctx->flb); TEST_CHECK(ret == 0); - // waiting to flush - flb_time_msleep(1500); + // waiting to flush + for (trys = 0; trys < 5 && get_output_num() <= 0; trys++) { + flb_time_msleep(1000); + } num = get_output_num(); if (!TEST_CHECK(num > 0)) { @@ -365,6 +368,7 @@ void flb_test_events_v1_with_creationTimestamp() int ret; int num; const char *filename = "eventlist_v1_with_creationTimestamp"; + int trys; clear_output_num(); @@ -384,8 +388,10 @@ void flb_test_events_v1_with_creationTimestamp() ret = flb_start(ctx->flb); TEST_CHECK(ret == 0); - // waiting to flush - flb_time_msleep(1500); + // waiting to flush + for (trys = 0; trys < 5 && get_output_num() <= 0; trys++) { + flb_time_msleep(1000); + } num = get_output_num(); if (!TEST_CHECK(num > 0)) { @@ -399,6 +405,7 @@ void flb_test_events_with_chunkedrecv() { struct flb_lib_out_cb cb_data; struct test_ctx *ctx; + int trys; int ret; int num; @@ -423,8 +430,10 @@ void flb_test_events_with_chunkedrecv() ret = flb_start(ctx->flb); TEST_CHECK(ret == 0); - // waiting to flush - flb_time_msleep(5000); + // waiting to flush + for (trys = 0; trys < 5 && get_output_num() <= 1; trys++) { + flb_time_msleep(1000); + } num = get_output_num(); if (!TEST_CHECK(num >= 2)) {