Home
last modified time | relevance | path

Searched refs:rk_curr_msgs (Results 1 – 6 of 6) sorted by relevance

/dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/src/
H A Drdkafka_int.h514 } rk_curr_msgs; member
620 rk->rk_curr_msgs.max_cnt || in rd_kafka_curr_msgs_add()
631 cnd_wait(&rk->rk_curr_msgs.cnd, &rk->rk_curr_msgs.lock); in rd_kafka_curr_msgs_add()
638 rk->rk_curr_msgs.cnt += cnt; in rd_kafka_curr_msgs_add()
666 (rk->rk_curr_msgs.cnt >= rk->rk_curr_msgs.max_cnt && in rd_kafka_curr_msgs_sub()
667 rk->rk_curr_msgs.cnt - cnt < rk->rk_curr_msgs.max_cnt) || in rd_kafka_curr_msgs_sub()
668 (rk->rk_curr_msgs.size >= rk->rk_curr_msgs.max_size && in rd_kafka_curr_msgs_sub()
669 rk->rk_curr_msgs.size - size < rk->rk_curr_msgs.max_size)) in rd_kafka_curr_msgs_sub()
672 rk->rk_curr_msgs.cnt -= cnt; in rd_kafka_curr_msgs_sub()
690 *cntp = rk->rk_curr_msgs.cnt; in rd_kafka_curr_msgs_get()
[all …]
H A Drdkafka.c941 cnd_destroy(&rk->rk_curr_msgs.cnd); in rd_kafka_destroy_final()
942 mtx_destroy(&rk->rk_curr_msgs.lock); in rd_kafka_destroy_final()
1566 rk->rk_curr_msgs.max_cnt, rk->rk_curr_msgs.max_size, in rd_kafka_stats_emit_all()
2148 mtx_init(&rk->rk_curr_msgs.lock, mtx_plain); in rd_kafka_new()
2149 cnd_init(&rk->rk_curr_msgs.cnd); in rd_kafka_new()
2150 rk->rk_curr_msgs.max_cnt = in rd_kafka_new()
2155 rk->rk_curr_msgs.max_size = SIZE_MAX; in rd_kafka_new()
2159 rk->rk_curr_msgs.max_size); in rd_kafka_new()
2161 rk->rk_curr_msgs.max_size = in rd_kafka_new()
/dports/net/librdkafka/librdkafka-1.8.2/src/
H A Drdkafka_int.h545 } rk_curr_msgs; member
658 rk->rk_curr_msgs.max_cnt || in rd_kafka_curr_msgs_add()
669 cnd_wait(&rk->rk_curr_msgs.cnd, &rk->rk_curr_msgs.lock); in rd_kafka_curr_msgs_add()
676 rk->rk_curr_msgs.cnt += cnt; in rd_kafka_curr_msgs_add()
704 (rk->rk_curr_msgs.cnt >= rk->rk_curr_msgs.max_cnt && in rd_kafka_curr_msgs_sub()
705 rk->rk_curr_msgs.cnt - cnt < rk->rk_curr_msgs.max_cnt) || in rd_kafka_curr_msgs_sub()
706 (rk->rk_curr_msgs.size >= rk->rk_curr_msgs.max_size && in rd_kafka_curr_msgs_sub()
707 rk->rk_curr_msgs.size - size < rk->rk_curr_msgs.max_size)) in rd_kafka_curr_msgs_sub()
710 rk->rk_curr_msgs.cnt -= cnt; in rd_kafka_curr_msgs_sub()
728 *cntp = rk->rk_curr_msgs.cnt; in rd_kafka_curr_msgs_get()
[all …]
H A Drdkafka.c979 cnd_destroy(&rk->rk_curr_msgs.cnd); in rd_kafka_destroy_final()
980 mtx_destroy(&rk->rk_curr_msgs.lock); in rd_kafka_destroy_final()
1664 rk->rk_curr_msgs.max_cnt, rk->rk_curr_msgs.max_size, in rd_kafka_stats_emit_all()
2263 mtx_init(&rk->rk_curr_msgs.lock, mtx_plain); in rd_kafka_new()
2264 cnd_init(&rk->rk_curr_msgs.cnd); in rd_kafka_new()
2265 rk->rk_curr_msgs.max_cnt = in rd_kafka_new()
2270 rk->rk_curr_msgs.max_size = SIZE_MAX; in rd_kafka_new()
2274 rk->rk_curr_msgs.max_size); in rd_kafka_new()
2276 rk->rk_curr_msgs.max_size = in rd_kafka_new()
/dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/src/
H A Drdkafka_int.h544 } rk_curr_msgs; member
657 rk->rk_curr_msgs.max_cnt || in rd_kafka_curr_msgs_add()
668 cnd_wait(&rk->rk_curr_msgs.cnd, &rk->rk_curr_msgs.lock); in rd_kafka_curr_msgs_add()
675 rk->rk_curr_msgs.cnt += cnt; in rd_kafka_curr_msgs_add()
703 (rk->rk_curr_msgs.cnt >= rk->rk_curr_msgs.max_cnt && in rd_kafka_curr_msgs_sub()
704 rk->rk_curr_msgs.cnt - cnt < rk->rk_curr_msgs.max_cnt) || in rd_kafka_curr_msgs_sub()
705 (rk->rk_curr_msgs.size >= rk->rk_curr_msgs.max_size && in rd_kafka_curr_msgs_sub()
706 rk->rk_curr_msgs.size - size < rk->rk_curr_msgs.max_size)) in rd_kafka_curr_msgs_sub()
709 rk->rk_curr_msgs.cnt -= cnt; in rd_kafka_curr_msgs_sub()
727 *cntp = rk->rk_curr_msgs.cnt; in rd_kafka_curr_msgs_get()
[all …]
H A Drdkafka.c979 cnd_destroy(&rk->rk_curr_msgs.cnd);
980 mtx_destroy(&rk->rk_curr_msgs.lock);
1664 rk->rk_curr_msgs.max_cnt, rk->rk_curr_msgs.max_size,
2262 mtx_init(&rk->rk_curr_msgs.lock, mtx_plain);
2263 cnd_init(&rk->rk_curr_msgs.cnd);
2264 rk->rk_curr_msgs.max_cnt =
2269 rk->rk_curr_msgs.max_size = SIZE_MAX;
2273 rk->rk_curr_msgs.max_size);
2275 rk->rk_curr_msgs.max_size =