/alps/fastwriter

#ifndef _FASTWRITER_PRIVATE_H

#define _FASTWRITER_PRIVATE_H

#define FASTWRITER_SYNCIO_ALIGN 512

#define FASTWRITER_DEFAULT_BUFFER_SIZE 134217728 /* 128 MB */

#define FASTWRITER_RESERVE_MEMORY 536870912 /* 512 MB */

#include <pthread.h>

#include "fastwriter.h"

typedef struct {

    fastwriter_flags_t flags;

    size_t buffer_size;

} fastwriter_parameters_t;

typedef enum {

    FASTWRITER_WRITE_FLAGS_DEFAULT = 0,

    FASTWRITER_WRITE_FLAG_FORCE = 1		/**< Force writting all passed data */

} fastwriter_write_flags_t;

typedef struct {

    int (*open)(fastwriter_t *ctx, const char *name, fastwriter_flags_t flags);

    void (*close)(fastwriter_t *ctx);

    int (*write)(fastwriter_t *ctx, fastwriter_write_flags_t flags, size_t size, void *data, size_t *written);

} fastwriter_api_t;

struct fastwrtier_s {

    fastwriter_api_t *api;		/**< Writer API */

    void *ctx;				/**< Writer Context */

    fastwriter_flags_t flags;

    int clean_locks;

    volatile int err;		        /**< indicates error reported by the writter backend */

    volatile int run_flag;

    pthread_t wthread;

    pthread_cond_t data_cond;		/**< broadcasted when new data arrives */

    pthread_mutex_t data_cond_mutex;

    pthread_cond_t space_cond;		/**< broadcasted when some space is freed */

    pthread_mutex_t space_cond_mutex;

    void *buffer;

    size_t size;		/**< size of the ring buffer in bytes */

    size_t max_usage;		/**< maximal number of bytes used in ring buffer */

    volatile size_t tail;	/**< first unwritten data in the ring buffer */

    volatile size_t head;	/**< last commited data in the ring buffer */

    size_t pos;			/**< last pushed data in the ring buffer */

    size_t written;		/**< number of bytes written */

    size_t commited;		/**< number of bytes commited */

    size_t chunked;		/**< number of bytes chunked */

    fastwriter_parameters_t params;

};

#endif /* _FASTWRITER_PRIVATE_H */