/dports/net/librdkafka/librdkafka-1.8.2/src/ |
H A D | rdkafka_queue.h | 134 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 D | rdkafka_queue.c | 127 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 D | rdkafka_op.h | 38 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 D | rdkafka_op.c | 447 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 D | rdkafka_int.h | 224 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 D | rdkafka_cgrp.h | 124 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 D | rdkafka_txnmgr.c | 435 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 D | rdkafka_broker.h | 68 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 D | rdkafka_queue.h | 134 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 D | rdkafka_queue.c | 127 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 D | rdkafka_op.h | 38 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 D | rdkafka_op.c | 447 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 D | rdkafka_int.h | 224 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 D | rdkafka_cgrp.h | 124 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 D | rdkafka_txnmgr.c | 435 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 D | rdkafka_broker.h | 68 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 D | rdkafka_queue.h | 125 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 D | rdkafka_queue.c | 127 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 D | rdkafka_op.h | 38 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 D | rdkafka_op.c | 389 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 D | rdkafka_cgrp.h | 121 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 D | rdkafka_txnmgr.c | 389 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 D | rdkafka_int.h | 220 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 D | rdkafka_partition.h | 111 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 D | rdkafka_broker.h | 67 rd_kafka_q_t *rkbmon_q; /**< Queue to enqueue op on. */ 98 rd_kafka_q_t *rkb_ops; 593 rd_kafka_q_t *rkq,
|