Searched refs:rkcg_coord (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 D | rdkafka_cgrp.c | 298 rkcg->rkcg_coord, &rkcg->rkcg_coord->rkb_persistconn.coord); in rd_kafka_cgrp_coord_set_broker()
303 rd_kafka_broker_set_nodename(rkcg->rkcg_coord, rkb); in rd_kafka_cgrp_coord_set_broker()
319 rd_assert(rkcg->rkcg_coord); in rd_kafka_cgrp_coord_clear_broker()
322 rkcg->rkcg_coord, in rd_kafka_cgrp_coord_clear_broker()
323 &rkcg->rkcg_coord->rkb_persistconn.coord); in rd_kafka_cgrp_coord_clear_broker()
783 rd_kafka_SyncGroupRequest(rkcg->rkcg_coord, in rd_kafka_cgrp_assignor_run()
1608 if (rkcg->rkcg_coord) { in rd_kafka_cgrp_terminated()
1609 rd_kafka_broker_destroy(rkcg->rkcg_coord); in rd_kafka_cgrp_terminated()
1610 rkcg->rkcg_coord = NULL; in rd_kafka_cgrp_terminated()
3087 rkcg->rkcg_coord, 1, in rd_kafka_cgrp_op_serve()
[all …]
|
| H A D | rdkafka_cgrp.h | 198 rd_kafka_broker_t *rkcg_coord; /**< The dedicated coordinator member
|
| /dports/net/librdkafka/librdkafka-1.8.2/src/ |
| H A D | rdkafka_cgrp.c | 494 rkcg->rkcg_coord, &rkcg->rkcg_coord->rkb_persistconn.coord); in rd_kafka_cgrp_coord_set_broker()
515 rd_assert(rkcg->rkcg_coord); in rd_kafka_cgrp_coord_clear_broker()
518 rkcg->rkcg_coord, in rd_kafka_cgrp_coord_clear_broker()
816 rd_kafka_broker_keep(rkcg->rkcg_coord); in rd_kafka_cgrp_get_coord()
818 return rkcg->rkcg_coord; in rd_kafka_cgrp_get_coord()
1772 rd_kafka_SyncGroupRequest(rkcg->rkcg_coord, in rd_kafka_cgrp_assignor_run()
2701 if (rkcg->rkcg_coord) { in rd_kafka_cgrp_terminated()
2703 rkcg->rkcg_coord = NULL; in rd_kafka_cgrp_terminated()
3274 rkcg->rkcg_coord, rkcg, offsets, in rd_kafka_cgrp_offsets_commit()
5046 rkcg->rkcg_coord, in rd_kafka_cgrp_op_serve()
[all …]
|
| H A D | rdkafka_cgrp.h | 194 rd_kafka_broker_t *rkcg_coord; /**< The dedicated coordinator member
|
| /dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/src/ |
| H A D | rdkafka_cgrp.c | 431 rkcg->rkcg_coord, &rkcg->rkcg_coord->rkb_persistconn.coord); in rd_kafka_cgrp_coord_set_broker()
452 rd_assert(rkcg->rkcg_coord); in rd_kafka_cgrp_coord_clear_broker()
455 rkcg->rkcg_coord, in rd_kafka_cgrp_coord_clear_broker()
753 rd_kafka_broker_keep(rkcg->rkcg_coord); in rd_kafka_cgrp_get_coord()
755 return rkcg->rkcg_coord; in rd_kafka_cgrp_get_coord()
1513 rd_kafka_SyncGroupRequest(rkcg->rkcg_coord, in rd_kafka_cgrp_assignor_run()
2443 if (rkcg->rkcg_coord) { in rd_kafka_cgrp_terminated()
2445 rkcg->rkcg_coord = NULL; in rd_kafka_cgrp_terminated()
3016 rkcg->rkcg_coord, rkcg, offsets, in rd_kafka_cgrp_offsets_commit()
4787 rkcg->rkcg_coord, in rd_kafka_cgrp_op_serve()
[all …]
|
| H A D | rdkafka_cgrp.h | 194 rd_kafka_broker_t *rkcg_coord; /**< The dedicated coordinator member
|