Searched refs:produce_cnt (Results 1 – 6 of 6) sorted by relevance
| /dports/net/librdkafka/librdkafka-1.8.2/tests/ |
| H A D | 0084-destroy_flags.c | 64 int produce_cnt; member
81 args->produce_cnt, args->consumer_subscribe, in do_test_destroy_flags()
94 if (args->produce_cnt > 0) { in do_test_destroy_flags()
101 0, args->produce_cnt, in do_test_destroy_flags()
163 args->produce_cnt, args->consumer_subscribe, in do_test_destroy_flags()
|
| H A D | 0090-idempotence.c | 43 rd_atomic32_t produce_cnt; member
65 n = rd_atomic32_add(&state.produce_cnt, 1); in handle_ProduceResponse()
111 rd_atomic32_init(&state.produce_cnt, 0); in do_test_implicit_ack()
|
| /dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/tests/ |
| H A D | 0084-destroy_flags.c | 64 int produce_cnt; member
81 args->produce_cnt, args->consumer_subscribe, in do_test_destroy_flags()
94 if (args->produce_cnt > 0) { in do_test_destroy_flags()
101 0, args->produce_cnt, in do_test_destroy_flags()
163 args->produce_cnt, args->consumer_subscribe, in do_test_destroy_flags()
|
| H A D | 0090-idempotence.c | 43 rd_atomic32_t produce_cnt; member
65 n = rd_atomic32_add(&state.produce_cnt, 1); in handle_ProduceResponse()
111 rd_atomic32_init(&state.produce_cnt, 0); in do_test_implicit_ack()
|
| /dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/tests/ |
| H A D | 0084-destroy_flags.c | 64 int produce_cnt;
81 args->produce_cnt, args->consumer_subscribe,
94 if (args->produce_cnt > 0) {
101 0, args->produce_cnt,
163 args->produce_cnt, args->consumer_subscribe,
|
| H A D | 0090-idempotence.c | 43 rd_atomic32_t produce_cnt; member
65 n = rd_atomic32_add(&state.produce_cnt, 1); in handle_ProduceResponse()
111 rd_atomic32_init(&state.produce_cnt, 0); in do_test_implicit_ack()
|