Diff: RingBuffer/RingBuffer.cpp

Revision:

0:0073c8def9f1

--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/RingBuffer/RingBuffer.cpp	Mon May 09 00:13:40 2016 +0000
@@ -0,0 +1,109 @@
+#include <RingBuffer.h>
+
+RingBuffer::RingBuffer()
+{
+    
+}
+
+RingBuffer::RingBuffer(int length)
+{
+  this->buffer = (byte *)malloc(length);
+  this->max = length;
+  this->fill = 0;
+  this->ptr = 0;
+}
+
+RingBuffer::~RingBuffer()
+{
+  free (this->buffer);
+}
+
+void RingBuffer::init(int length)
+{
+  this->buffer = (byte *)malloc(length);
+  this->max = length;
+  this->fill = 0;
+  this->ptr = 0;
+}
+
+void RingBuffer::clear()
+{
+  this->fill = 0;
+}
+
+bool RingBuffer::isFull()
+{
+  return (this->max == this->fill);
+}
+
+bool RingBuffer::hasData()
+{
+  return (this->fill != 0);
+}
+
+bool RingBuffer::addByte(byte b)
+{
+  if (this->max == this->fill)
+    return false;
+
+  int idx = (this->ptr + this->fill) % this->max;
+  this->buffer[idx] = b;
+  this->fill++;
+  return true;
+}
+
+byte RingBuffer::consumeByte()
+{
+  if (this->fill == 0)
+    return 0;
+  
+  byte ret = this->buffer[this->ptr];
+  this->fill--;
+  this->ptr++;
+  this->ptr %= this->max;
+  return ret;
+}
+
+byte RingBuffer::peek(int idx)
+{
+  byte p = (this->ptr + idx) % this->max;
+  return this->buffer[p];
+}
+
+int RingBuffer::findBuf(char * str)
+{
+    int i=0;
+    int cnt = 0;
+    int len = strlen(str);
+    byte *tmp = (byte *) str;
+    
+    if( this->fill == 0 )
+        return -1;
+    
+    for( i=0; i<this->fill; i++ )
+    {
+        if( peek(i) == *tmp )
+        {
+            tmp++;
+            cnt++;
+            
+            if(cnt == len)
+            {
+                return (i - len + 1);
+            }
+        }
+        else
+        {   
+            tmp = (byte *)str;
+            cnt=0;
+        }
+    }
+    
+    return -1;
+}
+
+
+int RingBuffer::count()
+{
+  return this->fill;
+}
\ No newline at end of file