/dports/sysutils/syslog-ng/syslog-ng-3.35.1/modules/kafka/ |
H A D | kafka-dest-driver.c | 428 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 D | 0057-invalid_topic.cpp | 100 if (p->outq_len() > 0) in test_invalid_topic() 102 p->outq_len() << " messages remain"); in test_invalid_topic()
|
H A D | 0085-headers.cpp | 96 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 D | 0057-invalid_topic.cpp | 100 if (p->outq_len() > 0) in test_invalid_topic() 102 p->outq_len() << " messages remain"); in test_invalid_topic()
|
H A D | 0085-headers.cpp | 96 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 D | 0057-invalid_topic.cpp | 100 if (p->outq_len() > 0) in test_invalid_topic() 102 p->outq_len() << " messages remain"); in test_invalid_topic()
|
H A D | 0085-headers.cpp | 96 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 D | producer.cpp | 222 if (producer->outq_len() > 0) in main() 223 std::cerr << "% " << producer->outq_len() << in main()
|
H A D | rdkafka_example.cpp | 556 while (run && producer->outq_len() > 0) { in main() 557 std::cerr << "Waiting for " << producer->outq_len() << std::endl; in main()
|
H A D | kafkatest_verifiable_client.cpp | 870 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 D | producer.cpp | 222 if (producer->outq_len() > 0) in main() 223 std::cerr << "% " << producer->outq_len() << in main()
|
H A D | rdkafka_example.cpp | 556 while (run && producer->outq_len() > 0) { in main() 557 std::cerr << "Waiting for " << producer->outq_len() << std::endl; in main()
|
H A D | kafkatest_verifiable_client.cpp | 870 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 D | producer.cpp | 222 if (producer->outq_len() > 0) in main() 223 std::cerr << "% " << producer->outq_len() << in main()
|
H A D | rdkafka_example.cpp | 556 while (run && producer->outq_len() > 0) { in main() 557 std::cerr << "Waiting for " << producer->outq_len() << std::endl; in main()
|
H A D | kafkatest_verifiable_client.cpp | 870 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 D | kafka_common.c | 582 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 D | kafka-serdes-avro-console-producer.cpp | 392 while (producer->outq_len() > 0) in main()
|
/dports/net-mgmt/openbmp/openbmp-0.14.0/Server/src/kafka/ |
H A D | MsgBusImpl_kafka.cpp | 133 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 D | rdkafkacpp.h | 1501 virtual int outq_len () = 0;
|
H A D | rdkafkacpp_int.h | 901 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 D | rdkafkacpp.h | 1388 virtual int outq_len () = 0;
|
H A D | rdkafkacpp_int.h | 876 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 D | rdkafkacpp.h | 1498 virtual int outq_len () = 0;
|
H A D | rdkafkacpp_int.h | 901 int outq_len () { return rd_kafka_outq_len(rk_); }; in outq_len() function
|