/dports/net/librdkafka/librdkafka-1.8.2/tests/ |
H A D | 0105-transactions_mock.c | 190 rd_kafka_consumer_group_metadata_t *cgmetadata; in do_test_txn_recoverable_errors() local 283 cgmetadata, -1)); in do_test_txn_recoverable_errors() 1105 rd_kafka_consumer_group_metadata_t *cgmetadata; in do_test_txn_req_cnt() local 1146 cgmetadata, -1)); in do_test_txn_req_cnt() 1171 rd_kafka_consumer_group_metadata_t *cgmetadata; in do_test_txn_requires_abort_errors() local 1487 rd_kafka_consumer_group_metadata_t *cgmetadata; in do_test_txn_switch_coordinator_refresh() local 1610 rd_kafka_consumer_group_metadata_t *cgmetadata; in do_test_txns_send_offsets_concurrent_is_retried() local 1677 rd_kafka_consumer_group_metadata_t *cgmetadata; in do_test_txns_no_timeout_crash() local 1802 rd_kafka_consumer_group_metadata_t *cgmetadata; in do_test_txn_flush_timeout() local 1889 cgmetadata, -1)); in do_test_txn_flush_timeout() [all …]
|
H A D | 0103-transactions.c | 1010 rd_kafka_consumer_group_metadata_t *cgmetadata; in do_test_empty_txn() local 1017 cgmetadata = rd_kafka_consumer_group_metadata(c); in do_test_empty_txn() 1018 TEST_ASSERT(cgmetadata != NULL, in do_test_empty_txn() 1023 p, offsets, cgmetadata, -1)); in do_test_empty_txn() 1025 rd_kafka_consumer_group_metadata_destroy(cgmetadata); in do_test_empty_txn()
|
/dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/tests/ |
H A D | 0105-transactions_mock.c | 190 rd_kafka_consumer_group_metadata_t *cgmetadata; in do_test_txn_recoverable_errors() local 283 cgmetadata, -1)); in do_test_txn_recoverable_errors() 285 rd_kafka_consumer_group_metadata_destroy(cgmetadata); in do_test_txn_recoverable_errors() 1105 rd_kafka_consumer_group_metadata_t *cgmetadata; in do_test_txn_req_cnt() local 1146 cgmetadata, -1)); in do_test_txn_req_cnt() 1171 rd_kafka_consumer_group_metadata_t *cgmetadata; in do_test_txn_requires_abort_errors() local 1549 rd_kafka_consumer_group_metadata_t *cgmetadata; in do_test_txns_send_offsets_concurrent_is_retried() local 1616 rd_kafka_consumer_group_metadata_t *cgmetadata; in do_test_txns_no_timeout_crash() local 1741 rd_kafka_consumer_group_metadata_t *cgmetadata; in do_test_txn_flush_timeout() local 1828 cgmetadata, -1)); in do_test_txn_flush_timeout() [all …]
|
H A D | 0103-transactions.c | 1010 rd_kafka_consumer_group_metadata_t *cgmetadata; in do_test_empty_txn() local 1017 cgmetadata = rd_kafka_consumer_group_metadata(c); in do_test_empty_txn() 1018 TEST_ASSERT(cgmetadata != NULL, in do_test_empty_txn() 1023 p, offsets, cgmetadata, -1)); in do_test_empty_txn() 1025 rd_kafka_consumer_group_metadata_destroy(cgmetadata); in do_test_empty_txn()
|
/dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/tests/ |
H A D | 0105-transactions_mock.c | 99 rd_kafka_consumer_group_metadata_t *cgmetadata; in do_test_txn_recoverable_errors() local 180 cgmetadata = rd_kafka_consumer_group_metadata_new("mygroupid"); in do_test_txn_recoverable_errors() 184 cgmetadata, -1)); in do_test_txn_recoverable_errors() 186 rd_kafka_consumer_group_metadata_destroy(cgmetadata); in do_test_txn_recoverable_errors() 220 rd_kafka_consumer_group_metadata_t *cgmetadata; in do_test_txn_requires_abort_errors() local 256 cgmetadata = rd_kafka_consumer_group_metadata_new("mygroupid"); in do_test_txn_requires_abort_errors() 259 cgmetadata, -1); in do_test_txn_requires_abort_errors() 261 rd_kafka_consumer_group_metadata_destroy(cgmetadata); in do_test_txn_requires_abort_errors() 323 cgmetadata = rd_kafka_consumer_group_metadata_new("mygroupid"); in do_test_txn_requires_abort_errors() 326 cgmetadata, -1); in do_test_txn_requires_abort_errors() [all …]
|
/dports/net/librdkafka/librdkafka-1.8.2/src/ |
H A D | rdkafka_cgrp.c | 5619 return cgmetadata; in rd_kafka_consumer_group_metadata_new() 5630 cgmetadata = rd_calloc(1, sizeof(*cgmetadata)); in rd_kafka_consumer_group_metadata_new_with_genid() 5637 return cgmetadata; in rd_kafka_consumer_group_metadata_new_with_genid() 5653 cgmetadata = rko->rko_u.cg_metadata; in rd_kafka_consumer_group_metadata() 5657 return cgmetadata; in rd_kafka_consumer_group_metadata() 5663 rd_free(cgmetadata->group_id); in rd_kafka_consumer_group_metadata_destroy() 5664 rd_free(cgmetadata->member_id); in rd_kafka_consumer_group_metadata_destroy() 5665 if (cgmetadata->group_instance_id) in rd_kafka_consumer_group_metadata_destroy() 5667 rd_free(cgmetadata); in rd_kafka_consumer_group_metadata_destroy() 5675 ret = rd_calloc(1, sizeof(*cgmetadata)); in rd_kafka_consumer_group_metadata_dup() [all …]
|
H A D | rdkafka_txnmgr.c | 1645 rko->rko_u.txn.cgmetadata->group_id, in rd_kafka_txn_handle_TxnOffsetCommit() 1692 const rd_kafka_consumer_group_metadata_t *cgmetadata = in rd_kafka_txn_send_TxnOffsetCommitRequest() local 1693 rko->rko_u.txn.cgmetadata; in rd_kafka_txn_send_TxnOffsetCommitRequest() 1741 rd_kafka_buf_write_i32(rkbuf, cgmetadata->generation_id); in rd_kafka_txn_send_TxnOffsetCommitRequest() 1743 rd_kafka_buf_write_str(rkbuf, cgmetadata->member_id, -1); in rd_kafka_txn_send_TxnOffsetCommitRequest() 1947 rko->rko_u.txn.cgmetadata->group_id, in rd_kafka_txn_handle_AddOffsetsToTxn() 2020 rko->rko_u.txn.cgmetadata->group_id, in rd_kafka_txn_op_send_offsets_to_transaction() 2050 const rd_kafka_consumer_group_metadata_t *cgmetadata, in rd_kafka_send_offsets_to_transaction() argument 2059 if (!cgmetadata || !offsets) in rd_kafka_send_offsets_to_transaction() 2079 rko->rko_u.txn.cgmetadata = in rd_kafka_send_offsets_to_transaction() [all …]
|
H A D | rdkafka_cgrp.h | 363 const rd_kafka_consumer_group_metadata_t *cgmetadata);
|
H A D | rdkafka_op.h | 576 rd_kafka_consumer_group_metadata_t *cgmetadata; member
|
H A D | rdkafka_op.c | 404 RD_IF_FREE(rko->rko_u.txn.cgmetadata, in rd_kafka_op_destroy()
|
H A D | rdkafka.h | 7642 const rd_kafka_consumer_group_metadata_t *cgmetadata,
|
/dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/src/ |
H A D | rdkafka_cgrp.c | 5471 return cgmetadata; in rd_kafka_consumer_group_metadata_new() 5482 cgmetadata = rd_calloc(1, sizeof(*cgmetadata)); in rd_kafka_consumer_group_metadata_new_with_genid() 5489 return cgmetadata; in rd_kafka_consumer_group_metadata_new_with_genid() 5505 cgmetadata = rko->rko_u.cg_metadata; in rd_kafka_consumer_group_metadata() 5509 return cgmetadata; in rd_kafka_consumer_group_metadata() 5515 rd_free(cgmetadata->group_id); in rd_kafka_consumer_group_metadata_destroy() 5516 rd_free(cgmetadata->member_id); in rd_kafka_consumer_group_metadata_destroy() 5517 if (cgmetadata->group_instance_id) in rd_kafka_consumer_group_metadata_destroy() 5519 rd_free(cgmetadata); in rd_kafka_consumer_group_metadata_destroy() 5527 ret = rd_calloc(1, sizeof(*cgmetadata)); in rd_kafka_consumer_group_metadata_dup() [all …]
|
H A D | rdkafka_txnmgr.c | 1645 rko->rko_u.txn.cgmetadata->group_id, 1692 const rd_kafka_consumer_group_metadata_t *cgmetadata = 1693 rko->rko_u.txn.cgmetadata; 1741 rd_kafka_buf_write_i32(rkbuf, cgmetadata->generation_id); 1743 rd_kafka_buf_write_str(rkbuf, cgmetadata->member_id, -1); 1940 rko->rko_u.txn.cgmetadata->group_id, 2013 rko->rko_u.txn.cgmetadata->group_id, 2043 const rd_kafka_consumer_group_metadata_t *cgmetadata, 2052 if (!cgmetadata || !offsets) 2072 rko->rko_u.txn.cgmetadata = [all …]
|
H A D | rdkafka_cgrp.h | 360 const rd_kafka_consumer_group_metadata_t *cgmetadata);
|
H A D | rdkafka_op.h | 565 rd_kafka_consumer_group_metadata_t *cgmetadata;
|
H A D | rdkafka_op.c | 404 RD_IF_FREE(rko->rko_u.txn.cgmetadata, in rd_kafka_op_destroy()
|
H A D | rdkafka.h | 7636 const rd_kafka_consumer_group_metadata_t *cgmetadata,
|
/dports/net/librdkafka/librdkafka-1.8.2/src-cpp/ |
H A D | rdkafkacpp_int.h | 1123 ConsumerGroupMetadataImpl(rd_kafka_consumer_group_metadata_t *cgmetadata): in ConsumerGroupMetadataImpl() argument 1124 cgmetadata_(cgmetadata) {} in ConsumerGroupMetadataImpl() 1214 rd_kafka_consumer_group_metadata_t *cgmetadata; in groupMetadata() local 1216 cgmetadata = rd_kafka_consumer_group_metadata(rk_); in groupMetadata() 1217 if (!cgmetadata) in groupMetadata() 1220 return new ConsumerGroupMetadataImpl(cgmetadata); in groupMetadata()
|
/dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/src-cpp/ |
H A D | rdkafkacpp_int.h | 1091 ConsumerGroupMetadataImpl(rd_kafka_consumer_group_metadata_t *cgmetadata): in ConsumerGroupMetadataImpl() argument 1092 cgmetadata_(cgmetadata) {} in ConsumerGroupMetadataImpl() 1174 rd_kafka_consumer_group_metadata_t *cgmetadata; in groupMetadata() local 1176 cgmetadata = rd_kafka_consumer_group_metadata(rk_); in groupMetadata() 1177 if (!cgmetadata) in groupMetadata() 1180 return new ConsumerGroupMetadataImpl(cgmetadata); in groupMetadata()
|
/dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/src-cpp/ |
H A D | rdkafkacpp_int.h | 1123 ConsumerGroupMetadataImpl(rd_kafka_consumer_group_metadata_t *cgmetadata): in ConsumerGroupMetadataImpl() argument 1124 cgmetadata_(cgmetadata) {} in ConsumerGroupMetadataImpl() 1214 rd_kafka_consumer_group_metadata_t *cgmetadata; in groupMetadata() local 1216 cgmetadata = rd_kafka_consumer_group_metadata(rk_); in groupMetadata() 1217 if (!cgmetadata) in groupMetadata() 1220 return new ConsumerGroupMetadataImpl(cgmetadata); in groupMetadata()
|
/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 | 3634 rd_kafka_consumer_group_metadata_t *cgmetadata; in rd_kafka_consumer_group_metadata_new() local 3639 cgmetadata = rd_calloc(1, sizeof(*cgmetadata)); in rd_kafka_consumer_group_metadata_new() 3640 cgmetadata->group_id = rd_strdup(group_id); in rd_kafka_consumer_group_metadata_new() 3642 return cgmetadata; in rd_kafka_consumer_group_metadata_new() 3656 rd_kafka_consumer_group_metadata_t *cgmetadata) { in rd_kafka_consumer_group_metadata_destroy() argument 3657 rd_free(cgmetadata->group_id); in rd_kafka_consumer_group_metadata_destroy() 3658 rd_free(cgmetadata); in rd_kafka_consumer_group_metadata_destroy() 3663 const rd_kafka_consumer_group_metadata_t *cgmetadata) { in rd_kafka_consumer_group_metadata_dup() argument 3666 ret = rd_calloc(1, sizeof(*cgmetadata)); in rd_kafka_consumer_group_metadata_dup() 3667 ret->group_id = rd_strdup(cgmetadata->group_id); in rd_kafka_consumer_group_metadata_dup()
|
H A D | rdkafka_cgrp.h | 317 const rd_kafka_consumer_group_metadata_t *cgmetadata);
|
H A D | rdkafka_txnmgr.c | 1813 const rd_kafka_consumer_group_metadata_t *cgmetadata, in rd_kafka_send_offsets_to_transaction() argument 1822 if (!cgmetadata || !offsets) in rd_kafka_send_offsets_to_transaction() 1842 rko->rko_u.txn.group_id = rd_strdup(cgmetadata->group_id); in rd_kafka_send_offsets_to_transaction()
|
H A D | rdkafka.h | 6795 const rd_kafka_consumer_group_metadata_t *cgmetadata,
|
/dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/src/ |
H A D | bindings.rs | 2166 cgmetadata: *const rd_kafka_consumer_group_metadata_t, in rd_kafka_send_offsets_to_transaction()
|