/dports/net/librdkafka/librdkafka-1.8.2/src/ |
H A D | rdkafka_queue.h | 115 static RD_INLINE RD_UNUSED 133 static RD_INLINE RD_UNUSED 141 static RD_INLINE RD_UNUSED 151 static RD_INLINE RD_UNUSED 160 static RD_INLINE RD_UNUSED 176 static RD_INLINE RD_UNUSED 197 static RD_INLINE RD_UNUSED 231 static RD_INLINE RD_UNUSED 242 static RD_INLINE RD_UNUSED 264 static RD_INLINE RD_UNUSED [all …]
|
H A D | rdinterval.h | 41 static RD_INLINE RD_UNUSED void rd_interval_init (rd_interval_t *ri) { in rd_interval_init() 66 static RD_INLINE RD_UNUSED rd_ts_t rd_interval0 (rd_interval_t *ri, in rd_interval0() 94 static RD_INLINE RD_UNUSED void rd_interval_reset (rd_interval_t *ri) { in rd_interval_reset() 103 static RD_INLINE RD_UNUSED void rd_interval_reset_to_now (rd_interval_t *ri, in rd_interval_reset_to_now() 115 static RD_INLINE RD_UNUSED void rd_interval_backoff (rd_interval_t *ri, in rd_interval_backoff() 125 static RD_INLINE RD_UNUSED void rd_interval_expedite (rd_interval_t *ri, in rd_interval_expedite() 137 static RD_INLINE RD_UNUSED void rd_interval_fixed (rd_interval_t *ri, in rd_interval_fixed() 147 static RD_INLINE RD_UNUSED void rd_interval_disable (rd_interval_t *ri) { in rd_interval_disable() 155 static RD_INLINE RD_UNUSED int rd_interval_disabled (const rd_interval_t *ri) { in rd_interval_disabled()
|
H A D | rdkafka_proto.h | 96 static RD_UNUSED 196 static RD_UNUSED 280 static RD_UNUSED void rd_kafkap_str_destroy (rd_kafkap_str_t *kstr) { in rd_kafkap_str_destroy() 293 static RD_INLINE RD_UNUSED 328 static RD_INLINE RD_UNUSED 354 static RD_INLINE RD_UNUSED int rd_kafkap_str_cmp_str2 (const char *str, in rd_kafkap_str_cmp_str2() 423 static RD_INLINE RD_UNUSED 454 static RD_INLINE RD_UNUSED 471 static RD_INLINE RD_UNUSED 642 static RD_UNUSED const char * [all …]
|
H A D | rdkafka_msg.h | 148 static RD_INLINE RD_UNUSED 172 static RD_INLINE RD_UNUSED 183 static RD_INLINE RD_UNUSED 214 static RD_INLINE RD_UNUSED 222 static RD_INLINE RD_UNUSED 322 static RD_INLINE RD_UNUSED 339 static RD_INLINE RD_UNUSED 355 static RD_INLINE RD_UNUSED 365 static RD_INLINE RD_UNUSED 376 static RD_INLINE RD_UNUSED [all …]
|
H A D | rd.h | 126 static RD_INLINE RD_UNUSED void *rd_calloc(size_t num, size_t sz) { in rd_calloc() 132 static RD_INLINE RD_UNUSED void *rd_malloc(size_t sz) { in rd_malloc() 138 static RD_INLINE RD_UNUSED void *rd_realloc(void *ptr, size_t sz) { in rd_realloc() 144 static RD_INLINE RD_UNUSED void rd_free(void *ptr) { in rd_free() 148 static RD_INLINE RD_UNUSED char *rd_strdup(const char *s) { in rd_strdup() 158 static RD_INLINE RD_UNUSED char *rd_strndup(const char *s, size_t len) { in rd_strndup() 294 static RD_INLINE RD_UNUSED void rd_refcnt_destroy (rd_refcnt_t *R) { in rd_refcnt_destroy() 307 static RD_INLINE RD_UNUSED int rd_refcnt_set (rd_refcnt_t *R, int v) { in rd_refcnt_set() 320 static RD_INLINE RD_UNUSED int rd_refcnt_add0 (rd_refcnt_t *R) { in rd_refcnt_add0() 331 static RD_INLINE RD_UNUSED int rd_refcnt_sub0 (rd_refcnt_t *R) { in rd_refcnt_sub0() [all …]
|
H A D | rdatomic.h | 48 static RD_INLINE RD_UNUSED void rd_atomic32_init (rd_atomic32_t *ra, int32_t v) { in rd_atomic32_init() 56 static RD_INLINE int32_t RD_UNUSED rd_atomic32_add (rd_atomic32_t *ra, int32_t v) { in rd_atomic32_add() 73 static RD_INLINE int32_t RD_UNUSED rd_atomic32_sub(rd_atomic32_t *ra, int32_t v) { in rd_atomic32_sub() 98 static RD_INLINE int32_t RD_UNUSED rd_atomic32_get(rd_atomic32_t *ra) { in rd_atomic32_get() 112 static RD_INLINE int32_t RD_UNUSED rd_atomic32_set(rd_atomic32_t *ra, int32_t v) { in rd_atomic32_set() 134 static RD_INLINE RD_UNUSED void rd_atomic64_init (rd_atomic64_t *ra, int64_t v) { in rd_atomic64_init() 141 static RD_INLINE int64_t RD_UNUSED rd_atomic64_add (rd_atomic64_t *ra, int64_t v) { in rd_atomic64_add() 158 static RD_INLINE int64_t RD_UNUSED rd_atomic64_sub(rd_atomic64_t *ra, int64_t v) { in rd_atomic64_sub() 184 static RD_INLINE int64_t RD_UNUSED rd_atomic64_get(rd_atomic64_t *ra) { in rd_atomic64_get() 199 static RD_INLINE int64_t RD_UNUSED rd_atomic64_set(rd_atomic64_t *ra, int64_t v) { in rd_atomic64_set()
|
H A D | rdwin32.h | 77 #define RD_UNUSED macro 109 static RD_UNUSED RD_INLINE 121 static RD_UNUSED RD_INLINE 155 static RD_INLINE RD_UNUSED const char *rd_strerror(int err) { in rd_strerror() 165 static RD_UNUSED char * 202 static RD_UNUSED 222 static RD_INLINE RD_UNUSED 253 static RD_UNUSED const char *rd_socket_strerror (int err) { in rd_socket_strerror() 270 static RD_UNUSED int rd_fd_set_nonblocking (rd_socket_t fd) { in rd_fd_set_nonblocking() 281 static RD_UNUSED int rd_pipe_nonblocking (rd_socket_t *fds) { in rd_pipe_nonblocking()
|
H A D | rdavl.h | 176 static RD_INLINE RD_UNUSED void rd_avl_rdlock (rd_avl_t *ravl) { in rd_avl_rdlock() 181 static RD_INLINE RD_UNUSED void rd_avl_wrlock (rd_avl_t *ravl) { in rd_avl_wrlock() 186 static RD_INLINE RD_UNUSED void rd_avl_rdunlock (rd_avl_t *ravl) { in rd_avl_rdunlock() 191 static RD_INLINE RD_UNUSED void rd_avl_wrunlock (rd_avl_t *ravl) { in rd_avl_wrunlock() 208 static RD_UNUSED void *rd_avl_insert (rd_avl_t *ravl, void *elm, in rd_avl_insert() 226 static RD_INLINE RD_UNUSED 239 static RD_INLINE RD_UNUSED void *rd_avl_find (rd_avl_t *ravl, const void *elm, in rd_avl_find()
|
/dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/src/ |
H A D | rdkafka_queue.h | 115 static RD_INLINE RD_UNUSED 133 static RD_INLINE RD_UNUSED 141 static RD_INLINE RD_UNUSED 151 static RD_INLINE RD_UNUSED 160 static RD_INLINE RD_UNUSED 176 static RD_INLINE RD_UNUSED 197 static RD_INLINE RD_UNUSED 231 static RD_INLINE RD_UNUSED 242 static RD_INLINE RD_UNUSED 264 static RD_INLINE RD_UNUSED [all …]
|
H A D | rdinterval.h | 41 static RD_INLINE RD_UNUSED void rd_interval_init (rd_interval_t *ri) { 66 static RD_INLINE RD_UNUSED rd_ts_t rd_interval0 (rd_interval_t *ri, 94 static RD_INLINE RD_UNUSED void rd_interval_reset (rd_interval_t *ri) { 103 static RD_INLINE RD_UNUSED void rd_interval_reset_to_now (rd_interval_t *ri, 115 static RD_INLINE RD_UNUSED void rd_interval_backoff (rd_interval_t *ri, 125 static RD_INLINE RD_UNUSED void rd_interval_expedite (rd_interval_t *ri, 137 static RD_INLINE RD_UNUSED void rd_interval_fixed (rd_interval_t *ri, 147 static RD_INLINE RD_UNUSED void rd_interval_disable (rd_interval_t *ri) { 155 static RD_INLINE RD_UNUSED int rd_interval_disabled (const rd_interval_t *ri) {
|
H A D | rdkafka_proto.h | 96 static RD_UNUSED 196 static RD_UNUSED 280 static RD_UNUSED void rd_kafkap_str_destroy (rd_kafkap_str_t *kstr) { in rd_kafkap_str_destroy() 293 static RD_INLINE RD_UNUSED 328 static RD_INLINE RD_UNUSED 354 static RD_INLINE RD_UNUSED int rd_kafkap_str_cmp_str2 (const char *str, in rd_kafkap_str_cmp_str2() 423 static RD_INLINE RD_UNUSED 454 static RD_INLINE RD_UNUSED 471 static RD_INLINE RD_UNUSED 642 static RD_UNUSED const char * [all …]
|
H A D | rdkafka_msg.h | 148 static RD_INLINE RD_UNUSED 172 static RD_INLINE RD_UNUSED 183 static RD_INLINE RD_UNUSED 214 static RD_INLINE RD_UNUSED 222 static RD_INLINE RD_UNUSED 322 static RD_INLINE RD_UNUSED 339 static RD_INLINE RD_UNUSED 355 static RD_INLINE RD_UNUSED 365 static RD_INLINE RD_UNUSED 376 static RD_INLINE RD_UNUSED [all …]
|
H A D | rd.h | 120 static RD_INLINE RD_UNUSED void *rd_calloc(size_t num, size_t sz) { 126 static RD_INLINE RD_UNUSED void *rd_malloc(size_t sz) { 132 static RD_INLINE RD_UNUSED void *rd_realloc(void *ptr, size_t sz) { 138 static RD_INLINE RD_UNUSED void rd_free(void *ptr) { 142 static RD_INLINE RD_UNUSED char *rd_strdup(const char *s) { 152 static RD_INLINE RD_UNUSED char *rd_strndup(const char *s, size_t len) { 288 static RD_INLINE RD_UNUSED void rd_refcnt_destroy (rd_refcnt_t *R) { 301 static RD_INLINE RD_UNUSED int rd_refcnt_set (rd_refcnt_t *R, int v) { 314 static RD_INLINE RD_UNUSED int rd_refcnt_add0 (rd_refcnt_t *R) { 325 static RD_INLINE RD_UNUSED int rd_refcnt_sub0 (rd_refcnt_t *R) { [all …]
|
H A D | rdatomic.h | 48 static RD_INLINE RD_UNUSED void rd_atomic32_init (rd_atomic32_t *ra, int32_t v) { in rd_atomic32_init() 56 static RD_INLINE int32_t RD_UNUSED rd_atomic32_add (rd_atomic32_t *ra, int32_t v) { in rd_atomic32_add() 73 static RD_INLINE int32_t RD_UNUSED rd_atomic32_sub(rd_atomic32_t *ra, int32_t v) { in rd_atomic32_sub() 98 static RD_INLINE int32_t RD_UNUSED rd_atomic32_get(rd_atomic32_t *ra) { in rd_atomic32_get() 112 static RD_INLINE int32_t RD_UNUSED rd_atomic32_set(rd_atomic32_t *ra, int32_t v) { in rd_atomic32_set() 134 static RD_INLINE RD_UNUSED void rd_atomic64_init (rd_atomic64_t *ra, int64_t v) { in rd_atomic64_init() 141 static RD_INLINE int64_t RD_UNUSED rd_atomic64_add (rd_atomic64_t *ra, int64_t v) { in rd_atomic64_add() 158 static RD_INLINE int64_t RD_UNUSED rd_atomic64_sub(rd_atomic64_t *ra, int64_t v) { in rd_atomic64_sub() 184 static RD_INLINE int64_t RD_UNUSED rd_atomic64_get(rd_atomic64_t *ra) { in rd_atomic64_get() 199 static RD_INLINE int64_t RD_UNUSED rd_atomic64_set(rd_atomic64_t *ra, int64_t v) { in rd_atomic64_set()
|
H A D | rdwin32.h | 77 #define RD_UNUSED macro 109 static RD_UNUSED RD_INLINE 121 static RD_UNUSED RD_INLINE 155 static RD_INLINE RD_UNUSED const char *rd_strerror(int err) { in rd_strerror() 165 static RD_UNUSED char * 202 static RD_UNUSED 222 static RD_INLINE RD_UNUSED 253 static RD_UNUSED const char *rd_socket_strerror (int err) { in rd_socket_strerror() 270 static RD_UNUSED int rd_fd_set_nonblocking (rd_socket_t fd) { in rd_fd_set_nonblocking() 281 static RD_UNUSED int rd_pipe_nonblocking (rd_socket_t *fds) { in rd_pipe_nonblocking()
|
/dports/net/librdkafka/librdkafka-1.8.2/tests/ |
H A D | testcpp.h | 74 static RD_UNUSED void Fail (std::string str) { in Fail() 78 static RD_UNUSED void FailLater (std::string str) { in FailLater() 82 static RD_UNUSED void Skip (std::string str) { in Skip() 85 static RD_UNUSED void Say (int level, std::string str) { in Say() 88 static RD_UNUSED void Say (std::string str) { in Say() 148 static RD_UNUSED 155 static RD_UNUSED 170 static RD_UNUSED void subscribe (RdKafka::KafkaConsumer *c, in subscribe() 204 static RD_UNUSED void 217 static RD_UNUSED void [all …]
|
/dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/tests/ |
H A D | testcpp.h | 74 static RD_UNUSED void Fail (std::string str) { in Fail() 78 static RD_UNUSED void FailLater (std::string str) { in FailLater() 82 static RD_UNUSED void Skip (std::string str) { in Skip() 85 static RD_UNUSED void Say (int level, std::string str) { in Say() 88 static RD_UNUSED void Say (std::string str) { in Say() 148 static RD_UNUSED 155 static RD_UNUSED 170 static RD_UNUSED void subscribe (RdKafka::KafkaConsumer *c, in subscribe() 204 static RD_UNUSED void 217 static RD_UNUSED void [all …]
|
/dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/src/ |
H A D | rdkafka_queue.h | 106 static RD_INLINE RD_UNUSED 124 static RD_INLINE RD_UNUSED 132 static RD_INLINE RD_UNUSED 142 static RD_INLINE RD_UNUSED 151 static RD_INLINE RD_UNUSED 167 static RD_INLINE RD_UNUSED 188 static RD_INLINE RD_UNUSED 222 static RD_INLINE RD_UNUSED 233 static RD_INLINE RD_UNUSED 255 static RD_INLINE RD_UNUSED [all …]
|
H A D | rdinterval.h | 41 static RD_INLINE RD_UNUSED void rd_interval_init (rd_interval_t *ri) { in rd_interval_init() 66 static RD_INLINE RD_UNUSED rd_ts_t rd_interval0 (rd_interval_t *ri, in rd_interval0() 94 static RD_INLINE RD_UNUSED void rd_interval_reset (rd_interval_t *ri) { in rd_interval_reset() 103 static RD_INLINE RD_UNUSED void rd_interval_reset_to_now (rd_interval_t *ri, in rd_interval_reset_to_now() 115 static RD_INLINE RD_UNUSED void rd_interval_backoff (rd_interval_t *ri, in rd_interval_backoff() 125 static RD_INLINE RD_UNUSED void rd_interval_expedite (rd_interval_t *ri, in rd_interval_expedite() 137 static RD_INLINE RD_UNUSED void rd_interval_fixed (rd_interval_t *ri, in rd_interval_fixed() 147 static RD_INLINE RD_UNUSED void rd_interval_disable (rd_interval_t *ri) { in rd_interval_disable() 155 static RD_INLINE RD_UNUSED int rd_interval_disabled (const rd_interval_t *ri) { in rd_interval_disabled()
|
H A D | rdkafka_msg.h | 146 static RD_INLINE RD_UNUSED 170 static RD_INLINE RD_UNUSED 181 static RD_INLINE RD_UNUSED 212 static RD_INLINE RD_UNUSED 220 static RD_INLINE RD_UNUSED 320 static RD_INLINE RD_UNUSED 337 static RD_INLINE RD_UNUSED 353 static RD_INLINE RD_UNUSED 363 static RD_INLINE RD_UNUSED 374 static RD_INLINE RD_UNUSED [all …]
|
H A D | rdkafka_proto.h | 115 static RD_UNUSED 193 static RD_UNUSED 274 static RD_UNUSED void rd_kafkap_str_destroy (rd_kafkap_str_t *kstr) { in rd_kafkap_str_destroy() 287 static RD_INLINE RD_UNUSED 322 static RD_INLINE RD_UNUSED 348 static RD_INLINE RD_UNUSED int rd_kafkap_str_cmp_str2 (const char *str, in rd_kafkap_str_cmp_str2() 417 static RD_INLINE RD_UNUSED 448 static RD_INLINE RD_UNUSED 464 static RD_INLINE RD_UNUSED 588 static RD_UNUSED const char * [all …]
|
H A D | rdatomic.h | 48 static RD_INLINE RD_UNUSED void rd_atomic32_init (rd_atomic32_t *ra, int32_t v) { in rd_atomic32_init() 56 static RD_INLINE int32_t RD_UNUSED rd_atomic32_add (rd_atomic32_t *ra, int32_t v) { in rd_atomic32_add() 73 static RD_INLINE int32_t RD_UNUSED rd_atomic32_sub(rd_atomic32_t *ra, int32_t v) { in rd_atomic32_sub() 98 static RD_INLINE int32_t RD_UNUSED rd_atomic32_get(rd_atomic32_t *ra) { in rd_atomic32_get() 112 static RD_INLINE int32_t RD_UNUSED rd_atomic32_set(rd_atomic32_t *ra, int32_t v) { in rd_atomic32_set() 134 static RD_INLINE RD_UNUSED void rd_atomic64_init (rd_atomic64_t *ra, int64_t v) { in rd_atomic64_init() 141 static RD_INLINE int64_t RD_UNUSED rd_atomic64_add (rd_atomic64_t *ra, int64_t v) { in rd_atomic64_add() 158 static RD_INLINE int64_t RD_UNUSED rd_atomic64_sub(rd_atomic64_t *ra, int64_t v) { in rd_atomic64_sub() 184 static RD_INLINE int64_t RD_UNUSED rd_atomic64_get(rd_atomic64_t *ra) { in rd_atomic64_get() 199 static RD_INLINE int64_t RD_UNUSED rd_atomic64_set(rd_atomic64_t *ra, int64_t v) { in rd_atomic64_set()
|
H A D | rd.h | 111 static RD_INLINE RD_UNUSED void *rd_calloc(size_t num, size_t sz) { in rd_calloc() 117 static RD_INLINE RD_UNUSED void *rd_malloc(size_t sz) { in rd_malloc() 123 static RD_INLINE RD_UNUSED void *rd_realloc(void *ptr, size_t sz) { in rd_realloc() 129 static RD_INLINE RD_UNUSED void rd_free(void *ptr) { in rd_free() 133 static RD_INLINE RD_UNUSED char *rd_strdup(const char *s) { in rd_strdup() 143 static RD_INLINE RD_UNUSED char *rd_strndup(const char *s, size_t len) { in rd_strndup() 279 static RD_INLINE RD_UNUSED void rd_refcnt_destroy (rd_refcnt_t *R) { in rd_refcnt_destroy() 292 static RD_INLINE RD_UNUSED int rd_refcnt_set (rd_refcnt_t *R, int v) { in rd_refcnt_set() 305 static RD_INLINE RD_UNUSED int rd_refcnt_add0 (rd_refcnt_t *R) { in rd_refcnt_add0() 316 static RD_INLINE RD_UNUSED int rd_refcnt_sub0 (rd_refcnt_t *R) { in rd_refcnt_sub0() [all …]
|
H A D | rdwin32.h | 74 #define RD_UNUSED macro 98 static RD_UNUSED RD_INLINE 110 static RD_UNUSED RD_INLINE 140 static RD_INLINE RD_UNUSED const char *rd_strerror(int err) { in rd_strerror() 150 static RD_UNUSED char * 187 static RD_UNUSED 207 static RD_INLINE RD_UNUSED 238 static RD_UNUSED const char *rd_socket_strerror (int err) { in rd_socket_strerror() 255 static RD_UNUSED int rd_fd_set_nonblocking (rd_socket_t fd) { in rd_fd_set_nonblocking() 266 static RD_UNUSED int rd_pipe_nonblocking (rd_socket_t *fds) { in rd_pipe_nonblocking()
|
/dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/tests/ |
H A D | testcpp.h | 74 static RD_UNUSED void Fail (std::string str) { in Fail() 78 static RD_UNUSED void FailLater (std::string str) { in FailLater() 82 static RD_UNUSED void Skip (std::string str) { in Skip() 85 static RD_UNUSED void Say (int level, std::string str) { in Say() 88 static RD_UNUSED void Say (std::string str) { in Say() 95 static RD_UNUSED std::string mk_topic_name (std::string suffix, in mk_topic_name() 104 static RD_UNUSED void create_topic (RdKafka::Handle *use_handle, const char *topicname, in create_topic() 115 static RD_UNUSED void delete_topic (RdKafka::Handle *use_handle, const char *topicname) { in delete_topic() 130 static RD_UNUSED 137 static RD_UNUSED
|