/dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/tests/ |
H A D | 0106-cgrp_sess_timeout.c | 40 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 D | 0084-destroy_flags.c | 37 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 D | 0093-holb.c | 49 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 D | 0091-max_poll_interval_timeout.c | 56 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 D | 0084-destroy_flags.c | 37 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 D | 0093-holb.c | 49 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 D | 0106-cgrp_sess_timeout.c | 40 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 D | 0091-max_poll_interval_timeout.c | 56 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 D | 0113-cooperative_rebalance.cpp | 2435 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 D | 0084-destroy_flags.c | 37 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 D | 0093-holb.c | 49 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 D | 0106-cgrp_sess_timeout.c | 40 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 D | 0091-max_poll_interval_timeout.c | 56 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 D | 0113-cooperative_rebalance.cpp | 2435 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 D | rdkafka_cgrp.h | 244 int rebalance_cnt; /* Number of member
|
H A D | rdkafka_cgrp.c | 692 rkcg->rkcg_c.rebalance_cnt++; in rd_kafka_rebalance_op()
|
H A D | rdkafka.c | 1730 rkcg->rkcg_c.rebalance_cnt, in rd_kafka_stats_emit_all()
|
/dports/net/librdkafka/librdkafka-1.8.2/src/ |
H A D | rdkafka_cgrp.h | 280 int rebalance_cnt; /* Number of member
|
H A D | rdkafka_cgrp.c | 972 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 D | rdkafka_cgrp.h | 273 int rebalance_cnt; /* Number of member
|
H A D | rdkafka_cgrp.c | 909 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 D | statistics.rs | 301 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 D | STATISTICS.md | 203 rebalance_cnt | int | | Total number of rebalances (assign or revoke).
|
/dports/net/librdkafka/librdkafka-1.8.2/ |
H A D | STATISTICS.md | 208 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 D | STATISTICS.md | 208 rebalance_cnt | int | | Total number of rebalances (assign or revoke).
|