Home
last modified time | relevance | path

Searched refs:outq_len (Results 1 – 25 of 26) sorted by relevance

12

/dports/sysutils/syslog-ng/syslog-ng-3.35.1/modules/kafka/
H A Dkafka-dest-driver.c428 gint outq_len = rd_kafka_outq_len(self->kafka); in _flush_inflight_messages() local
431 if (outq_len > 0) in _flush_inflight_messages()
437 evt_tag_int("outq_len", outq_len), in _flush_inflight_messages()
453 outq_len = rd_kafka_outq_len(self->kafka); in _flush_inflight_messages()
455 if (outq_len != 0) in _flush_inflight_messages()
459 evt_tag_int("outq_len", outq_len)); in _flush_inflight_messages()
659 gint outq_len = rd_kafka_outq_len(self->kafka); in _check_for_remaining_messages() local
660 if (outq_len != 0) in _check_for_remaining_messages()
664 evt_tag_int("outq_len", outq_len)); in _check_for_remaining_messages()
/dports/net/librdkafka/librdkafka-1.8.2/tests/
H A D0057-invalid_topic.cpp100 if (p->outq_len() > 0) in test_invalid_topic()
102 p->outq_len() << " messages remain"); in test_invalid_topic()
H A D0085-headers.cpp96 if (producer->outq_len() > 0) in test_headers()
98 producer->outq_len() << " messages remain"); in test_headers()
/dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/tests/
H A D0057-invalid_topic.cpp100 if (p->outq_len() > 0) in test_invalid_topic()
102 p->outq_len() << " messages remain"); in test_invalid_topic()
H A D0085-headers.cpp96 if (producer->outq_len() > 0) in test_headers()
98 producer->outq_len() << " messages remain"); in test_headers()
/dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/tests/
H A D0057-invalid_topic.cpp100 if (p->outq_len() > 0) in test_invalid_topic()
102 p->outq_len() << " messages remain"); in test_invalid_topic()
H A D0085-headers.cpp96 if (producer->outq_len() > 0) in test_headers()
98 producer->outq_len() << " messages remain"); in test_headers()
/dports/net/librdkafka/librdkafka-1.8.2/examples/
H A Dproducer.cpp222 if (producer->outq_len() > 0) in main()
223 std::cerr << "% " << producer->outq_len() << in main()
H A Drdkafka_example.cpp556 while (run && producer->outq_len() > 0) { in main()
557 std::cerr << "Waiting for " << producer->outq_len() << std::endl; in main()
H A Dkafkatest_verifiable_client.cpp870 while (run && producer->outq_len() > 0) { in main()
871 std::cerr << now() << ": Waiting for " << producer->outq_len() << std::endl; in main()
/dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/examples/
H A Dproducer.cpp222 if (producer->outq_len() > 0) in main()
223 std::cerr << "% " << producer->outq_len() << in main()
H A Drdkafka_example.cpp556 while (run && producer->outq_len() > 0) { in main()
557 std::cerr << "Waiting for " << producer->outq_len() << std::endl; in main()
H A Dkafkatest_verifiable_client.cpp870 while (run && producer->outq_len() > 0) { in main()
871 std::cerr << now() << ": Waiting for " << producer->outq_len() << std::endl; in main()
/dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/examples/
H A Dproducer.cpp222 if (producer->outq_len() > 0) in main()
223 std::cerr << "% " << producer->outq_len() << in main()
H A Drdkafka_example.cpp556 while (run && producer->outq_len() > 0) { in main()
557 std::cerr << "Waiting for " << producer->outq_len() << std::endl; in main()
H A Dkafkatest_verifiable_client.cpp870 while (run && producer->outq_len() > 0) { in main()
871 std::cerr << now() << ": Waiting for " << producer->outq_len() << std::endl; in main()
/dports/net-mgmt/pmacct/pmacct-1.7.5/src/
H A Dkafka_common.c582 int outq_len = 0, old_outq_len = 0, retries = 0; in p_kafka_check_outq_len() local
585 while ((outq_len = rd_kafka_outq_len(kafka_host->rk)) > 0) { in p_kafka_check_outq_len()
586 if (outq_len == old_outq_len) { in p_kafka_check_outq_len()
591 return outq_len; in p_kafka_check_outq_len()
594 else old_outq_len = outq_len; in p_kafka_check_outq_len()
/dports/devel/libserdes/libserdes-6.0.2/examples/
H A Dkafka-serdes-avro-console-producer.cpp392 while (producer->outq_len() > 0) in main()
/dports/net-mgmt/openbmp/openbmp-0.14.0/Server/src/kafka/
H A DMsgBusImpl_kafka.cpp133 while (producer->outq_len() > 0 and i < 8) { in disconnect()
134 … LOG_INFO("Waiting for producer to finish before disconnecting: outq=%d", producer->outq_len()); in disconnect()
/dports/net/librdkafka/librdkafka-1.8.2/src-cpp/
H A Drdkafkacpp.h1501 virtual int outq_len () = 0;
H A Drdkafkacpp_int.h901 int outq_len () { return rd_kafka_outq_len(rk_); }; in outq_len() function
/dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/src-cpp/
H A Drdkafkacpp.h1388 virtual int outq_len () = 0;
H A Drdkafkacpp_int.h876 int outq_len () { return rd_kafka_outq_len(rk_); }; in outq_len() function
/dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/src-cpp/
H A Drdkafkacpp.h1498 virtual int outq_len () = 0;
H A Drdkafkacpp_int.h901 int outq_len () { return rd_kafka_outq_len(rk_); }; in outq_len() function

12