From 77c65afcdafceb70af6a6ece67e0867a414ba0c9 Mon Sep 17 00:00:00 2001 From: Anchit Jain Date: Fri, 29 Sep 2023 12:16:58 +0000 Subject: [PATCH] Fix style --- tests/0089-max_poll_interval.c | 17 +++++++++-------- 1 file changed, 9 insertions(+), 8 deletions(-) diff --git a/tests/0089-max_poll_interval.c b/tests/0089-max_poll_interval.c index e47ce1510b..6227e8a11f 100644 --- a/tests/0089-max_poll_interval.c +++ b/tests/0089-max_poll_interval.c @@ -453,7 +453,7 @@ static void consume_cb(rd_kafka_message_t *rkmessage, void *opaque) { TEST_SAY("Consume callback\n"); } -static void do_test_max_poll_reset_with_consumer_cb(void ) { +static void do_test_max_poll_reset_with_consumer_cb(void) { const char *topic = test_mk_topic_name("0089_max_poll_interval", 1); rd_kafka_conf_t *conf; char groupid[64]; @@ -486,7 +486,8 @@ static void do_test_max_poll_reset_with_consumer_cb(void ) { TEST_SAY("Subscribed to %s and sleeping for 5 s\n", topic); rd_sleep(5); rd_kafka_poll(rk, 10); - TEST_SAY("Polled and sleeping again for 6s. Max poll should be reset\n"); + TEST_SAY( + "Polled and sleeping again for 6s. Max poll should be reset\n"); rd_sleep(6); // Poll should work @@ -497,11 +498,11 @@ static void do_test_max_poll_reset_with_consumer_cb(void ) { } int main_0089_max_poll_interval(int argc, char **argv) { - do_test(); - do_test_with_log_queue(); - do_test_rejoin_after_interval_expire(rd_false, rd_false); - do_test_rejoin_after_interval_expire(rd_true, rd_false); - do_test_rejoin_after_interval_expire(rd_false, rd_true); - do_test_max_poll_reset_with_consumer_cb(); + do_test(); + do_test_with_log_queue(); + do_test_rejoin_after_interval_expire(rd_false, rd_false); + do_test_rejoin_after_interval_expire(rd_true, rd_false); + do_test_rejoin_after_interval_expire(rd_false, rd_true); + do_test_max_poll_reset_with_consumer_cb(); return 0; }