/dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/tests/ |
H A D | 0103-transactions.c | 565 TEST_ASSERT(rd_kafka_error_code(error) == RD_KAFKA_RESP_ERR__STATE, in do_test_misuse_txn() 573 TEST_ASSERT(rd_kafka_error_code(error) == RD_KAFKA_RESP_ERR__STATE, in do_test_misuse_txn() 627 RD_KAFKA_RESP_ERR__STATE, in do_test_misuse_txn() 640 TEST_ASSERT(rd_kafka_error_code(error) == RD_KAFKA_RESP_ERR__STATE, in do_test_misuse_txn() 735 RD_KAFKA_RESP_ERR__STATE /* FIXME ? */, in do_test_fenced_txn() 738 rd_kafka_err2name(RD_KAFKA_RESP_ERR__STATE), in do_test_fenced_txn()
|
/dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/tests/ |
H A D | 0103-transactions.c | 588 TEST_ASSERT(rd_kafka_error_code(error) == RD_KAFKA_RESP_ERR__STATE, in do_test_misuse_txn() 597 TEST_ASSERT(rd_kafka_error_code(error) == RD_KAFKA_RESP_ERR__STATE, in do_test_misuse_txn() 654 RD_KAFKA_RESP_ERR__STATE, in do_test_misuse_txn() 667 TEST_ASSERT(rd_kafka_error_code(error) == RD_KAFKA_RESP_ERR__STATE, in do_test_misuse_txn()
|
/dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/src/ |
H A D | rdkafka_txnmgr.c | 98 RD_KAFKA_RESP_ERR__STATE, in rd_kafka_txn_require_states0() 769 err = RD_KAFKA_RESP_ERR__STATE; in rd_kafka_txn_register_partitions() 1057 RD_KAFKA_RESP_ERR__STATE, in rd_kafka_txn_curr_api_req() 1534 return RD_KAFKA_RESP_ERR__STATE; in rd_kafka_txn_send_TxnOffsetCommitRequest() 1771 RD_KAFKA_RESP_ERR__STATE, in rd_kafka_txn_op_send_offsets_to_transaction() 2017 RD_KAFKA_RESP_ERR__STATE, in rd_kafka_txn_op_commit_transaction() 2229 RD_KAFKA_RESP_ERR__STATE, in rd_kafka_txn_op_abort_transaction()
|
H A D | rdkafka_sasl_oauthbearer.c | 367 return RD_KAFKA_RESP_ERR__STATE; in rd_kafka_oauthbearer_set_token0() 460 return RD_KAFKA_RESP_ERR__STATE; in rd_kafka_oauthbearer_set_token_failure0()
|
H A D | rdkafka_msg.c | 67 rd_kafka_set_last_error(RD_KAFKA_RESP_ERR__STATE, ENOEXEC); in rd_kafka_check_produce() 69 return RD_KAFKA_RESP_ERR__STATE; in rd_kafka_check_produce()
|
H A D | rdkafka.h | 319 RD_KAFKA_RESP_ERR__STATE = -172, enumerator
|
H A D | rdkafka_partition.c | 1750 err = RD_KAFKA_RESP_ERR__STATE; in rd_kafka_toppar_seek()
|
/dports/net/librdkafka/librdkafka-1.8.2/tests/ |
H A D | 0103-transactions.c | 588 TEST_ASSERT(rd_kafka_error_code(error) == RD_KAFKA_RESP_ERR__STATE, in do_test_misuse_txn() 597 TEST_ASSERT(rd_kafka_error_code(error) == RD_KAFKA_RESP_ERR__STATE, in do_test_misuse_txn() 654 RD_KAFKA_RESP_ERR__STATE, in do_test_misuse_txn() 667 TEST_ASSERT(rd_kafka_error_code(error) == RD_KAFKA_RESP_ERR__STATE, in do_test_misuse_txn()
|
H A D | 0105-transactions_mock.c | 2714 TEST_ASSERT(err == RD_KAFKA_RESP_ERR__STATE, in do_test_out_of_order_seq()
|
/dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/src/ |
H A D | helpers.rs | 38 RD_KAFKA_RESP_ERR__STATE => State, in rd_kafka_resp_err_t_to_rdkafka_error()
|
H A D | bindings.rs | 142 RD_KAFKA_RESP_ERR__STATE = -172, enumerator
|
/dports/net/librdkafka/librdkafka-1.8.2/src/ |
H A D | rdkafka_txnmgr.c | 127 RD_KAFKA_RESP_ERR__STATE, in rd_kafka_txn_require_states0() 1218 RD_KAFKA_RESP_ERR__STATE, in rd_kafka_txn_curr_api_req() 1702 return RD_KAFKA_RESP_ERR__STATE; in rd_kafka_txn_send_TxnOffsetCommitRequest() 1711 return RD_KAFKA_RESP_ERR__STATE; in rd_kafka_txn_send_TxnOffsetCommitRequest() 2006 RD_KAFKA_RESP_ERR__STATE, in rd_kafka_txn_op_send_offsets_to_transaction() 2382 RD_KAFKA_RESP_ERR__STATE, in rd_kafka_txn_op_commit_transaction() 2739 RD_KAFKA_RESP_ERR__STATE, in rd_kafka_txn_op_abort_transaction()
|
H A D | rdkafka_sasl_oauthbearer.c | 367 return RD_KAFKA_RESP_ERR__STATE; in rd_kafka_oauthbearer_set_token0() 460 return RD_KAFKA_RESP_ERR__STATE; in rd_kafka_oauthbearer_set_token_failure0()
|
H A D | rdkafka_msg.c | 93 rd_kafka_set_last_error(RD_KAFKA_RESP_ERR__STATE, ENOEXEC); in rd_kafka_check_produce() 98 RD_KAFKA_RESP_ERR__STATE, in rd_kafka_check_produce() 104 return RD_KAFKA_RESP_ERR__STATE; in rd_kafka_check_produce()
|
H A D | rdkafka.h | 330 RD_KAFKA_RESP_ERR__STATE = -172, enumerator
|
H A D | rdkafka_cgrp.c | 4887 error = rd_kafka_error_new(RD_KAFKA_RESP_ERR__STATE, in rd_kafka_cgrp_handle_assign_op() 4898 error = rd_kafka_error_new(RD_KAFKA_RESP_ERR__STATE, in rd_kafka_cgrp_handle_assign_op()
|
H A D | rdkafka_partition.c | 1783 err = RD_KAFKA_RESP_ERR__STATE; in rd_kafka_toppar_seek()
|
/dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/src/ |
H A D | rdkafka_txnmgr.c | 127 RD_KAFKA_RESP_ERR__STATE, 1218 RD_KAFKA_RESP_ERR__STATE, 1702 return RD_KAFKA_RESP_ERR__STATE; 1711 return RD_KAFKA_RESP_ERR__STATE; 1999 RD_KAFKA_RESP_ERR__STATE, 2375 RD_KAFKA_RESP_ERR__STATE, 2732 RD_KAFKA_RESP_ERR__STATE,
|
H A D | rdkafka_sasl_oauthbearer.c | 367 return RD_KAFKA_RESP_ERR__STATE; in rd_kafka_oauthbearer_set_token0() 460 return RD_KAFKA_RESP_ERR__STATE; in rd_kafka_oauthbearer_set_token_failure0()
|
H A D | rdkafka_msg.c | 93 rd_kafka_set_last_error(RD_KAFKA_RESP_ERR__STATE, ENOEXEC); in rd_kafka_check_produce() 98 RD_KAFKA_RESP_ERR__STATE, in rd_kafka_check_produce() 104 return RD_KAFKA_RESP_ERR__STATE; in rd_kafka_check_produce()
|
H A D | rdkafka.h | 330 RD_KAFKA_RESP_ERR__STATE = -172, enumerator
|
H A D | rdkafka_cgrp.c | 4628 error = rd_kafka_error_new(RD_KAFKA_RESP_ERR__STATE, in rd_kafka_cgrp_handle_assign_op() 4639 error = rd_kafka_error_new(RD_KAFKA_RESP_ERR__STATE, in rd_kafka_cgrp_handle_assign_op()
|
H A D | rdkafka_partition.c | 1768 err = RD_KAFKA_RESP_ERR__STATE; in rd_kafka_toppar_seek()
|
/dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/ |
H A D | CHANGELOG.md | 306 * The transactional producer API would return `RD_KAFKA_RESP_ERR__STATE`
|
/dports/net/librdkafka/librdkafka-1.8.2/ |
H A D | CHANGELOG.md | 452 * The transactional producer API would return `RD_KAFKA_RESP_ERR__STATE`
|