drain.h

Go to the documentation of this file.

#ifndef KEEL_DRAIN_H
#define KEEL_DRAIN_H
 
#include <keel/allocator.h>
#include <stddef.h>
#include <sys/types.h>
 
typedef ssize_t (*KlDrainWriteFn)(const char *data, size_t len, void *ctx);
 
typedef void (*KlDrainCb)(void *ctx);
 
typedef struct {
    KlDrainWriteFn  write_fn;    
    void           *write_ctx;   
    KlDrainCb       on_drain;    
    void           *drain_ctx;   
    KlAllocator    *alloc;       
    char           *buf;         
    size_t          buf_len;     
    size_t          buf_cap;     
    size_t          max_size;    
    int             error;       
} KlDrain;
 
void kl_drain_init(KlDrain *d, KlDrainWriteFn write_fn, void *write_ctx,
                   KlAllocator *alloc);
 
void kl_drain_set_max_size(KlDrain *d, size_t max_size);
 
void kl_drain_on_drain(KlDrain *d, KlDrainCb cb, void *ctx);
 
int kl_drain_write(KlDrain *d, const char *data, size_t len);
 
int kl_drain_flush(KlDrain *d);
 
int kl_drain_pending(const KlDrain *d);
 
size_t kl_drain_buffered(const KlDrain *d);
 
void kl_drain_free(KlDrain *d);
 
#endif /* KEEL_DRAIN_H */