Home
last modified time | relevance | path

Searched refs:RD_KAFKA_RESP_ERR__CRIT_SYS_RESOURCE (Results 1 – 23 of 23) sorted by relevance

/dports/net/librdkafka/librdkafka-1.8.2/src/
H A Drdkafka_lz4.c189 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 Drdkafka_zstd.c76 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 Drdkafka.c392 _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 Drdkafka_metadata.c271 err = RD_KAFKA_RESP_ERR__CRIT_SYS_RESOURCE; in rd_kafka_parse_Metadata()
H A Drdkafka_msgset_reader.c371 err = RD_KAFKA_RESP_ERR__CRIT_SYS_RESOURCE; in rd_kafka_msgset_reader_decompress()
H A Drdkafka.h283 RD_KAFKA_RESP_ERR__CRIT_SYS_RESOURCE = -194, enumerator
H A Drdkafka_broker.c5671 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 Drdkafka_lz4.c189 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 Drdkafka_zstd.c76 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 Drdkafka.c403 _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 Drdkafka_metadata.c251 err = RD_KAFKA_RESP_ERR__CRIT_SYS_RESOURCE; in rd_kafka_parse_Metadata()
H A Drdkafka_msgset_reader.c369 err = RD_KAFKA_RESP_ERR__CRIT_SYS_RESOURCE; in rd_kafka_msgset_reader_decompress()
H A Drdkafka.h272 RD_KAFKA_RESP_ERR__CRIT_SYS_RESOURCE = -194, enumerator
H A Drdkafka_broker.c5263 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 Drdkafka_lz4.c189 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 Drdkafka_zstd.c76 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 Drdkafka.c392 _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 Drdkafka_metadata.c271 err = RD_KAFKA_RESP_ERR__CRIT_SYS_RESOURCE;
H A Drdkafka_msgset_reader.c371 err = RD_KAFKA_RESP_ERR__CRIT_SYS_RESOURCE; in rd_kafka_msgset_reader_decompress()
H A Drdkafka.h283 RD_KAFKA_RESP_ERR__CRIT_SYS_RESOURCE = -194, enumerator
H A Drdkafka_broker.c5616 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 Dhelpers.rs16 RD_KAFKA_RESP_ERR__CRIT_SYS_RESOURCE => CriticalSystemResource, in rd_kafka_resp_err_t_to_rdkafka_error()
H A Dbindings.rs120 RD_KAFKA_RESP_ERR__CRIT_SYS_RESOURCE = -194, enumerator