/dports/net/librdkafka/librdkafka-1.8.2/src/ |
H A D | rdkafka_lz4.c | 189 return RD_KAFKA_RESP_ERR__CRIT_SYS_RESOURCE; in rd_kafka_lz4_decompress() 234 err = RD_KAFKA_RESP_ERR__CRIT_SYS_RESOURCE; in rd_kafka_lz4_decompress() 281 err = RD_KAFKA_RESP_ERR__CRIT_SYS_RESOURCE; in rd_kafka_lz4_decompress() 366 return RD_KAFKA_RESP_ERR__CRIT_SYS_RESOURCE; in rd_kafka_lz4_compress() 375 return RD_KAFKA_RESP_ERR__CRIT_SYS_RESOURCE; in rd_kafka_lz4_compress()
|
H A D | rdkafka_zstd.c | 76 return RD_KAFKA_RESP_ERR__CRIT_SYS_RESOURCE; in rd_kafka_zstd_decompress() 137 return RD_KAFKA_RESP_ERR__CRIT_SYS_RESOURCE; in rd_kafka_zstd_compress() 145 err = RD_KAFKA_RESP_ERR__CRIT_SYS_RESOURCE; in rd_kafka_zstd_compress()
|
H A D | rdkafka.c | 392 _ERR_DESC(RD_KAFKA_RESP_ERR__CRIT_SYS_RESOURCE, 2408 ret_err = RD_KAFKA_RESP_ERR__CRIT_SYS_RESOURCE; in rd_kafka_new() 2439 ret_err = RD_KAFKA_RESP_ERR__CRIT_SYS_RESOURCE; in rd_kafka_new() 2501 rd_kafka_set_last_error(RD_KAFKA_RESP_ERR__CRIT_SYS_RESOURCE, in rd_kafka_new()
|
H A D | rdkafka_metadata.c | 271 err = RD_KAFKA_RESP_ERR__CRIT_SYS_RESOURCE; in rd_kafka_parse_Metadata()
|
H A D | rdkafka_msgset_reader.c | 371 err = RD_KAFKA_RESP_ERR__CRIT_SYS_RESOURCE; in rd_kafka_msgset_reader_decompress()
|
H A D | rdkafka.h | 283 RD_KAFKA_RESP_ERR__CRIT_SYS_RESOURCE = -194, enumerator
|
H A D | rdkafka_broker.c | 5671 rd_kafka_op_err(rk, RD_KAFKA_RESP_ERR__CRIT_SYS_RESOURCE, in rd_kafka_broker_add()
|
/dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/src/ |
H A D | rdkafka_lz4.c | 189 return RD_KAFKA_RESP_ERR__CRIT_SYS_RESOURCE; in rd_kafka_lz4_decompress() 234 err = RD_KAFKA_RESP_ERR__CRIT_SYS_RESOURCE; in rd_kafka_lz4_decompress() 281 err = RD_KAFKA_RESP_ERR__CRIT_SYS_RESOURCE; in rd_kafka_lz4_decompress() 366 return RD_KAFKA_RESP_ERR__CRIT_SYS_RESOURCE; in rd_kafka_lz4_compress() 375 return RD_KAFKA_RESP_ERR__CRIT_SYS_RESOURCE; in rd_kafka_lz4_compress()
|
H A D | rdkafka_zstd.c | 76 return RD_KAFKA_RESP_ERR__CRIT_SYS_RESOURCE; in rd_kafka_zstd_decompress() 137 return RD_KAFKA_RESP_ERR__CRIT_SYS_RESOURCE; in rd_kafka_zstd_compress() 145 err = RD_KAFKA_RESP_ERR__CRIT_SYS_RESOURCE; in rd_kafka_zstd_compress()
|
H A D | rdkafka.c | 403 _ERR_DESC(RD_KAFKA_RESP_ERR__CRIT_SYS_RESOURCE, 2285 ret_err = RD_KAFKA_RESP_ERR__CRIT_SYS_RESOURCE; in rd_kafka_new() 2316 ret_err = RD_KAFKA_RESP_ERR__CRIT_SYS_RESOURCE; in rd_kafka_new() 2378 rd_kafka_set_last_error(RD_KAFKA_RESP_ERR__CRIT_SYS_RESOURCE, in rd_kafka_new()
|
H A D | rdkafka_metadata.c | 251 err = RD_KAFKA_RESP_ERR__CRIT_SYS_RESOURCE; in rd_kafka_parse_Metadata()
|
H A D | rdkafka_msgset_reader.c | 369 err = RD_KAFKA_RESP_ERR__CRIT_SYS_RESOURCE; in rd_kafka_msgset_reader_decompress()
|
H A D | rdkafka.h | 272 RD_KAFKA_RESP_ERR__CRIT_SYS_RESOURCE = -194, enumerator
|
H A D | rdkafka_broker.c | 5263 rd_kafka_op_err(rk, RD_KAFKA_RESP_ERR__CRIT_SYS_RESOURCE, in rd_kafka_broker_add()
|
/dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/src/ |
H A D | rdkafka_lz4.c | 189 return RD_KAFKA_RESP_ERR__CRIT_SYS_RESOURCE; in pg_atomic_compare_exchange_u32_impl() 234 err = RD_KAFKA_RESP_ERR__CRIT_SYS_RESOURCE; in pg_atomic_compare_exchange_u32_impl() 281 err = RD_KAFKA_RESP_ERR__CRIT_SYS_RESOURCE; in pg_atomic_compare_exchange_u32_impl() 366 return RD_KAFKA_RESP_ERR__CRIT_SYS_RESOURCE; 375 return RD_KAFKA_RESP_ERR__CRIT_SYS_RESOURCE;
|
H A D | rdkafka_zstd.c | 76 return RD_KAFKA_RESP_ERR__CRIT_SYS_RESOURCE; 137 return RD_KAFKA_RESP_ERR__CRIT_SYS_RESOURCE; 145 err = RD_KAFKA_RESP_ERR__CRIT_SYS_RESOURCE;
|
H A D | rdkafka.c | 392 _ERR_DESC(RD_KAFKA_RESP_ERR__CRIT_SYS_RESOURCE, 2407 ret_err = RD_KAFKA_RESP_ERR__CRIT_SYS_RESOURCE; 2438 ret_err = RD_KAFKA_RESP_ERR__CRIT_SYS_RESOURCE; 2500 rd_kafka_set_last_error(RD_KAFKA_RESP_ERR__CRIT_SYS_RESOURCE,
|
H A D | rdkafka_metadata.c | 271 err = RD_KAFKA_RESP_ERR__CRIT_SYS_RESOURCE;
|
H A D | rdkafka_msgset_reader.c | 371 err = RD_KAFKA_RESP_ERR__CRIT_SYS_RESOURCE; in rd_kafka_msgset_reader_decompress()
|
H A D | rdkafka.h | 283 RD_KAFKA_RESP_ERR__CRIT_SYS_RESOURCE = -194, enumerator
|
H A D | rdkafka_broker.c | 5616 rd_kafka_op_err(rk, RD_KAFKA_RESP_ERR__CRIT_SYS_RESOURCE, in rd_kafka_broker_add()
|
/dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/src/ |
H A D | helpers.rs | 16 RD_KAFKA_RESP_ERR__CRIT_SYS_RESOURCE => CriticalSystemResource, in rd_kafka_resp_err_t_to_rdkafka_error()
|
H A D | bindings.rs | 120 RD_KAFKA_RESP_ERR__CRIT_SYS_RESOURCE = -194, enumerator
|