Searched refs:rd_interval_immediate (Results 1 – 11 of 11) sorted by relevance
/dports/net/librdkafka/librdkafka-1.8.2/src/ |
H A D | rdinterval.h | 64 #define rd_interval_immediate(ri,interval_us,now) \ macro
|
H A D | rdkafka_broker.c | 2500 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 D | rdkafka_topic.c | 1476 rd_interval_immediate(&rkt->rkt_desp_refresh_intvl, in rd_kafka_topic_scan_all()
|
H A D | rdkafka_cgrp.c | 5251 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 D | rdinterval.h | 64 #define rd_interval_immediate(ri,interval_us,now) \ macro
|
H A D | rdkafka_broker.c | 2258 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 D | rdkafka_cgrp.c | 3278 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 D | rdinterval.h | 64 #define rd_interval_immediate(ri,interval_us,now) \
|
H A D | rdkafka_broker.c | 2487 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 D | rdkafka_topic.c | 1476 rd_interval_immediate(&rkt->rkt_desp_refresh_intvl,
|
H A D | rdkafka_cgrp.c | 4989 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()
|