Home
last modified time | relevance | path

Searched refs:rd_kafka_msgq_concat (Results 1 – 6 of 6) sorted by relevance

/dports/net/librdkafka/librdkafka-1.8.2/src/
H A Drdkafka_msg.h263 static RD_INLINE RD_UNUSED void rd_kafka_msgq_concat (rd_kafka_msgq_t *dst, in rd_kafka_msgq_concat() function
294 rd_kafka_msgq_concat(src, dst); in rd_kafka_msgq_prepend()
H A Drdkafka_partition.c736 rd_kafka_msgq_concat(destq, srcq); in rd_kafka_msgq_insert_msgq_before()
833 rd_kafka_msgq_concat(destq, srcq); in rd_kafka_msgq_insert_msgq()
4312 rd_kafka_msgq_concat(&rkmq, &rktp->rktp_xmit_msgq); in rd_kafka_toppar_purge_queues()
4316 rd_kafka_msgq_concat(&rkmq, &rktp->rktp_msgq); in rd_kafka_toppar_purge_queues()
/dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/src/
H A Drdkafka_msg.h261 static RD_INLINE RD_UNUSED void rd_kafka_msgq_concat (rd_kafka_msgq_t *dst, in rd_kafka_msgq_concat() function
292 rd_kafka_msgq_concat(src, dst); in rd_kafka_msgq_prepend()
H A Drdkafka_partition.c724 rd_kafka_msgq_concat(destq, srcq); in rd_kafka_msgq_insert_msgq_before()
821 rd_kafka_msgq_concat(destq, srcq); in rd_kafka_msgq_insert_msgq()
3752 rd_kafka_msgq_concat(&rkmq, &rktp->rktp_xmit_msgq); in rd_kafka_toppar_handle_purge_queues()
3755 rd_kafka_msgq_concat(&rkmq, &rktp->rktp_msgq); in rd_kafka_toppar_handle_purge_queues()
/dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/src/
H A Drdkafka_msg.h263 static RD_INLINE RD_UNUSED void rd_kafka_msgq_concat (rd_kafka_msgq_t *dst, in rd_kafka_msgq_concat() function
294 rd_kafka_msgq_concat(src, dst); in rd_kafka_msgq_prepend()
H A Drdkafka_partition.c736 rd_kafka_msgq_concat(destq, srcq); in rd_kafka_msgq_insert_msgq_before()
833 rd_kafka_msgq_concat(destq, srcq); in rd_kafka_msgq_insert_msgq()
4297 rd_kafka_msgq_concat(&rkmq, &rktp->rktp_xmit_msgq); in rd_kafka_toppar_purge_queues()
4301 rd_kafka_msgq_concat(&rkmq, &rktp->rktp_msgq); in rd_kafka_toppar_purge_queues()