|
Packit |
2997f0 |
#ifndef _LINUX_SNAPPY_H
|
|
Packit |
2997f0 |
#define _LINUX_SNAPPY_H 1
|
|
Packit |
2997f0 |
|
|
Packit |
2997f0 |
#include <stdbool.h>
|
|
Packit |
2997f0 |
#include <stddef.h>
|
|
Packit |
2997f0 |
|
|
Packit |
2997f0 |
/* Only needed for compression. This preallocates the worst case */
|
|
Packit |
2997f0 |
struct snappy_env {
|
|
Packit |
2997f0 |
unsigned short *hash_table;
|
|
Packit |
2997f0 |
void *scratch;
|
|
Packit |
2997f0 |
void *scratch_output;
|
|
Packit |
2997f0 |
};
|
|
Packit |
2997f0 |
|
|
Packit |
2997f0 |
struct iovec;
|
|
Packit |
2997f0 |
int rd_kafka_snappy_init_env(struct snappy_env *env);
|
|
Packit |
2997f0 |
int rd_kafka_snappy_init_env_sg(struct snappy_env *env, bool sg);
|
|
Packit |
2997f0 |
void rd_kafka_snappy_free_env(struct snappy_env *env);
|
|
Packit |
2997f0 |
int rd_kafka_snappy_uncompress_iov(struct iovec *iov_in, int iov_in_len,
|
|
Packit |
2997f0 |
size_t input_len, char *uncompressed);
|
|
Packit |
2997f0 |
int rd_kafka_snappy_uncompress(const char *compressed, size_t n, char *uncompressed);
|
|
Packit |
2997f0 |
char *rd_kafka_snappy_java_uncompress (const char *inbuf, size_t inlen,
|
|
Packit |
2997f0 |
size_t *outlenp,
|
|
Packit |
2997f0 |
char *errstr, size_t errstr_size);
|
|
Packit |
2997f0 |
int rd_kafka_snappy_compress_iov(struct snappy_env *env,
|
|
Packit |
2997f0 |
const struct iovec *iov_in, size_t iov_in_cnt,
|
|
Packit |
2997f0 |
size_t input_length,
|
|
Packit |
2997f0 |
struct iovec *iov_out);
|
|
Packit |
2997f0 |
bool rd_kafka_snappy_uncompressed_length(const char *buf, size_t len, size_t *result);
|
|
Packit |
2997f0 |
size_t rd_kafka_snappy_max_compressed_length(size_t source_len);
|
|
Packit |
2997f0 |
|
|
Packit |
2997f0 |
|
|
Packit |
2997f0 |
|
|
Packit |
2997f0 |
|
|
Packit |
2997f0 |
#endif
|