Home
last modified time | relevance | path

Searched refs:rd_kafka_q_t (Results 1 – 25 of 63) sorted by relevance

123

/dports/net/librdkafka/librdkafka-1.8.2/src/
H A Drdkafka_queue.h134 rd_kafka_q_t *rd_kafka_q_keep (rd_kafka_q_t *rkq) { in rd_kafka_q_keep()
142 rd_kafka_q_t *rd_kafka_q_keep_nolock (rd_kafka_q_t *rkq) { in rd_kafka_q_keep_nolock()
255 void rd_kafka_q_fwd_set0 (rd_kafka_q_t *srcq, rd_kafka_q_t *destq,
265 rd_kafka_q_t *rd_kafka_q_fwd_get (rd_kafka_q_t *rkq, int do_lock) { in rd_kafka_q_fwd_get()
266 rd_kafka_q_t *fwdq; in rd_kafka_q_fwd_get()
347 rd_kafka_q_t *fwdq; in rd_kafka_q_yield()
413 rd_kafka_q_t *fwdq; in rd_kafka_q_enq1()
530 int rd_kafka_q_concat0 (rd_kafka_q_t *rkq, rd_kafka_q_t *srcq, int do_lock) { in rd_kafka_q_concat0()
592 void rd_kafka_q_prepend0 (rd_kafka_q_t *rkq, rd_kafka_q_t *srcq, in rd_kafka_q_prepend0()
832 int rd_kafka_q_move_cnt (rd_kafka_q_t *dstq, rd_kafka_q_t *srcq,
[all …]
H A Drdkafka_queue.c127 void rd_kafka_q_fwd_set0 (rd_kafka_q_t *srcq, rd_kafka_q_t *destq, in rd_kafka_q_fwd_set0()
160 rd_kafka_q_t *fwdq; in rd_kafka_q_purge0()
209 rd_kafka_q_t *fwdq; in rd_kafka_q_purge_toppar_version()
250 int rd_kafka_q_move_cnt (rd_kafka_q_t *dstq, rd_kafka_q_t *srcq, in rd_kafka_q_move_cnt()
348 rd_kafka_q_t *fwdq; in rd_kafka_q_pop_serve()
456 rd_kafka_q_t localq; in rd_kafka_q_serve()
457 rd_kafka_q_t *fwdq; in rd_kafka_q_serve()
572 rd_kafka_q_t *fwdq; in rd_kafka_q_serve_rkmessages()
698 rd_kafka_q_t *rkq; in rd_kafka_queue_new()
754 rd_kafka_q_t *rkq; in rd_kafka_set_log_queue()
[all …]
H A Drdkafka_op.h38 typedef struct rd_kafka_q_s rd_kafka_q_t; typedef
47 rd_kafka_q_t *q;
225 rd_kafka_q_t *rkq,
666 void rd_kafka_q_op_err (rd_kafka_q_t *rkq, rd_kafka_resp_err_t err,
669 void rd_kafka_consumer_err (rd_kafka_q_t *rkq, int32_t broker_id,
674 rd_kafka_op_t *rd_kafka_op_req0 (rd_kafka_q_t *destq,
675 rd_kafka_q_t *recvq,
678 rd_kafka_op_t *rd_kafka_op_req (rd_kafka_q_t *destq,
686 rd_kafka_q_t *rkq, rd_kafka_op_t *rko)
705 rd_kafka_q_t *rkq,
[all …]
H A Drdkafka_op.c447 void rd_kafka_q_op_err (rd_kafka_q_t *rkq, rd_kafka_resp_err_t err, in rd_kafka_q_op_err()
479 void rd_kafka_consumer_err (rd_kafka_q_t *rkq, int32_t broker_id, in rd_kafka_consumer_err()
600 rd_kafka_op_t *rd_kafka_op_req0 (rd_kafka_q_t *destq, in rd_kafka_op_req0()
601 rd_kafka_q_t *recvq, in rd_kafka_op_req0()
624 rd_kafka_op_t *rd_kafka_op_req (rd_kafka_q_t *destq, in rd_kafka_op_req()
627 rd_kafka_q_t *recvq; in rd_kafka_op_req()
643 rd_kafka_op_t *rd_kafka_op_req2 (rd_kafka_q_t *destq, rd_kafka_op_type_t type) { in rd_kafka_op_req2()
685 rd_kafka_op_res_t rd_kafka_op_call (rd_kafka_t *rk, rd_kafka_q_t *rkq, in rd_kafka_op_call()
778 rd_kafka_q_t *rkq, in rd_kafka_op_throttle_time()
808 rd_kafka_op_handle_std (rd_kafka_t *rk, rd_kafka_q_t *rkq, in rd_kafka_op_handle_std()
[all …]
H A Drdkafka_int.h224 rd_kafka_q_t *rk_rep; /* kafka -> application reply queue */
225 rd_kafka_q_t *rk_ops; /* any -> rdkafka main thread ops */
260 rd_kafka_q_t *rk_logq; /* Log queue if `log.queue` set */
455 rd_kafka_q_t *txn_init_rkq;
519 rd_kafka_q_t *q;
568 rd_kafka_q_t *q; /**< Queue served by background thread. */
967 rd_kafka_poll_cb (rd_kafka_t *rk, rd_kafka_q_t *rkq, rd_kafka_op_t *rko,
H A Drdkafka_cgrp.h124 rd_kafka_q_t *rkcg_q; /* Application poll queue */
125 rd_kafka_q_t *rkcg_ops; /* Manager ops queue */
126 rd_kafka_q_t *rkcg_wait_coord_q; /* Ops awaiting coord */
H A Drdkafka_txnmgr.c435 rd_kafka_txn_curr_api_reply (rd_kafka_q_t *rkq,
442 rd_kafka_txn_curr_api_reply (rd_kafka_q_t *rkq, in rd_kafka_txn_curr_api_reply()
1041 rd_kafka_q_t *rkq = arg; in rd_kafka_txn_curr_api_abort_timeout_cb()
1066 rd_kafka_q_t *rkq = arg; in rd_kafka_txn_curr_api_retriable_timeout_cb()
1084 rd_kafka_q_t *rkq = arg; in rd_kafka_txn_curr_api_timeout_cb()
1099 rd_kafka_q_t *rkq = arg; in rd_kafka_txn_curr_api_init_timeout_cb()
1133 rd_kafka_q_t *rkq; in rd_kafka_txn_curr_api_reset()
1189 rd_kafka_q_t *tmpq = NULL; in rd_kafka_txn_curr_api_req()
2133 rd_kafka_q_t *rkq = opaque; in rd_kafka_txn_handle_EndTxn()
2433 rd_kafka_q_t *rkq, in rd_kafka_txn_op_begin_commit()
[all …]
H A Drdkafka_broker.h68 rd_kafka_q_t *rkbmon_q; /**< Queue to enqueue op on. */
100 rd_kafka_q_t *rkb_ops;
582 rd_kafka_q_t *rkq,
/dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/src/
H A Drdkafka_queue.h134 rd_kafka_q_t *rd_kafka_q_keep (rd_kafka_q_t *rkq) { in rd_kafka_q_keep()
142 rd_kafka_q_t *rd_kafka_q_keep_nolock (rd_kafka_q_t *rkq) { in rd_kafka_q_keep_nolock()
255 void rd_kafka_q_fwd_set0 (rd_kafka_q_t *srcq, rd_kafka_q_t *destq,
265 rd_kafka_q_t *rd_kafka_q_fwd_get (rd_kafka_q_t *rkq, int do_lock) { in rd_kafka_q_fwd_get()
266 rd_kafka_q_t *fwdq; in rd_kafka_q_fwd_get()
347 rd_kafka_q_t *fwdq; in rd_kafka_q_yield()
413 rd_kafka_q_t *fwdq; in rd_kafka_q_enq1()
530 int rd_kafka_q_concat0 (rd_kafka_q_t *rkq, rd_kafka_q_t *srcq, int do_lock) { in rd_kafka_q_concat0()
592 void rd_kafka_q_prepend0 (rd_kafka_q_t *rkq, rd_kafka_q_t *srcq, in rd_kafka_q_prepend0()
832 int rd_kafka_q_move_cnt (rd_kafka_q_t *dstq, rd_kafka_q_t *srcq,
[all …]
H A Drdkafka_queue.c127 void rd_kafka_q_fwd_set0 (rd_kafka_q_t *srcq, rd_kafka_q_t *destq, in rd_kafka_q_fwd_set0()
160 rd_kafka_q_t *fwdq; in rd_kafka_q_purge0()
209 rd_kafka_q_t *fwdq; in rd_kafka_q_purge_toppar_version()
250 int rd_kafka_q_move_cnt (rd_kafka_q_t *dstq, rd_kafka_q_t *srcq, in rd_kafka_q_move_cnt()
348 rd_kafka_q_t *fwdq; in rd_kafka_q_pop_serve()
456 rd_kafka_q_t localq; in rd_kafka_q_serve()
457 rd_kafka_q_t *fwdq; in rd_kafka_q_serve()
572 rd_kafka_q_t *fwdq; in rd_kafka_q_serve_rkmessages()
698 rd_kafka_q_t *rkq; in rd_kafka_queue_new()
754 rd_kafka_q_t *rkq; in rd_kafka_set_log_queue()
[all …]
H A Drdkafka_op.h38 typedef struct rd_kafka_q_s rd_kafka_q_t;
47 rd_kafka_q_t *q;
220 rd_kafka_q_t *rkq,
655 void rd_kafka_q_op_err (rd_kafka_q_t *rkq, rd_kafka_resp_err_t err,
658 void rd_kafka_consumer_err (rd_kafka_q_t *rkq, int32_t broker_id,
663 rd_kafka_op_t *rd_kafka_op_req0 (rd_kafka_q_t *destq,
664 rd_kafka_q_t *recvq,
667 rd_kafka_op_t *rd_kafka_op_req (rd_kafka_q_t *destq,
675 rd_kafka_q_t *rkq, rd_kafka_op_t *rko)
694 rd_kafka_q_t *rkq,
[all …]
H A Drdkafka_op.c447 void rd_kafka_q_op_err (rd_kafka_q_t *rkq, rd_kafka_resp_err_t err, in rd_kafka_q_op_err()
479 void rd_kafka_consumer_err (rd_kafka_q_t *rkq, int32_t broker_id, in rd_kafka_consumer_err()
600 rd_kafka_op_t *rd_kafka_op_req0 (rd_kafka_q_t *destq, in rd_kafka_op_req0()
601 rd_kafka_q_t *recvq, in rd_kafka_op_req0()
624 rd_kafka_op_t *rd_kafka_op_req (rd_kafka_q_t *destq, in rd_kafka_op_req()
627 rd_kafka_q_t *recvq; in rd_kafka_op_req()
643 rd_kafka_op_t *rd_kafka_op_req2 (rd_kafka_q_t *destq, rd_kafka_op_type_t type) { in rd_kafka_op_req2()
685 rd_kafka_op_res_t rd_kafka_op_call (rd_kafka_t *rk, rd_kafka_q_t *rkq, in rd_kafka_op_call()
778 rd_kafka_q_t *rkq, in rd_kafka_op_throttle_time()
808 rd_kafka_op_handle_std (rd_kafka_t *rk, rd_kafka_q_t *rkq, in rd_kafka_op_handle_std()
[all …]
H A Drdkafka_int.h224 rd_kafka_q_t *rk_rep; /* kafka -> application reply queue */
225 rd_kafka_q_t *rk_ops; /* any -> rdkafka main thread ops */
260 rd_kafka_q_t *rk_logq; /* Log queue if `log.queue` set */
455 rd_kafka_q_t *txn_init_rkq;
518 rd_kafka_q_t *q;
567 rd_kafka_q_t *q; /**< Queue served by background thread. */
966 rd_kafka_poll_cb (rd_kafka_t *rk, rd_kafka_q_t *rkq, rd_kafka_op_t *rko,
H A Drdkafka_cgrp.h124 rd_kafka_q_t *rkcg_q; /* Application poll queue */
125 rd_kafka_q_t *rkcg_ops; /* Manager ops queue */
126 rd_kafka_q_t *rkcg_wait_coord_q; /* Ops awaiting coord */
H A Drdkafka_txnmgr.c435 rd_kafka_txn_curr_api_reply (rd_kafka_q_t *rkq,
442 rd_kafka_txn_curr_api_reply (rd_kafka_q_t *rkq,
1041 rd_kafka_q_t *rkq = arg;
1066 rd_kafka_q_t *rkq = arg;
1084 rd_kafka_q_t *rkq = arg;
1099 rd_kafka_q_t *rkq = arg;
1133 rd_kafka_q_t *rkq;
1189 rd_kafka_q_t *tmpq = NULL;
2126 rd_kafka_q_t *rkq = opaque;
2426 rd_kafka_q_t *rkq,
[all …]
H A Drdkafka_broker.h68 rd_kafka_q_t *rkbmon_q; /**< Queue to enqueue op on. */
100 rd_kafka_q_t *rkb_ops;
582 rd_kafka_q_t *rkq,
/dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/src/
H A Drdkafka_queue.h125 rd_kafka_q_t *rd_kafka_q_keep (rd_kafka_q_t *rkq) { in rd_kafka_q_keep()
133 rd_kafka_q_t *rd_kafka_q_keep_nolock (rd_kafka_q_t *rkq) { in rd_kafka_q_keep_nolock()
246 void rd_kafka_q_fwd_set0 (rd_kafka_q_t *srcq, rd_kafka_q_t *destq,
256 rd_kafka_q_t *rd_kafka_q_fwd_get (rd_kafka_q_t *rkq, int do_lock) { in rd_kafka_q_fwd_get()
257 rd_kafka_q_t *fwdq; in rd_kafka_q_fwd_get()
337 rd_kafka_q_t *fwdq; in rd_kafka_q_yield()
403 rd_kafka_q_t *fwdq; in rd_kafka_q_enq1()
503 int rd_kafka_q_concat0 (rd_kafka_q_t *rkq, rd_kafka_q_t *srcq, int do_lock) { in rd_kafka_q_concat0()
564 void rd_kafka_q_prepend0 (rd_kafka_q_t *rkq, rd_kafka_q_t *srcq, in rd_kafka_q_prepend0()
783 int rd_kafka_q_move_cnt (rd_kafka_q_t *dstq, rd_kafka_q_t *srcq,
[all …]
H A Drdkafka_queue.c127 void rd_kafka_q_fwd_set0 (rd_kafka_q_t *srcq, rd_kafka_q_t *destq, in rd_kafka_q_fwd_set0()
160 rd_kafka_q_t *fwdq; in rd_kafka_q_purge0()
207 rd_kafka_q_t *fwdq; in rd_kafka_q_purge_toppar_version()
247 int rd_kafka_q_move_cnt (rd_kafka_q_t *dstq, rd_kafka_q_t *srcq, in rd_kafka_q_move_cnt()
342 rd_kafka_q_t *fwdq; in rd_kafka_q_pop_serve()
448 rd_kafka_q_t localq; in rd_kafka_q_serve()
449 rd_kafka_q_t *fwdq; in rd_kafka_q_serve()
538 rd_kafka_q_t *fwdq; in rd_kafka_q_serve_rkmessages()
651 rd_kafka_q_t *rkq; in rd_kafka_queue_new()
709 rd_kafka_q_t *rkq; in rd_kafka_set_log_queue()
[all …]
H A Drdkafka_op.h38 typedef struct rd_kafka_q_s rd_kafka_q_t; typedef
47 rd_kafka_q_t *q;
198 rd_kafka_q_t *rkq,
532 void rd_kafka_q_op_err (rd_kafka_q_t *rkq, rd_kafka_op_type_t optype,
536 rd_kafka_op_t *rd_kafka_op_req0 (rd_kafka_q_t *destq,
537 rd_kafka_q_t *recvq,
540 rd_kafka_op_t *rd_kafka_op_req (rd_kafka_q_t *destq,
543 rd_kafka_op_t *rd_kafka_op_req2 (rd_kafka_q_t *destq, rd_kafka_op_type_t type);
547 rd_kafka_q_t *rkq, rd_kafka_op_t *rko)
566 rd_kafka_q_t *rkq,
[all …]
H A Drdkafka_op.c389 void rd_kafka_q_op_err (rd_kafka_q_t *rkq, rd_kafka_op_type_t optype, in rd_kafka_q_op_err()
474 rd_kafka_op_t *rd_kafka_op_req0 (rd_kafka_q_t *destq, in rd_kafka_op_req0()
475 rd_kafka_q_t *recvq, in rd_kafka_op_req0()
498 rd_kafka_op_t *rd_kafka_op_req (rd_kafka_q_t *destq, in rd_kafka_op_req()
501 rd_kafka_q_t *recvq; in rd_kafka_op_req()
517 rd_kafka_op_t *rd_kafka_op_req2 (rd_kafka_q_t *destq, rd_kafka_op_type_t type) { in rd_kafka_op_req2()
541 rd_kafka_op_res_t rd_kafka_op_call (rd_kafka_t *rk, rd_kafka_q_t *rkq, in rd_kafka_op_call()
634 rd_kafka_q_t *rkq, in rd_kafka_op_throttle_time()
663 rd_kafka_op_handle_std (rd_kafka_t *rk, rd_kafka_q_t *rkq, in rd_kafka_op_handle_std()
702 rd_kafka_op_handle (rd_kafka_t *rk, rd_kafka_q_t *rkq, rd_kafka_op_t *rko, in rd_kafka_op_handle()
H A Drdkafka_cgrp.h121 rd_kafka_q_t *rkcg_q; /* Application poll queue */
122 rd_kafka_q_t *rkcg_ops; /* Manager ops queue */
123 rd_kafka_q_t *rkcg_wait_coord_q; /* Ops awaiting coord */
H A Drdkafka_txnmgr.c389 rd_kafka_txn_curr_api_reply (rd_kafka_q_t *rkq, in rd_kafka_txn_curr_api_reply()
895 rd_kafka_q_t *rkq = arg; in rd_kafka_txn_curr_api_abort_timeout_cb()
918 rd_kafka_q_t *rkq = arg; in rd_kafka_txn_curr_api_retriable_timeout_cb()
936 rd_kafka_q_t *rkq = arg; in rd_kafka_txn_curr_api_timeout_cb()
951 rd_kafka_q_t *rkq = arg; in rd_kafka_txn_curr_api_init_timeout_cb()
980 rd_kafka_q_t *rkq; in rd_kafka_txn_curr_api_reset()
1031 rd_kafka_q_t *tmpq = NULL; in rd_kafka_txn_curr_api_req()
1134 rd_kafka_q_t *rkq, in rd_kafka_txn_op_init_transactions()
1893 rd_kafka_q_t *rkq = opaque; in rd_kafka_txn_handle_EndTxn()
2060 rd_kafka_q_t *rkq, in rd_kafka_txn_op_begin_commit()
[all …]
H A Drdkafka_int.h220 rd_kafka_q_t *rk_rep; /* kafka -> application reply queue */
221 rd_kafka_q_t *rk_ops; /* any -> rdkafka main thread ops */
256 rd_kafka_q_t *rk_logq; /* Log queue if `log.queue` set */
447 rd_kafka_q_t *txn_init_rkq;
534 rd_kafka_q_t *q; /**< Queue served by background thread. */
910 rd_kafka_poll_cb (rd_kafka_t *rk, rd_kafka_q_t *rkq, rd_kafka_op_t *rko,
H A Drdkafka_partition.h111 rd_kafka_q_t *rktp_msgq_wakeup_q; /**< Wake-up queue */
120 rd_kafka_q_t *rktp_fetchq; /* Queue of fetched messages
123 rd_kafka_q_t *rktp_ops; /* * -> Main thread */
492 rd_kafka_q_t *fwdq,
H A Drdkafka_broker.h67 rd_kafka_q_t *rkbmon_q; /**< Queue to enqueue op on. */
98 rd_kafka_q_t *rkb_ops;
593 rd_kafka_q_t *rkq,

123