Home
last modified time | relevance | path

Searched refs:msgs_wait_cnt (Results 1 – 3 of 3) sorted by relevance

/dports/net/librdkafka/librdkafka-1.8.2/examples/
H A Drdkafka_performance.c86 static long int msgs_wait_cnt = 0; variable
193 msgs_wait_cnt--; in msg_delivered()
214 !last || msgs_wait_cnt < 5 || in msg_delivered()
215 !(msgs_wait_cnt % dr_disp_div) || in msg_delivered()
224 msgs_wait_cnt); in msg_delivered()
228 rkmessage->offset, msgs_wait_cnt); in msg_delivered()
238 if (msgs_wait_produce_cnt == 0 && msgs_wait_cnt == 0 && !forever) { in msg_delivered()
1463 msgs_wait_cnt++; in main()
1488 msgs_wait_cnt); in main()
/dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/examples/
H A Drdkafka_performance.c86 static long int msgs_wait_cnt = 0; variable
193 msgs_wait_cnt--; in msg_delivered()
214 !last || msgs_wait_cnt < 5 || in msg_delivered()
215 !(msgs_wait_cnt % dr_disp_div) || in msg_delivered()
224 msgs_wait_cnt); in msg_delivered()
228 rkmessage->offset, msgs_wait_cnt); in msg_delivered()
238 if (msgs_wait_produce_cnt == 0 && msgs_wait_cnt == 0 && !forever) { in msg_delivered()
1435 msgs_wait_cnt++; in main()
1460 msgs_wait_cnt); in main()
/dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/examples/
H A Drdkafka_performance.c86 static long int msgs_wait_cnt = 0; variable
193 msgs_wait_cnt--; in msg_delivered()
214 !last || msgs_wait_cnt < 5 || in msg_delivered()
215 !(msgs_wait_cnt % dr_disp_div) || in msg_delivered()
224 msgs_wait_cnt); in msg_delivered()
228 rkmessage->offset, msgs_wait_cnt); in msg_delivered()
238 if (msgs_wait_produce_cnt == 0 && msgs_wait_cnt == 0 && !forever) { in msg_delivered()
1463 msgs_wait_cnt++; in main()
1488 msgs_wait_cnt); in main()