Home
last modified time | relevance | path

Searched refs:rd_kafka_rdlock (Results 1 – 25 of 34) sorted by relevance

12

/dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/src/
H A Drdkafka_idempotence.h56 rd_kafka_rdlock(rk); in rd_kafka_idemp_get_pid0()
H A Drdkafka_topic.c163 rd_kafka_rdlock(rk); in rd_kafka_topic_find_fl()
185 rd_kafka_rdlock(rk); in rd_kafka_topic_find0_fl()
624 rd_kafka_rdlock(rktp->rktp_rkt->rkt_rk); in rd_kafka_toppar_delegate_to_leader()
1277 rd_kafka_rdlock(rk); in rd_kafka_topic_scan_all()
1524 rd_kafka_rdlock(rk); in rd_kafka_local_topics_to_list()
H A Drdkafka.c775 rd_kafka_rdlock(rk); in rd_kafka_fatal_error()
1542 rd_kafka_rdlock(rk); in rd_kafka_stats_emit_all()
3805 rd_kafka_rdlock(rk); in rd_kafka_dump0()
3930 rd_kafka_rdlock(rk); in rd_kafka_clusterid()
3975 rd_kafka_rdlock(rk); in rd_kafka_controllerid()
4092 rd_kafka_rdlock(rk); in rd_kafka_purge()
4451 rd_kafka_rdlock(rk); in rd_kafka_list_groups()
4459 rd_kafka_rdlock(rk); in rd_kafka_list_groups()
H A Drdkafka_metadata.c653 rd_kafka_rdlock(rk); in rd_kafka_metadata_topic_match()
707 rd_kafka_rdlock(rk); in rd_kafka_metadata_topic_filter()
H A Drdkafka_txnmgr.c525 rd_kafka_rdlock(rk); in rd_kafka_txn_handle_AddPartitionsToTxn()
1523 rd_kafka_rdlock(rk); in rd_kafka_txn_send_TxnOffsetCommitRequest()
2433 rd_kafka_rdlock(rk); in rd_kafka_txn_handle_FindCoordinator()
H A Drdkafka_int.h592 #define rd_kafka_rdlock(rk) rwlock_rdlock(&(rk)->rk_lock) macro
H A Drdkafka_broker.c1300 rd_kafka_rdlock(rk); in rd_kafka_broker_any_usable()
1391 rd_kafka_rdlock(rk); in rd_kafka_broker_get_async()
1418 rd_kafka_rdlock(rk); in rd_kafka_broker_controller_nowait()
2660 rd_kafka_rdlock(rk); in rd_kafka_broker_map_partitions()
3863 rd_kafka_rdlock(rk); in rd_kafka_fetch_preferred_replica_handle()
5678 rd_kafka_rdlock(rk); in rd_kafka_brokers_add0()
5805 rd_kafka_rdlock(rk); in rd_kafka_all_brokers_wakeup()
H A Drdkafka_cgrp.c377 rd_kafka_rdlock(rkcg->rkcg_rk); in rd_kafka_cgrp_coord_update()
521 rd_kafka_rdlock(rkcg->rkcg_rk); in rd_kafka_cgrp_coord_query()
1221 rd_kafka_rdlock(rk); in rd_kafka_cgrp_metadata_refresh()
/dports/net/librdkafka/librdkafka-1.8.2/src/
H A Drdkafka_idempotence.h56 rd_kafka_rdlock(rk); in rd_kafka_idemp_get_pid0()
H A Drdkafka_txnmgr.h57 rd_kafka_rdlock(rk); in rd_kafka_txn_may_send_msg()
H A Drdkafka_topic.c151 rd_kafka_rdlock(rk); in rd_kafka_topic_find_fl()
172 rd_kafka_rdlock(rk); in rd_kafka_topic_find0_fl()
712 rd_kafka_rdlock(rktp->rktp_rkt->rkt_rk); in rd_kafka_toppar_delegate_to_leader()
1431 rd_kafka_rdlock(rk); in rd_kafka_topic_scan_all()
1735 rd_kafka_rdlock(rk); in rd_kafka_local_topics_to_list()
H A Drdkafka.c808 rd_kafka_rdlock(rk); in rd_kafka_fatal_error()
1638 rd_kafka_rdlock(rk); in rd_kafka_stats_emit_all()
4016 rd_kafka_rdlock(rk); in rd_kafka_dump0()
4132 rd_kafka_rdlock(rk); in rd_kafka_clusterid()
4177 rd_kafka_rdlock(rk); in rd_kafka_controllerid()
4338 rd_kafka_rdlock(rk); in rd_kafka_purge()
4692 rd_kafka_rdlock(rk); in rd_kafka_list_groups()
4700 rd_kafka_rdlock(rk); in rd_kafka_list_groups()
H A Drdkafka_txnmgr.c601 rd_kafka_rdlock(rk); in rd_kafka_txn_handle_AddPartitionsToTxn()
877 rd_kafka_rdlock(rk); in rd_kafka_txn_register_partitions()
1696 rd_kafka_rdlock(rk); in rd_kafka_txn_send_TxnOffsetCommitRequest()
2992 rd_kafka_rdlock(rk); in rd_kafka_txn_handle_FindCoordinator()
H A Drdkafka_metadata.c703 rd_kafka_rdlock(rk); in rd_kafka_metadata_topic_match()
792 rd_kafka_rdlock(rk); in rd_kafka_metadata_topic_filter()
H A Drdkafka_int.h630 #define rd_kafka_rdlock(rk) rwlock_rdlock(&(rk)->rk_lock) macro
H A Drdkafka_broker.c1554 rd_kafka_rdlock(rk); in rd_kafka_broker_any_usable()
1608 rd_kafka_rdlock(rk); in rd_kafka_broker_get_async()
1635 rd_kafka_rdlock(rk); in rd_kafka_broker_controller_nowait()
2944 rd_kafka_rdlock(rk); in rd_kafka_broker_map_partitions()
4193 rd_kafka_rdlock(rk); in rd_kafka_fetch_preferred_replica_handle()
6094 rd_kafka_rdlock(rk); in rd_kafka_brokers_add0()
6250 rd_kafka_rdlock(rk); in rd_kafka_all_brokers_wakeup()
H A Drdkafka_msg.c78 rd_kafka_rdlock(rk); in rd_kafka_check_produce()
96 rd_kafka_rdlock(rk); in rd_kafka_check_produce()
/dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/src/
H A Drdkafka_idempotence.h56 rd_kafka_rdlock(rk); in rd_kafka_idemp_get_pid0()
H A Drdkafka_txnmgr.h57 rd_kafka_rdlock(rk); in rd_kafka_txn_may_send_msg()
H A Drdkafka_topic.c151 rd_kafka_rdlock(rk);
172 rd_kafka_rdlock(rk);
712 rd_kafka_rdlock(rktp->rktp_rkt->rkt_rk);
1431 rd_kafka_rdlock(rk);
1735 rd_kafka_rdlock(rk);
H A Drdkafka.c808 rd_kafka_rdlock(rk);
1638 rd_kafka_rdlock(rk);
4015 rd_kafka_rdlock(rk);
4131 rd_kafka_rdlock(rk);
4176 rd_kafka_rdlock(rk);
4326 rd_kafka_rdlock(rk);
4680 rd_kafka_rdlock(rk);
4688 rd_kafka_rdlock(rk);
H A Drdkafka_txnmgr.c601 rd_kafka_rdlock(rk);
877 rd_kafka_rdlock(rk);
1696 rd_kafka_rdlock(rk);
2983 rd_kafka_rdlock(rk);
H A Drdkafka_metadata.c703 rd_kafka_rdlock(rk);
792 rd_kafka_rdlock(rk);
H A Drdkafka_int.h629 #define rd_kafka_rdlock(rk) rwlock_rdlock(&(rk)->rk_lock) macro
H A Drdkafka_broker.c1541 rd_kafka_rdlock(rk); in rd_kafka_broker_any_usable()
1595 rd_kafka_rdlock(rk); in rd_kafka_broker_get_async()
1622 rd_kafka_rdlock(rk); in rd_kafka_broker_controller_nowait()
2896 rd_kafka_rdlock(rk); in rd_kafka_broker_map_partitions()
4138 rd_kafka_rdlock(rk); in rd_kafka_fetch_preferred_replica_handle()
6039 rd_kafka_rdlock(rk); in rd_kafka_brokers_add0()
6195 rd_kafka_rdlock(rk); in rd_kafka_all_brokers_wakeup()

12