Home
last modified time | relevance | path

Searched refs:rd_kafka_msgq_init (Results 1 – 18 of 18) sorted by relevance

/dports/net/librdkafka/librdkafka-1.8.2/src/
H A Drdkafka_msg.h236 static RD_INLINE RD_UNUSED void rd_kafka_msgq_init (rd_kafka_msgq_t *rkmq) { in rd_kafka_msgq_init() function
268 rd_kafka_msgq_init(src); in rd_kafka_msgq_concat()
281 rd_kafka_msgq_init(src); in rd_kafka_msgq_move()
315 rd_kafka_msgq_init(rkmq); in rd_kafka_msgq_purge()
H A Drdkafka_msg.c972 rd_kafka_msgq_init(rightq); in rd_kafka_msgq_split()
1646 rd_kafka_msgq_init(&rkmb->msgq); in rd_kafka_msgbatch_init()
1822 rd_kafka_msgq_init(rkmq); in ut_rd_kafka_msgq_purge()
1895 rd_kafka_msgq_init(&sendq); in unittest_msgq_order()
1933 rd_kafka_msgq_init(&sendq); in unittest_msgq_order()
1985 rd_kafka_msgq_init(&sendq); in unittest_msgq_order()
1986 rd_kafka_msgq_init(&sendq2); in unittest_msgq_order()
2110 rd_kafka_msgq_init(&destq); in unittest_msgq_insert_all_sort()
2111 rd_kafka_msgq_init(&srcq); in unittest_msgq_insert_all_sort()
2206 rd_kafka_msgq_init(&destq); in unittest_msgq_insert_each_sort()
[all …]
H A Drdkafka_event.h68 rd_kafka_msgq_init(&rko->rko_u.dr.msgq2); in rd_kafka_event_setup()
H A Drdkafka_partition.c249 rd_kafka_msgq_init(&rktp->rktp_msgq); in rd_kafka_toppar_new0()
250 rd_kafka_msgq_init(&rktp->rktp_xmit_msgq); in rd_kafka_toppar_new0()
767 rd_kafka_msgq_init(&tmpq); in rd_kafka_msgq_insert_msgq_before()
H A Drdkafka.c3816 rd_kafka_msgq_init(&rko->rko_u.dr.msgq); in rd_kafka_poll_cb()
H A Drdkafka_broker.c2859 rd_kafka_msgq_init(&rko->rko_u.dr.msgq); in rd_kafka_dr_msgq()
/dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/src/
H A Drdkafka_msg.h234 static RD_INLINE RD_UNUSED void rd_kafka_msgq_init (rd_kafka_msgq_t *rkmq) { in rd_kafka_msgq_init() function
266 rd_kafka_msgq_init(src); in rd_kafka_msgq_concat()
279 rd_kafka_msgq_init(src); in rd_kafka_msgq_move()
313 rd_kafka_msgq_init(rkmq); in rd_kafka_msgq_purge()
H A Drdkafka_msg.c764 rd_kafka_msgq_init(rightq); in rd_kafka_msgq_split()
1388 rd_kafka_msgq_init(&rkmb->msgq); in rd_kafka_msgbatch_init()
1563 rd_kafka_msgq_init(rkmq); in ut_rd_kafka_msgq_purge()
1636 rd_kafka_msgq_init(&sendq); in unittest_msgq_order()
1674 rd_kafka_msgq_init(&sendq); in unittest_msgq_order()
1726 rd_kafka_msgq_init(&sendq); in unittest_msgq_order()
1727 rd_kafka_msgq_init(&sendq2); in unittest_msgq_order()
1851 rd_kafka_msgq_init(&destq); in unittest_msgq_insert_all_sort()
1852 rd_kafka_msgq_init(&srcq); in unittest_msgq_insert_all_sort()
1947 rd_kafka_msgq_init(&destq); in unittest_msgq_insert_each_sort()
[all …]
H A Drdkafka_event.h68 rd_kafka_msgq_init(&rko->rko_u.dr.msgq2); in rd_kafka_event_setup()
H A Drdkafka_partition.c230 rd_kafka_msgq_init(&rktp->rktp_msgq); in rd_kafka_toppar_new0()
231 rd_kafka_msgq_init(&rktp->rktp_xmit_msgq); in rd_kafka_toppar_new0()
755 rd_kafka_msgq_init(&tmpq); in rd_kafka_msgq_insert_msgq_before()
H A Drdkafka.c3610 rd_kafka_msgq_init(&rko->rko_u.dr.msgq); in rd_kafka_poll_cb()
H A Drdkafka_broker.c2575 rd_kafka_msgq_init(&rko->rko_u.dr.msgq); in rd_kafka_dr_msgq()
/dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/src/
H A Drdkafka_msg.h236 static RD_INLINE RD_UNUSED void rd_kafka_msgq_init (rd_kafka_msgq_t *rkmq) { in rd_kafka_msgq_init() function
268 rd_kafka_msgq_init(src); in rd_kafka_msgq_concat()
281 rd_kafka_msgq_init(src); in rd_kafka_msgq_move()
315 rd_kafka_msgq_init(rkmq); in rd_kafka_msgq_purge()
H A Drdkafka_msg.c972 rd_kafka_msgq_init(rightq); in rd_kafka_msgq_split()
1646 rd_kafka_msgq_init(&rkmb->msgq); in rd_kafka_msgbatch_init()
1822 rd_kafka_msgq_init(rkmq); in ut_rd_kafka_msgq_purge()
1895 rd_kafka_msgq_init(&sendq); in unittest_msgq_order()
1933 rd_kafka_msgq_init(&sendq); in unittest_msgq_order()
1985 rd_kafka_msgq_init(&sendq); in unittest_msgq_order()
1986 rd_kafka_msgq_init(&sendq2); in unittest_msgq_order()
2110 rd_kafka_msgq_init(&destq); in unittest_msgq_insert_all_sort()
2111 rd_kafka_msgq_init(&srcq); in unittest_msgq_insert_all_sort()
2206 rd_kafka_msgq_init(&destq); in unittest_msgq_insert_each_sort()
[all …]
H A Drdkafka_event.h68 rd_kafka_msgq_init(&rko->rko_u.dr.msgq2); in rd_kafka_event_setup()
H A Drdkafka_partition.c249 rd_kafka_msgq_init(&rktp->rktp_msgq); in rd_kafka_toppar_new0()
250 rd_kafka_msgq_init(&rktp->rktp_xmit_msgq); in rd_kafka_toppar_new0()
767 rd_kafka_msgq_init(&tmpq); in rd_kafka_msgq_insert_msgq_before()
H A Drdkafka.c3815 rd_kafka_msgq_init(&rko->rko_u.dr.msgq);
H A Drdkafka_broker.c2811 rd_kafka_msgq_init(&rko->rko_u.dr.msgq); in rd_kafka_dr_msgq()