Home
last modified time | relevance | path

Searched refs:rebalance_cnt (Results 1 – 25 of 27) sorted by relevance

12

/dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/tests/
H A D0106-cgrp_sess_timeout.c40 static int rebalance_cnt; variable
49 rebalance_cnt++; in rebalance_cb()
51 rebalance_cnt, rd_kafka_err2name(err), parts->cnt); in rebalance_cb()
108 int start_cnt = rebalance_cnt; in expect_rebalance()
115 while (tmout > test_clock() && rebalance_cnt == start_cnt) { in expect_rebalance()
120 if (rebalance_cnt == start_cnt + 1) { in expect_rebalance()
143 rebalance_cnt = 0; in do_test_session_timeout()
H A D0084-destroy_flags.c37 static RD_TLS int rebalance_cnt = 0; variable
42 rebalance_cnt++; in destroy_flags_rebalance_cb()
120 while (rebalance_cnt == 0) in do_test_destroy_flags()
137 rebalance_cnt = 0; in do_test_destroy_flags()
152 TEST_ASSERT(rebalance_cnt > 0, in do_test_destroy_flags()
155 TEST_ASSERT(rebalance_cnt == 0, in do_test_destroy_flags()
157 rebalance_cnt); in do_test_destroy_flags()
H A D0093-holb.c49 int rebalance_cnt; member
85 cons->rebalance_cnt++; in rebalance_cb()
89 cons->rebalance_cnt, cons->max_rebalance_cnt, in rebalance_cb()
93 TEST_ASSERT(cons->rebalance_cnt <= cons->max_rebalance_cnt, in rebalance_cb()
96 cons->rebalance_cnt, cons->max_rebalance_cnt); in rebalance_cb()
181 c[0].rebalance_cnt, c[0].max_rebalance_cnt, in main_0093_holb_consumer()
182 c[1].rebalance_cnt, c[1].max_rebalance_cnt); in main_0093_holb_consumer()
H A D0091-max_poll_interval_timeout.c56 int rebalance_cnt; member
95 cons->rebalance_cnt++; in rebalance_cb()
99 cons->rebalance_cnt, cons->max_rebalance_cnt, in rebalance_cb()
103 TEST_ASSERT(cons->rebalance_cnt <= cons->max_rebalance_cnt, in rebalance_cb()
106 cons->rebalance_cnt, cons->max_rebalance_cnt); in rebalance_cb()
/dports/net/librdkafka/librdkafka-1.8.2/tests/
H A D0084-destroy_flags.c37 static RD_TLS int rebalance_cnt = 0; variable
42 rebalance_cnt++; in destroy_flags_rebalance_cb()
120 while (rebalance_cnt == 0) in do_test_destroy_flags()
137 rebalance_cnt = 0; in do_test_destroy_flags()
152 TEST_ASSERT(rebalance_cnt > 0, in do_test_destroy_flags()
155 TEST_ASSERT(rebalance_cnt == 0, in do_test_destroy_flags()
157 rebalance_cnt); in do_test_destroy_flags()
H A D0093-holb.c49 int rebalance_cnt; member
85 cons->rebalance_cnt++; in rebalance_cb()
89 cons->rebalance_cnt, cons->max_rebalance_cnt, in rebalance_cb()
93 TEST_ASSERT(cons->rebalance_cnt <= cons->max_rebalance_cnt, in rebalance_cb()
96 cons->rebalance_cnt, cons->max_rebalance_cnt); in rebalance_cb()
181 c[0].rebalance_cnt, c[0].max_rebalance_cnt, in main_0093_holb_consumer()
182 c[1].rebalance_cnt, c[1].max_rebalance_cnt); in main_0093_holb_consumer()
H A D0106-cgrp_sess_timeout.c40 static int rebalance_cnt; variable
49 rebalance_cnt++; in rebalance_cb()
51 rebalance_cnt, rd_kafka_err2name(err), parts->cnt); in rebalance_cb()
113 int start_cnt = rebalance_cnt; in expect_rebalance()
120 while (tmout > test_clock() && rebalance_cnt == start_cnt) { in expect_rebalance()
125 if (rebalance_cnt == start_cnt + 1) { in expect_rebalance()
148 rebalance_cnt = 0; in do_test_session_timeout()
H A D0091-max_poll_interval_timeout.c56 int rebalance_cnt; member
95 cons->rebalance_cnt++; in rebalance_cb()
99 cons->rebalance_cnt, cons->max_rebalance_cnt, in rebalance_cb()
103 TEST_ASSERT(cons->rebalance_cnt <= cons->max_rebalance_cnt, in rebalance_cb()
106 cons->rebalance_cnt, cons->max_rebalance_cnt); in rebalance_cb()
H A D0113-cooperative_rebalance.cpp2435 static int rebalance_cnt; variable
2447 rebalance_cnt++; in rebalance_cb()
2449 rebalance_cnt, rd_kafka_err2name(err), parts->cnt); in rebalance_cb()
2481 int start_cnt = rebalance_cnt; in expect_rebalance0()
2489 while (tmout > test_clock() && rebalance_cnt == start_cnt) { in expect_rebalance0()
2493 if (rebalance_cnt == start_cnt + 1) { in expect_rebalance0()
/dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/tests/
H A D0084-destroy_flags.c37 static RD_TLS int rebalance_cnt = 0;
42 rebalance_cnt++;
120 while (rebalance_cnt == 0)
137 rebalance_cnt = 0;
152 TEST_ASSERT(rebalance_cnt > 0,
155 TEST_ASSERT(rebalance_cnt == 0,
157 rebalance_cnt);
H A D0093-holb.c49 int rebalance_cnt; member
85 cons->rebalance_cnt++; in rebalance_cb()
89 cons->rebalance_cnt, cons->max_rebalance_cnt, in rebalance_cb()
93 TEST_ASSERT(cons->rebalance_cnt <= cons->max_rebalance_cnt, in rebalance_cb()
96 cons->rebalance_cnt, cons->max_rebalance_cnt); in rebalance_cb()
181 c[0].rebalance_cnt, c[0].max_rebalance_cnt, in main_0093_holb_consumer()
182 c[1].rebalance_cnt, c[1].max_rebalance_cnt); in main_0093_holb_consumer()
H A D0106-cgrp_sess_timeout.c40 static int rebalance_cnt; variable
49 rebalance_cnt++; in rebalance_cb()
51 rebalance_cnt, rd_kafka_err2name(err), parts->cnt); in rebalance_cb()
113 int start_cnt = rebalance_cnt; in expect_rebalance()
120 while (tmout > test_clock() && rebalance_cnt == start_cnt) { in expect_rebalance()
125 if (rebalance_cnt == start_cnt + 1) { in expect_rebalance()
148 rebalance_cnt = 0; in do_test_session_timeout()
H A D0091-max_poll_interval_timeout.c56 int rebalance_cnt; member
95 cons->rebalance_cnt++; in rebalance_cb()
99 cons->rebalance_cnt, cons->max_rebalance_cnt, in rebalance_cb()
103 TEST_ASSERT(cons->rebalance_cnt <= cons->max_rebalance_cnt, in rebalance_cb()
106 cons->rebalance_cnt, cons->max_rebalance_cnt); in rebalance_cb()
H A D0113-cooperative_rebalance.cpp2435 static int rebalance_cnt;
2447 rebalance_cnt++;
2449 rebalance_cnt, rd_kafka_err2name(err), parts->cnt);
2481 int start_cnt = rebalance_cnt;
2489 while (tmout > test_clock() && rebalance_cnt == start_cnt) {
2493 if (rebalance_cnt == start_cnt + 1) {
/dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/src/
H A Drdkafka_cgrp.h244 int rebalance_cnt; /* Number of member
H A Drdkafka_cgrp.c692 rkcg->rkcg_c.rebalance_cnt++; in rd_kafka_rebalance_op()
H A Drdkafka.c1730 rkcg->rkcg_c.rebalance_cnt, in rd_kafka_stats_emit_all()
/dports/net/librdkafka/librdkafka-1.8.2/src/
H A Drdkafka_cgrp.h280 int rebalance_cnt; /* Number of member
H A Drdkafka_cgrp.c972 rkcg->rkcg_c.rebalance_cnt++; in rd_kafka_rebalance_op_incr()
1091 rkcg->rkcg_c.rebalance_cnt++; in rd_kafka_rebalance_op()
/dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/src/
H A Drdkafka_cgrp.h273 int rebalance_cnt; /* Number of member
H A Drdkafka_cgrp.c909 rkcg->rkcg_c.rebalance_cnt++; in rd_kafka_rebalance_op_incr()
1028 rkcg->rkcg_c.rebalance_cnt++; in rd_kafka_rebalance_op()
/dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-0.24.0/src/
H A Dstatistics.rs301 pub rebalance_cnt: i64, field
/dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/
H A DSTATISTICS.md203 rebalance_cnt | int | | Total number of rebalances (assign or revoke).
/dports/net/librdkafka/librdkafka-1.8.2/
H A DSTATISTICS.md208 rebalance_cnt | int | | Total number of rebalances (assign or revoke).
/dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/
H A DSTATISTICS.md208 rebalance_cnt | int | | Total number of rebalances (assign or revoke).

12