Searched refs:inflight_cnt (Results 1 – 3 of 3) sorted by relevance
| /dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/src/ |
| H A D | rdkafka_broker.c | 726 int inflight_cnt, retry_cnt, outq_cnt; in rd_kafka_broker_timeout_scan() local
732 inflight_cnt = rd_kafka_broker_bufq_timeout_scan( in rd_kafka_broker_timeout_scan()
746 if (inflight_cnt + retry_cnt + outq_cnt + partial_cnt > 0) { in rd_kafka_broker_timeout_scan()
750 inflight_cnt, retry_cnt, outq_cnt, partial_cnt); in rd_kafka_broker_timeout_scan()
752 rkb->rkb_req_timeouts += inflight_cnt + outq_cnt; in rd_kafka_broker_timeout_scan()
754 inflight_cnt + outq_cnt); in rd_kafka_broker_timeout_scan()
5927 int inflight_cnt = 0, retry_cnt = 0, outq_cnt = 0, partial_cnt = 0; in rd_kafka_broker_handle_purge_queues() local
5941 inflight_cnt = rd_kafka_broker_bufq_timeout_scan( in rd_kafka_broker_handle_purge_queues()
5973 inflight_cnt, retry_cnt, outq_cnt, partial_cnt); in rd_kafka_broker_handle_purge_queues()
|
| /dports/net/librdkafka/librdkafka-1.8.2/src/ |
| H A D | rdkafka_broker.c | 863 int inflight_cnt, retry_cnt, outq_cnt; in rd_kafka_broker_timeout_scan() local
869 inflight_cnt = rd_kafka_broker_bufq_timeout_scan( in rd_kafka_broker_timeout_scan()
883 if (inflight_cnt + retry_cnt + outq_cnt + partial_cnt > 0) { in rd_kafka_broker_timeout_scan()
887 inflight_cnt, retry_cnt, outq_cnt, partial_cnt); in rd_kafka_broker_timeout_scan()
889 rkb->rkb_req_timeouts += inflight_cnt + outq_cnt; in rd_kafka_broker_timeout_scan()
891 inflight_cnt + outq_cnt); in rd_kafka_broker_timeout_scan()
6373 int inflight_cnt = 0, retry_cnt = 0, outq_cnt = 0, partial_cnt = 0; in rd_kafka_broker_handle_purge_queues() local
6387 inflight_cnt = rd_kafka_broker_bufq_timeout_scan( in rd_kafka_broker_handle_purge_queues()
6420 inflight_cnt, retry_cnt, outq_cnt, partial_cnt); in rd_kafka_broker_handle_purge_queues()
|
| /dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/src/ |
| H A D | rdkafka_broker.c | 853 int inflight_cnt, retry_cnt, outq_cnt; in rd_kafka_broker_timeout_scan() local
859 inflight_cnt = rd_kafka_broker_bufq_timeout_scan( in rd_kafka_broker_timeout_scan()
873 if (inflight_cnt + retry_cnt + outq_cnt + partial_cnt > 0) { in rd_kafka_broker_timeout_scan()
877 inflight_cnt, retry_cnt, outq_cnt, partial_cnt); in rd_kafka_broker_timeout_scan()
879 rkb->rkb_req_timeouts += inflight_cnt + outq_cnt; in rd_kafka_broker_timeout_scan()
881 inflight_cnt + outq_cnt); in rd_kafka_broker_timeout_scan()
6318 int inflight_cnt = 0, retry_cnt = 0, outq_cnt = 0, partial_cnt = 0; in rd_kafka_broker_handle_purge_queues() local
6332 inflight_cnt = rd_kafka_broker_bufq_timeout_scan( in rd_kafka_broker_handle_purge_queues()
6365 inflight_cnt, retry_cnt, outq_cnt, partial_cnt); in rd_kafka_broker_handle_purge_queues()
|