Searched refs:rd_kafka_msgq_init (Results 1 – 18 of 18) sorted by relevance
236 static RD_INLINE RD_UNUSED void rd_kafka_msgq_init (rd_kafka_msgq_t *rkmq) { in rd_kafka_msgq_init() function268 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()
972 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 …]
68 rd_kafka_msgq_init(&rko->rko_u.dr.msgq2); in rd_kafka_event_setup()
249 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()
3816 rd_kafka_msgq_init(&rko->rko_u.dr.msgq); in rd_kafka_poll_cb()
2859 rd_kafka_msgq_init(&rko->rko_u.dr.msgq); in rd_kafka_dr_msgq()
234 static RD_INLINE RD_UNUSED void rd_kafka_msgq_init (rd_kafka_msgq_t *rkmq) { in rd_kafka_msgq_init() function266 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()
764 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 …]
230 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()
3610 rd_kafka_msgq_init(&rko->rko_u.dr.msgq); in rd_kafka_poll_cb()
2575 rd_kafka_msgq_init(&rko->rko_u.dr.msgq); in rd_kafka_dr_msgq()
3815 rd_kafka_msgq_init(&rko->rko_u.dr.msgq);
2811 rd_kafka_msgq_init(&rko->rko_u.dr.msgq); in rd_kafka_dr_msgq()