Searched refs:outq_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 742 outq_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 5954 outq_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 879 outq_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 6400 outq_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 869 outq_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 6345 outq_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()
|