second ring buffer implementation

1 files changed, 72 insertions, 0 deletions

diff --git a/lf_ring_buffer2.h b/lf_ring_buffer2.h
new file mode 100644
index 0000000..6f0cee1
--- /dev/null
+++ b/lf_ring_buffer2.h
@@ -0,0 +1,72 @@
+/*
+ * File     : lf_ring_buffer.h
+ * Author   : Jérémy Zurcher  <jeremy@asynk.ch>
+ * Date     : 05/01/010
+ * License  :
+ *
+ *  Permission is hereby granted, free of charge, to any person obtaining
+ *  a copy of this software and associated documentation files (the
+ *  "Software"), to deal in the Software without restriction, including
+ *  without limitation the rights to use, copy, modify, merge, publish,
+ *  distribute, sublicense, and/or sell copies of the Software, and to
+ *  permit persons to whom the Software is furnished to do so, subject to
+ *  the following conditions:
+ *  
+ *  The above copyright notice and this permission notice shall be
+ *  included in all copies or substantial portions of the Software.
+ *  
+ *  THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
+ *  EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
+ *  MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
+ *  NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE
+ *  LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION
+ *  OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
+ *  WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
+ *
+ */
+
+#ifndef _LF_RING_BUFFER_H_
+#define _LF_RING_BUFFER_H_
+
+# ifdef __cplusplus
+extern "C" {
+# endif /* __cplusplus */
+
+#include <sys/types.h>
+#include "lf_ring_buffer_data.h"
+
+#define LFRB_NO_BLOCK   1       /* if buffer is full, leave instead of try again and again */
+#define IS_NOT_BLOCKING( flags ) ( (flags)&LFRB_NO_BLOCK )
+
+typedef struct ring_buffer {
+    LFRB_BUFFER_TYPE *buffer;   /* buffer data */
+    size_t n_buf;               /* number of buffers */
+    unsigned int indexes;       /* indexes where to read from and write data to */
+} lf_ring_buffer_t;
+
+/* return an initialized lf_ring_buffer_t struct */
+lf_ring_buffer_t* lf_ring_buffer_create( size_t n_buf );
+
+/* destroy an lf_ring_buffer_t struct */
+void lf_ring_buffer_destroy( lf_ring_buffer_t *r );
+
+/* return 1 if is empty */
+int lf_ring_buffer_empty( lf_ring_buffer_t *r );
+
+/* write data into the ring buffer
+ * return 0 on success
+ * return -1 if IS_NOT_BLOCKING and buffer is full
+ */
+int lf_ring_buffer_write( lf_ring_buffer_t *r, void *data, int flags );
+
+/* read data from the ring buffer
+ * return 0 on success
+ * return -1 if IS_NOT_BLOCKING and buffer is empty
+ */
+int lf_ring_buffer_read( lf_ring_buffer_t *r, void *data, int flags );
+
+# ifdef __cplusplus
+}
+# endif /* __cplusplus */
+
+# endif /* _LF_RING_BUFFER_H_ */