Home
last modified time | relevance | path

Searched refs:rd_interval_immediate (Results 1 – 11 of 11) sorted by relevance

/dports/net/librdkafka/librdkafka-1.8.2/src/
H A Drdinterval.h64 #define rd_interval_immediate(ri,interval_us,now) \ macro
H A Drdkafka_broker.c2500 rd_interval_immediate(&rkb->rkb_ApiVersion_fail_intvl, 0, 0) > 0) { in rd_kafka_broker_connect_done()
4159 rd_ts_t new_intvl = rd_interval_immediate(&rktp->rktp_new_lease_intvl, in rd_kafka_fetch_preferred_replica_handle()
4176 if (rd_interval_immediate(&rktp->rktp_new_lease_log_intvl, in rd_kafka_fetch_preferred_replica_handle()
4209 if (rd_interval_immediate(&rktp->rktp_metadata_intvl, in rd_kafka_fetch_preferred_replica_handle()
H A Drdkafka_topic.c1476 rd_interval_immediate(&rkt->rkt_desp_refresh_intvl, in rd_kafka_topic_scan_all()
H A Drdkafka_cgrp.c5251 if (rd_interval_immediate(&rkcg->rkcg_join_intvl, in rd_kafka_cgrp_join_state_serve()
5328 if (rd_interval_immediate(&rkcg->rkcg_coord_query_intvl, in rd_kafka_cgrp_serve()
/dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/src/
H A Drdinterval.h64 #define rd_interval_immediate(ri,interval_us,now) \ macro
H A Drdkafka_broker.c2258 rd_interval_immediate(&rkb->rkb_ApiVersion_fail_intvl, 0, 0) > 0) { in rd_kafka_broker_connect_done()
3829 rd_ts_t new_intvl = rd_interval_immediate(&rktp->rktp_new_lease_intvl, in rd_kafka_fetch_preferred_replica_handle()
3846 if (rd_interval_immediate(&rktp->rktp_new_lease_log_intvl, in rd_kafka_fetch_preferred_replica_handle()
3879 if (rd_interval_immediate(&rktp->rktp_metadata_intvl, in rd_kafka_fetch_preferred_replica_handle()
H A Drdkafka_cgrp.c3278 if (rd_interval_immediate(&rkcg->rkcg_join_intvl, in rd_kafka_cgrp_join_state_serve()
3351 if (rd_interval_immediate(&rkcg->rkcg_coord_query_intvl, in rd_kafka_cgrp_serve()
/dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/src/
H A Drdinterval.h64 #define rd_interval_immediate(ri,interval_us,now) \
H A Drdkafka_broker.c2487 rd_interval_immediate(&rkb->rkb_ApiVersion_fail_intvl, 0, 0) > 0) { in rd_kafka_broker_connect_done()
4104 rd_ts_t new_intvl = rd_interval_immediate(&rktp->rktp_new_lease_intvl, in rd_kafka_fetch_preferred_replica_handle()
4121 if (rd_interval_immediate(&rktp->rktp_new_lease_log_intvl, in rd_kafka_fetch_preferred_replica_handle()
4154 if (rd_interval_immediate(&rktp->rktp_metadata_intvl, in rd_kafka_fetch_preferred_replica_handle()
H A Drdkafka_topic.c1476 rd_interval_immediate(&rkt->rkt_desp_refresh_intvl,
H A Drdkafka_cgrp.c4989 if (rd_interval_immediate(&rkcg->rkcg_join_intvl, in rd_kafka_cgrp_join_state_serve()
5066 if (rd_interval_immediate(&rkcg->rkcg_coord_query_intvl, in rd_kafka_cgrp_serve()