| /dports/net/librdkafka/librdkafka-1.8.2/src/ |
| H A D | rdkafka_offset.c | 260 rd_kafka_offset_file_commit (rd_kafka_toppar_t *rktp) { in rd_kafka_offset_file_commit()
349 rd_kafka_toppar_t *rktp, in rd_kafka_commit0()
502 rd_kafka_toppar_t *rktp; in rd_kafka_offset_broker_commit_cb() local
650 rd_kafka_toppar_t *rktp; in rd_kafka_offset_store() local
679 rd_kafka_toppar_t *rktp; in rd_kafka_offsets_store() local
731 rd_kafka_toppar_t *rktp = rko->rko_rktp; in rd_kafka_offset_reset_op_cb() local
884 rd_kafka_toppar_t *rktp = arg; in rd_kafka_offset_sync_tmr_cb() local
993 void rd_kafka_offset_store_term (rd_kafka_toppar_t *rktp, in rd_kafka_offset_store_term()
1087 rd_kafka_toppar_t *rktp = arg; in rd_kafka_offset_auto_commit_tmr_cb() local
1092 rd_kafka_toppar_t *rktp = arg; in rd_kafka_offset_query_tmr_cb() local
[all …]
|
| H A D | rdkafka_partition.c | 84 rd_kafka_toppar_t *rktp = opaque; in rd_kafka_toppar_lag_handle_Offset() local
185 rd_kafka_toppar_t *rktp = arg; in rd_kafka_toppar_consumer_lag_tmr_cb() local
217 rd_kafka_toppar_t *rktp; in rd_kafka_toppar_new0() local
405 rd_kafka_toppar_t *rktp; in rd_kafka_toppar_get0() local
434 rd_kafka_toppar_t *rktp; in rd_kafka_toppar_get2() local
477 rd_kafka_toppar_t *rktp; in rd_kafka_toppar_get_avail() local
555 rd_kafka_toppar_t *rktp; in rd_kafka_toppar_desired_get() local
637 rd_kafka_toppar_t *rktp; in rd_kafka_toppar_desired_add() local
2149 rd_kafka_toppar_t *rktp = NULL; in rd_kafka_toppar_op_serve() local
2530 rd_kafka_toppar_t *rktp; in rd_kafka_toppars_pause_resume() local
[all …]
|
| H A D | rdkafka_topic.c | 577 int rd_kafka_toppar_broker_update (rd_kafka_toppar_t *rktp, in rd_kafka_toppar_broker_update()
637 rd_kafka_toppar_t *rktp; in rd_kafka_toppar_leader_update() local
708 int rd_kafka_toppar_delegate_to_leader (rd_kafka_toppar_t *rktp) { in rd_kafka_toppar_delegate_to_leader()
754 rd_kafka_toppar_t *rktp; in rd_kafka_topic_partition_cnt_update() local
892 rd_kafka_toppar_t *rktp; in rd_kafka_topic_propagate_notexists() local
1221 rd_kafka_toppar_t *rktp; in rd_kafka_topic_metadata_update() local
1286 rd_kafka_toppar_t *rktp; in rd_kafka_topic_get_all_partitions() local
1314 rd_kafka_toppar_t *rktp; in rd_kafka_topic_partitions_remove() local
1383 rd_kafka_toppar_t *rktp) { in rd_kafka_toppar_needs_query()
1426 rd_kafka_toppar_t *rktp; in rd_kafka_topic_scan_all() local
[all …]
|
| H A D | rdkafka_txnmgr.h | 74 rd_kafka_txn_toppar_may_send_msg (rd_kafka_toppar_t *rktp) { in rd_kafka_txn_toppar_may_send_msg()
99 void rd_kafka_txn_add_partition (rd_kafka_toppar_t *rktp) { in rd_kafka_txn_add_partition()
|
| H A D | rdkafka_assignment.c | 142 rd_kafka_toppar_t *rktp = rktpar->_private; /* May be NULL */ in rd_kafka_assignment_apply_offsets() local
322 rd_kafka_toppar_t *rktp = rktpar->_private; /* Borrow ref */ in rd_kafka_assignment_serve_removals() local
444 rd_kafka_toppar_t *rktp = rktpar->_private; /* Borrow ref */ in rd_kafka_assignment_serve_pending() local
871 rd_kafka_toppar_t *rktp) { in rd_kafka_assignment_partition_stopped()
|
| H A D | rdkafka_offset.h | 46 void rd_kafka_offset_store0 (rd_kafka_toppar_t *rktp, int64_t offset, in rd_kafka_offset_store0()
|
| H A D | rdkafka_idempotence.c | 649 void rd_kafka_idemp_drain_toppar (rd_kafka_toppar_t *rktp, in rd_kafka_idemp_drain_toppar()
669 rd_kafka_toppar_t *rktp) { in rd_kafka_idemp_inflight_toppar_sub()
690 rd_kafka_toppar_t *rktp) { in rd_kafka_idemp_inflight_toppar_add()
|
| H A D | rdkafka_msgset_reader.c | 220 rd_kafka_toppar_t *rktp, in rd_kafka_msgset_reader_init()
267 rd_kafka_toppar_t *rktp = msetr->msetr_rktp; in rd_kafka_msgset_reader_decompress() local
546 rd_kafka_toppar_t *rktp = msetr->msetr_rktp; in rd_kafka_msgset_reader_msg_v0_1() local
725 rd_kafka_toppar_t *rktp = msetr->msetr_rktp; in rd_kafka_msgset_reader_msg_v2() local
956 rd_kafka_toppar_t *rktp = msetr->msetr_rktp; in rd_kafka_msgset_reader_msgs_v2() local
1017 rd_kafka_toppar_t *rktp = msetr->msetr_rktp; in rd_kafka_msgset_reader_v2() local
1185 rd_kafka_toppar_t *rktp = msetr->msetr_rktp; in rd_kafka_msgset_reader_peek_msg_version() local
1334 rd_kafka_toppar_t *rktp = msetr->msetr_rktp; in rd_kafka_msgset_reader_run() local
1436 rd_kafka_toppar_t *rktp, in rd_kafka_msgset_parse()
|
| H A D | rdkafka_msgset_writer.c | 107 rd_kafka_toppar_t *rktp = msetw->msetw_rktp; in rd_kafka_msgset_writer_select_MsgVersion() local
498 rd_kafka_toppar_t *rktp, in rd_kafka_msgset_writer_init()
837 rd_kafka_toppar_t *rktp = msetw->msetw_rktp; in rd_kafka_msgset_writer_write_msgq() local
982 rd_kafka_toppar_t *rktp = msetw->msetw_rktp; in rd_kafka_msgset_writer_compress_gzip() local
1078 rd_kafka_toppar_t *rktp = msetw->msetw_rktp; in rd_kafka_msgset_writer_compress_snappy() local
1377 rd_kafka_toppar_t *rktp = msetw->msetw_rktp; in rd_kafka_msgset_writer_finalize() local
1457 rd_kafka_toppar_t *rktp, in rd_kafka_msgset_create_ProduceRequest()
|
| /dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/src/ |
| H A D | rdkafka_offset.c | 146 static int rd_kafka_offset_file_open (rd_kafka_toppar_t *rktp) { in rd_kafka_offset_file_open()
236 static int rd_kafka_offset_file_sync (rd_kafka_toppar_t *rktp) { in rd_kafka_offset_file_sync()
262 rd_kafka_offset_file_commit (rd_kafka_toppar_t *rktp) { in rd_kafka_offset_file_commit()
351 rd_kafka_toppar_t *rktp, in rd_kafka_commit0()
505 rd_kafka_toppar_t *rktp; in rd_kafka_offset_broker_commit_cb() local
735 rd_kafka_toppar_t *rktp = in rd_kafka_offset_reset_op_cb() local
882 rd_kafka_toppar_t *rktp = arg; in rd_kafka_offset_sync_tmr_cb() local
990 void rd_kafka_offset_store_term (rd_kafka_toppar_t *rktp, in rd_kafka_offset_store_term()
1084 rd_kafka_toppar_t *rktp = arg; in rd_kafka_offset_auto_commit_tmr_cb() local
1089 rd_kafka_toppar_t *rktp = arg; in rd_kafka_offset_query_tmr_cb() local
[all …]
|
| H A D | rdkafka_partition.c | 58 rd_kafka_toppar_version_new_barrier0 (rd_kafka_toppar_t *rktp, in rd_kafka_toppar_version_new_barrier0()
68 #define rd_kafka_toppar_version_new_barrier(rktp) \ argument
184 rd_kafka_toppar_t *rktp = arg; in rd_kafka_toppar_consumer_lag_tmr_cb() local
198 rd_kafka_toppar_t *rktp; in rd_kafka_toppar_new0() local
605 rd_kafka_toppar_t *rktp; in rd_kafka_toppar_desired_add() local
1730 void rd_kafka_toppar_seek (rd_kafka_toppar_t *rktp, in rd_kafka_toppar_seek()
2095 rd_kafka_toppar_t *rktp = NULL; in rd_kafka_toppar_op_serve() local
2264 static void rd_kafka_toppar_op (rd_kafka_toppar_t *rktp, in rd_kafka_toppar_op()
2475 rd_kafka_toppar_t *rktp; in rd_kafka_toppars_pause_resume() local
3373 rd_kafka_toppar_t *rktp; in rd_kafka_topic_partition_list_get_topics() local
[all …]
|
| H A D | rdkafka_txnmgr.h | 74 rd_kafka_txn_toppar_may_send_msg (rd_kafka_toppar_t *rktp) { in rd_kafka_txn_toppar_may_send_msg()
99 void rd_kafka_txn_add_partition (rd_kafka_toppar_t *rktp) { in rd_kafka_txn_add_partition()
|
| H A D | rdkafka_topic.c | 498 int rd_kafka_toppar_broker_update (rd_kafka_toppar_t *rktp, in rd_kafka_toppar_broker_update()
558 rd_kafka_toppar_t *rktp; in rd_kafka_toppar_leader_update() local
620 int rd_kafka_toppar_delegate_to_leader (rd_kafka_toppar_t *rktp) { in rd_kafka_toppar_delegate_to_leader()
667 rd_kafka_toppar_t *rktp; in rd_kafka_topic_partition_cnt_update() local
1053 rd_kafka_toppar_t *rktp; in rd_kafka_topic_metadata_update() local
1170 rd_kafka_toppar_t *rktp = rd_kafka_toppar_s2i(s_rktp); in rd_kafka_topic_partitions_remove() local
1192 rd_kafka_toppar_t *rktp = rd_kafka_toppar_s2i(s_rktp); in rd_kafka_topic_partitions_remove() local
1228 rd_kafka_toppar_t *rktp) { in rd_kafka_toppar_needs_query()
1271 rd_kafka_toppar_t *rktp; in rd_kafka_topic_scan_all() local
1404 rd_kafka_toppar_t *rktp; in rd_kafka_topic_partition_available() local
|
| H A D | rdkafka_op.c | 117 rd_kafka_toppar_t *rktp = rd_kafka_toppar_s2i(rko->rko_rktp); in rd_kafka_op_print() local
391 rd_kafka_toppar_t *rktp, int64_t offset, in rd_kafka_q_op_err()
560 rd_kafka_op_new_ctrl_msg (rd_kafka_toppar_t *rktp, in rd_kafka_op_new_ctrl_msg()
588 rd_kafka_toppar_t *rktp, in rd_kafka_op_new_fetch_msg()
737 rd_kafka_toppar_t *rktp; in rd_kafka_op_offset_store() local
|
| H A D | rdkafka_offset.h | 46 void rd_kafka_offset_store0 (rd_kafka_toppar_t *rktp, int64_t offset, in rd_kafka_offset_store0()
|
| H A D | rdkafka_idempotence.c | 580 void rd_kafka_idemp_drain_toppar (rd_kafka_toppar_t *rktp, in rd_kafka_idemp_drain_toppar()
600 rd_kafka_toppar_t *rktp) { in rd_kafka_idemp_inflight_toppar_sub()
621 rd_kafka_toppar_t *rktp) { in rd_kafka_idemp_inflight_toppar_add()
|
| H A D | rdkafka_msgset_writer.c | 107 rd_kafka_toppar_t *rktp = msetw->msetw_rktp; in rd_kafka_msgset_writer_select_MsgVersion() local
498 rd_kafka_toppar_t *rktp, in rd_kafka_msgset_writer_init()
836 rd_kafka_toppar_t *rktp = msetw->msetw_rktp; in rd_kafka_msgset_writer_write_msgq() local
979 rd_kafka_toppar_t *rktp = msetw->msetw_rktp; in rd_kafka_msgset_writer_compress_gzip() local
1075 rd_kafka_toppar_t *rktp = msetw->msetw_rktp; in rd_kafka_msgset_writer_compress_snappy() local
1374 rd_kafka_toppar_t *rktp = msetw->msetw_rktp; in rd_kafka_msgset_writer_finalize() local
1454 rd_kafka_toppar_t *rktp, in rd_kafka_msgset_create_ProduceRequest()
|
| H A D | rdkafka_msgset_reader.c | 219 rd_kafka_toppar_t *rktp, in rd_kafka_msgset_reader_init()
265 rd_kafka_toppar_t *rktp = msetr->msetr_rktp; in rd_kafka_msgset_reader_decompress() local
542 rd_kafka_toppar_t *rktp = msetr->msetr_rktp; in rd_kafka_msgset_reader_msg_v0_1() local
718 rd_kafka_toppar_t *rktp = msetr->msetr_rktp; in rd_kafka_msgset_reader_msg_v2() local
959 rd_kafka_toppar_t *rktp = msetr->msetr_rktp; in rd_kafka_msgset_reader_v2() local
1159 rd_kafka_toppar_t *rktp = msetr->msetr_rktp; in rd_kafka_msgset_reader_peek_msg_version() local
1308 rd_kafka_toppar_t *rktp = msetr->msetr_rktp; in rd_kafka_msgset_reader_run() local
1410 rd_kafka_toppar_t *rktp, in rd_kafka_msgset_parse()
|
| /dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/src/ |
| H A D | rdkafka_partition.c | 84 rd_kafka_toppar_t *rktp = opaque; in rd_kafka_toppar_lag_handle_Offset() local
185 rd_kafka_toppar_t *rktp = arg; in rd_kafka_toppar_consumer_lag_tmr_cb() local
217 rd_kafka_toppar_t *rktp; in rd_kafka_toppar_new0() local
405 rd_kafka_toppar_t *rktp; in rd_kafka_toppar_get0() local
434 rd_kafka_toppar_t *rktp; in rd_kafka_toppar_get2() local
477 rd_kafka_toppar_t *rktp; in rd_kafka_toppar_get_avail() local
555 rd_kafka_toppar_t *rktp; in rd_kafka_toppar_desired_get() local
637 rd_kafka_toppar_t *rktp; in rd_kafka_toppar_desired_add() local
2134 rd_kafka_toppar_t *rktp = NULL; in rd_kafka_toppar_op_serve() local
2515 rd_kafka_toppar_t *rktp; in rd_kafka_toppars_pause_resume() local
[all …]
|
| H A D | rdlist.h | 96 * rd_list_add(), instead pass NULL to rd_list_add() and use the returned in rd_kafka_offset_file_close()
147 * This is a slow O(n) + memmove operation. in rd_kafka_offset_file_open()
178 * @returns the number of elements removed. in rd_kafka_offset_file_read()
179 * in rd_kafka_offset_file_read()
180 * @sa rd_list_remove() in rd_kafka_offset_file_read()
235 * Returns the number of elements in list. in rd_kafka_offset_file_sync()
236 */ in rd_kafka_offset_file_sync()
237 static RD_INLINE RD_UNUSED int rd_list_cnt (const rd_list_t *rl) { in rd_kafka_offset_file_sync()
261 * @brief Find element using comparator in rd_kafka_offset_file_commit()
262 * in rd_kafka_offset_file_commit()
[all …]
|
| H A D | rdkafka_txnmgr.h | 74 rd_kafka_txn_toppar_may_send_msg (rd_kafka_toppar_t *rktp) { in rd_kafka_txn_toppar_may_send_msg()
99 void rd_kafka_txn_add_partition (rd_kafka_toppar_t *rktp) { in rd_kafka_txn_add_partition()
|
| H A D | rdkafka_assignment.c | 142 rd_kafka_toppar_t *rktp = rktpar->_private; /* May be NULL */ in rd_kafka_assignment_apply_offsets() local
322 rd_kafka_toppar_t *rktp = rktpar->_private; /* Borrow ref */ in rd_kafka_assignment_serve_removals() local
444 rd_kafka_toppar_t *rktp = rktpar->_private; /* Borrow ref */ in rd_kafka_assignment_serve_pending() local
871 rd_kafka_toppar_t *rktp) { in rd_kafka_assignment_partition_stopped()
|
| H A D | rdkafka_offset.h | 46 void rd_kafka_offset_store0 (rd_kafka_toppar_t *rktp, int64_t offset, in rd_kafka_offset_store0()
|
| H A D | rdkafka_msgset_reader.c | 220 rd_kafka_toppar_t *rktp, in rd_kafka_msgset_reader_init()
267 rd_kafka_toppar_t *rktp = msetr->msetr_rktp; in rd_kafka_msgset_reader_decompress() local
546 rd_kafka_toppar_t *rktp = msetr->msetr_rktp; in rd_kafka_msgset_reader_msg_v0_1() local
725 rd_kafka_toppar_t *rktp = msetr->msetr_rktp; in rd_kafka_msgset_reader_msg_v2() local
956 rd_kafka_toppar_t *rktp = msetr->msetr_rktp; in rd_kafka_msgset_reader_msgs_v2() local
1017 rd_kafka_toppar_t *rktp = msetr->msetr_rktp; in rd_kafka_msgset_reader_v2() local
1185 rd_kafka_toppar_t *rktp = msetr->msetr_rktp; in rd_kafka_msgset_reader_peek_msg_version() local
1334 rd_kafka_toppar_t *rktp = msetr->msetr_rktp; in rd_kafka_msgset_reader_run() local
1436 rd_kafka_toppar_t *rktp, in rd_kafka_msgset_parse()
|
| H A D | rdkafka_msgset_writer.c | 107 rd_kafka_toppar_t *rktp = msetw->msetw_rktp; in rd_kafka_msgset_writer_select_MsgVersion() local
498 rd_kafka_toppar_t *rktp, in rd_kafka_msgset_writer_init()
837 rd_kafka_toppar_t *rktp = msetw->msetw_rktp; in rd_kafka_msgset_writer_write_msgq() local
982 rd_kafka_toppar_t *rktp = msetw->msetw_rktp; in rd_kafka_msgset_writer_compress_gzip() local
1078 rd_kafka_toppar_t *rktp = msetw->msetw_rktp; in rd_kafka_msgset_writer_compress_snappy() local
1377 rd_kafka_toppar_t *rktp = msetw->msetw_rktp; in rd_kafka_msgset_writer_finalize() local
1457 rd_kafka_toppar_t *rktp, in rd_kafka_msgset_create_ProduceRequest()
|