| /dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/src/ |
| H A D | rdkafka_msg.c | 1445 rd_kafka_msgq_len(&rkmb->msgq) && in rd_kafka_msgbatch_ready_produce()
1467 if (rd_kafka_msgq_len(rkmq) == 0) in rd_kafka_msgq_verify_order0()
1637 while (rd_kafka_msgq_len(&sendq) < 3) in unittest_msgq_order()
1661 rd_kafka_msgq_len(&sendq)); in unittest_msgq_order()
1675 while (rd_kafka_msgq_len(&sendq) < 4) in unittest_msgq_order()
1729 while (rd_kafka_msgq_len(&sendq) < 3) in unittest_msgq_order()
1732 while (rd_kafka_msgq_len(&sendq2) < 3) in unittest_msgq_order()
1746 rd_kafka_msgq_len(&sendq)); in unittest_msgq_order()
1883 rd_kafka_msgq_len(&srcq), rd_kafka_msgq_len(&destq)); in unittest_msgq_insert_all_sort()
1895 rd_kafka_msgq_len(&srcq)); in unittest_msgq_insert_all_sort()
[all …]
|
| H A D | rdkafka_request.c | 2631 rd_kafka_msgq_len(&batch->msgq), in rd_kafka_handle_idempotent_Produce_error()
2763 rd_kafka_msgq_len(&batch->msgq), in rd_kafka_handle_Produce_error()
3044 rd_kafka_msgq_len(&batch->msgq), in rd_kafka_handle_idempotent_Produce_success()
3106 rd_kafka_msgq_len(&batch->msgq)); in rd_kafka_msgbatch_handle_Produce_result()
3159 if (likely(rd_kafka_msgq_len(&batch->msgq) > 0)) { in rd_kafka_msgbatch_handle_Produce_result()
3249 cnt = rd_kafka_msgq_len(&rkbuf->rkbuf_batch.msgq); in rd_kafka_ProduceRequest()
4250 RD_UT_ASSERT(rd_kafka_msgq_len(&rkmq) == 0, in unittest_idempotent_producer()
4253 rd_kafka_msgq_len(&rkmq)); in unittest_idempotent_producer()
4286 rd_kafka_msgq_len(&rktp->rktp_msgq)); in unittest_idempotent_producer()
4301 rd_kafka_msgq_len(&rktp->rktp_msgq)); in unittest_idempotent_producer()
[all …]
|
| H A D | rdkafka_buf.c | 195 rd_kafka_msgq_len(&rkbuf->rkbuf_batch.msgq)); in rd_kafka_bufq_enq()
204 rd_kafka_msgq_len(&rkbuf->rkbuf_batch.msgq)); in rd_kafka_bufq_deq()
|
| H A D | rdkafka_msgset_writer.c | 501 int msgcnt = rd_kafka_msgq_len(rkmq); in rd_kafka_msgset_writer_init()
1286 int msgcnt = rd_kafka_msgq_len(&rkbuf->rkbuf_batch.msgq); in rd_kafka_msgset_writer_finalize_MessageSet_v2_header()
1380 rd_kafka_msgq_len(&rkbuf->rkbuf_batch.msgq)) == 0)) { in rd_kafka_msgset_writer_finalize()
|
| H A D | rdkafka_broker.c | 926 rd_kafka_msgq_len(&rkbuf->rkbuf_batch.msgq)); in rd_kafka_broker_buf_enq0()
2561 if (unlikely(rd_kafka_msgq_len(rkmq) == 0)) in rd_kafka_dr_msgq()
2616 if (!rd_kafka_msgq_len(&acked)) in rd_kafka_dr_implicit_ack()
2626 rd_kafka_msgq_len(&acked), in rd_kafka_dr_implicit_ack()
2904 rd_kafka_msgq_len(&rktp->rktp_msgq)); in rd_kafka_broker_op_serve()
2985 rd_kafka_msgq_len(&rktp->rktp_xmit_msgq), in rd_kafka_broker_op_serve()
3027 rd_kafka_msgq_len(&rktp->rktp_msgq)); in rd_kafka_broker_op_serve()
3028 rd_kafka_assert(NULL, rd_kafka_msgq_len(&rktp->rktp_xmit_msgq) == 0); in rd_kafka_broker_op_serve()
3648 if (rd_kafka_msgq_len(&rktp->rktp_xmit_msgq) > 0) in rd_kafka_toppar_producer_serve()
6034 rd_kafka_msgq_len(&rktp->rktp_msgq), in rd_kafka_broker_active_toppar_add()
|
| H A D | rdkafka_msg.h | 213 int rd_kafka_msgq_len (const rd_kafka_msgq_t *rkmq) { in rd_kafka_msgq_len() function
|
| H A D | rdkafka_topic.c | 1369 if (rd_kafka_msgq_len(&timedout) > 0) { in rd_kafka_topic_scan_all()
1373 rd_kafka_msgq_len(&timedout)); in rd_kafka_topic_scan_all()
|
| H A D | rdkafka_partition.c | 313 rd_kafka_msgq_len(&rktp->rktp_xmit_msgq) == 0); in rd_kafka_toppar_destroy_final()
3756 cnt = rd_kafka_msgq_len(&rkmq); in rd_kafka_toppar_handle_purge_queues()
3811 r = rd_kafka_msgq_len(&rktp->rktp_msgq); in rd_kafka_purge_ua_toppar_queues()
|
| H A D | rdkafka.c | 1396 rd_kafka_msgq_len(&rktp->rktp_msgq), in rd_kafka_stats_emit_toppar()
|
| /dports/net/librdkafka/librdkafka-1.8.2/src/ |
| H A D | rdkafka_msg.c | 1704 rd_kafka_msgq_len(&rkmb->msgq) && in rd_kafka_msgbatch_ready_produce()
1726 if (rd_kafka_msgq_len(rkmq) == 0) in rd_kafka_msgq_verify_order0()
1896 while (rd_kafka_msgq_len(&sendq) < 3) in unittest_msgq_order()
1920 rd_kafka_msgq_len(&sendq)); in unittest_msgq_order()
1934 while (rd_kafka_msgq_len(&sendq) < 4) in unittest_msgq_order()
1988 while (rd_kafka_msgq_len(&sendq) < 3) in unittest_msgq_order()
1991 while (rd_kafka_msgq_len(&sendq2) < 3) in unittest_msgq_order()
2005 rd_kafka_msgq_len(&sendq)); in unittest_msgq_order()
2142 rd_kafka_msgq_len(&srcq), rd_kafka_msgq_len(&destq)); in unittest_msgq_insert_all_sort()
2154 rd_kafka_msgq_len(&srcq)); in unittest_msgq_insert_all_sort()
[all …]
|
| H A D | rdkafka_request.c | 2824 rd_kafka_msgq_len(&batch->msgq), in rd_kafka_handle_idempotent_Produce_error()
2965 rd_kafka_msgq_len(&batch->msgq), in rd_kafka_handle_Produce_error()
3258 rd_kafka_msgq_len(&batch->msgq), in rd_kafka_handle_idempotent_Produce_success()
3320 rd_kafka_msgq_len(&batch->msgq)); in rd_kafka_msgbatch_handle_Produce_result()
3373 if (likely(rd_kafka_msgq_len(&batch->msgq) > 0)) { in rd_kafka_msgbatch_handle_Produce_result()
3466 cnt = rd_kafka_msgq_len(&rkbuf->rkbuf_batch.msgq); in rd_kafka_ProduceRequest()
4633 RD_UT_ASSERT(rd_kafka_msgq_len(&rkmq) == 0, in unittest_idempotent_producer()
4636 rd_kafka_msgq_len(&rkmq)); in unittest_idempotent_producer()
4669 rd_kafka_msgq_len(&rktp->rktp_msgq)); in unittest_idempotent_producer()
4684 rd_kafka_msgq_len(&rktp->rktp_msgq)); in unittest_idempotent_producer()
[all …]
|
| H A D | rdkafka_buf.c | 214 rd_kafka_msgq_len(&rkbuf->rkbuf_batch.msgq)); in rd_kafka_bufq_enq()
223 rd_kafka_msgq_len(&rkbuf->rkbuf_batch.msgq)); in rd_kafka_bufq_deq()
|
| H A D | rdkafka_msgset_writer.c | 502 int msgcnt = rd_kafka_msgq_len(rkmq); in rd_kafka_msgset_writer_init()
1289 int msgcnt = rd_kafka_msgq_len(&rkbuf->rkbuf_batch.msgq); in rd_kafka_msgset_writer_finalize_MessageSet_v2_header()
1383 rd_kafka_msgq_len(&rkbuf->rkbuf_batch.msgq)) == 0)) { in rd_kafka_msgset_writer_finalize()
|
| H A D | rdkafka_broker.c | 1061 rd_kafka_msgq_len(&rkbuf->rkbuf_batch.msgq)); in rd_kafka_broker_buf_enq0()
2841 if (unlikely(rd_kafka_msgq_len(rkmq) == 0)) in rd_kafka_dr_msgq()
2846 rd_kafka_msgq_len(rkmq)); in rd_kafka_dr_msgq()
2900 if (!rd_kafka_msgq_len(&acked)) in rd_kafka_dr_implicit_ack()
2910 rd_kafka_msgq_len(&acked), in rd_kafka_dr_implicit_ack()
3189 rd_kafka_msgq_len(&rktp->rktp_msgq)); in rd_kafka_broker_op_serve()
3276 rd_kafka_msgq_len(&rktp->rktp_xmit_msgq), in rd_kafka_broker_op_serve()
3316 rd_kafka_msgq_len(&rktp->rktp_msgq)); in rd_kafka_broker_op_serve()
3317 rd_kafka_assert(NULL, rd_kafka_msgq_len(&rktp->rktp_xmit_msgq) == 0); in rd_kafka_broker_op_serve()
3969 if (rd_kafka_msgq_len(&rktp->rktp_xmit_msgq) > 0) in rd_kafka_toppar_producer_serve()
[all …]
|
| H A D | rdkafka_msg.h | 215 int rd_kafka_msgq_len (const rd_kafka_msgq_t *rkmq) { in rd_kafka_msgq_len() function
|
| H A D | rdkafka_topic.c | 1536 if (rd_kafka_msgq_len(&timedout) > 0) { in rd_kafka_topic_scan_all()
1540 rd_kafka_msgq_len(&timedout)); in rd_kafka_topic_scan_all()
|
| H A D | rdkafka_partition.c | 334 rd_kafka_msgq_len(&rktp->rktp_xmit_msgq) == 0); in rd_kafka_toppar_destroy_final()
4317 cnt = rd_kafka_msgq_len(&rkmq); in rd_kafka_toppar_purge_queues()
4369 r = rd_kafka_msgq_len(&rktp->rktp_msgq); in rd_kafka_purge_ua_toppar_queues()
|
| /dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/src/ |
| H A D | rdkafka_msg.c | 1704 rd_kafka_msgq_len(&rkmb->msgq) && in rd_kafka_msgbatch_ready_produce()
1726 if (rd_kafka_msgq_len(rkmq) == 0) in rd_kafka_msgq_verify_order0()
1896 while (rd_kafka_msgq_len(&sendq) < 3) in unittest_msgq_order()
1920 rd_kafka_msgq_len(&sendq)); in unittest_msgq_order()
1934 while (rd_kafka_msgq_len(&sendq) < 4) in unittest_msgq_order()
1988 while (rd_kafka_msgq_len(&sendq) < 3) in unittest_msgq_order()
1991 while (rd_kafka_msgq_len(&sendq2) < 3) in unittest_msgq_order()
2005 rd_kafka_msgq_len(&sendq)); in unittest_msgq_order()
2142 rd_kafka_msgq_len(&srcq), rd_kafka_msgq_len(&destq)); in unittest_msgq_insert_all_sort()
2154 rd_kafka_msgq_len(&srcq)); in unittest_msgq_insert_all_sort()
[all …]
|
| H A D | rdkafka_request.c | 2819 rd_kafka_msgq_len(&batch->msgq), in rd_kafka_handle_idempotent_Produce_error()
2960 rd_kafka_msgq_len(&batch->msgq), in rd_kafka_handle_Produce_error()
3253 rd_kafka_msgq_len(&batch->msgq), in rd_kafka_handle_idempotent_Produce_success()
3315 rd_kafka_msgq_len(&batch->msgq)); in rd_kafka_msgbatch_handle_Produce_result()
3368 if (likely(rd_kafka_msgq_len(&batch->msgq) > 0)) { in rd_kafka_msgbatch_handle_Produce_result()
3461 cnt = rd_kafka_msgq_len(&rkbuf->rkbuf_batch.msgq); in rd_kafka_ProduceRequest()
4628 RD_UT_ASSERT(rd_kafka_msgq_len(&rkmq) == 0, in unittest_idempotent_producer()
4631 rd_kafka_msgq_len(&rkmq)); in unittest_idempotent_producer()
4664 rd_kafka_msgq_len(&rktp->rktp_msgq)); in unittest_idempotent_producer()
4679 rd_kafka_msgq_len(&rktp->rktp_msgq)); in unittest_idempotent_producer()
[all …]
|
| H A D | rdkafka_buf.c | 211 rd_kafka_msgq_len(&rkbuf->rkbuf_batch.msgq)); in rd_kafka_bufq_enq()
220 rd_kafka_msgq_len(&rkbuf->rkbuf_batch.msgq)); in rd_kafka_bufq_deq()
|
| H A D | rdkafka_msgset_writer.c | 502 int msgcnt = rd_kafka_msgq_len(rkmq); in rd_kafka_msgset_writer_init()
1289 int msgcnt = rd_kafka_msgq_len(&rkbuf->rkbuf_batch.msgq); in rd_kafka_msgset_writer_finalize_MessageSet_v2_header()
1383 rd_kafka_msgq_len(&rkbuf->rkbuf_batch.msgq)) == 0)) { in rd_kafka_msgset_writer_finalize()
|
| H A D | rdkafka_broker.c | 1051 rd_kafka_msgq_len(&rkbuf->rkbuf_batch.msgq)); in rd_kafka_broker_buf_enq0()
2793 if (unlikely(rd_kafka_msgq_len(rkmq) == 0)) in rd_kafka_dr_msgq()
2798 rd_kafka_msgq_len(rkmq)); in rd_kafka_dr_msgq()
2852 if (!rd_kafka_msgq_len(&acked)) in rd_kafka_dr_implicit_ack()
2862 rd_kafka_msgq_len(&acked), in rd_kafka_dr_implicit_ack()
3141 rd_kafka_msgq_len(&rktp->rktp_msgq)); in rd_kafka_broker_op_serve()
3228 rd_kafka_msgq_len(&rktp->rktp_xmit_msgq), in rd_kafka_broker_op_serve()
3268 rd_kafka_msgq_len(&rktp->rktp_msgq)); in rd_kafka_broker_op_serve()
3269 rd_kafka_assert(NULL, rd_kafka_msgq_len(&rktp->rktp_xmit_msgq) == 0); in rd_kafka_broker_op_serve()
3917 if (rd_kafka_msgq_len(&rktp->rktp_xmit_msgq) > 0) in rd_kafka_toppar_producer_serve()
[all …]
|
| H A D | rdkafka_msg.h | 215 int rd_kafka_msgq_len (const rd_kafka_msgq_t *rkmq) { in rd_kafka_msgq_len() function
|
| H A D | rdkafka_topic.c | 1536 if (rd_kafka_msgq_len(&timedout) > 0) {
1540 rd_kafka_msgq_len(&timedout));
|
| H A D | rdkafka_partition.c | 334 rd_kafka_msgq_len(&rktp->rktp_xmit_msgq) == 0); in rd_kafka_toppar_destroy_final()
4302 cnt = rd_kafka_msgq_len(&rkmq); in rd_kafka_toppar_purge_queues()
4354 r = rd_kafka_msgq_len(&rktp->rktp_msgq); in rd_kafka_purge_ua_toppar_queues()
|