1 files changed, 55 insertions, 0 deletions
diff --git a/private.h b/private.h
new file mode 100644
index 0000000..6beb35b
--- /dev/null
+++ b/private.h
@@ -0,0 +1,55 @@
+#ifndef _FASTWRITER_PRIVATE_H
+#define _FASTWRITER_PRIVATE_H
+
+#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 */