compress.h

Go to the documentation of this file.

#ifndef KEEL_COMPRESS_H
#define KEEL_COMPRESS_H
 
#include <keel/allocator.h>
#include <keel/response.h>
#include <stddef.h>
 
typedef struct KlCompress KlCompress;
 
struct KlCompress {
    int (*compress)(KlCompress *self, const char *in, size_t in_len,
                    char **out, size_t *out_len, KlAllocator *alloc);
 
    int (*feed)(KlCompress *self, const char *data, size_t len, int flush,
                int (*emit)(void *ctx, const char *data, size_t len),
                void *emit_ctx);
 
    const char *(*encoding)(KlCompress *self);
 
    void (*reset)(KlCompress *self);
 
    void (*destroy)(KlCompress *self);
};
 
typedef struct KlCompressCtx KlCompressCtx;
 
typedef KlCompress *(*KlCompressFactory)(KlCompressCtx *ctx,
                                          KlAllocator *alloc);
 
typedef struct KlCompressConfig {
    KlCompressCtx     *ctx;         
    KlCompressFactory  factory;     
    void (*ctx_destroy)(KlCompressCtx *ctx);  
} KlCompressConfig;
 
typedef struct {
    KlCompress  *comp;       
    KlWriteFn    write_fn;   
    void        *write_ctx;  
    KlResponse  *res;        
    KlAllocator *alloc;      
    int          error;      
} KlCompressStream;
 
int kl_response_body_compress(KlResponse *res, KlCompressConfig *cfg,
                               const char *data, size_t len);
 
int kl_compress_stream_begin(KlResponse *res, KlCompressConfig *cfg,
                              int status, KlCompressStream *cs);
 
int kl_compress_stream_write(KlCompressStream *cs, const char *data,
                              size_t len);
 
int kl_compress_stream_end(KlCompressStream *cs);
 
#endif /* KEEL_COMPRESS_H */