Diff: RingBuffer.cpp

Revision:

3:9adf0d5e0522

Parent:

2:ea6d02ba96ae

--- a/RingBuffer.cpp	Thu Sep 27 13:15:54 2012 +0000
+++ b/RingBuffer.cpp	Thu Sep 27 13:31:29 2012 +0000
@@ -30,17 +30,21 @@
 int
 RingBuffer::save(unsigned char c)
 {
+    mutex.lock();
     if( (ep==sp-1)||
         ((sp==buf)&&
-            (ep==buf+bufsize-1)) )    /* buffer full */
+            (ep==buf+bufsize-1)) ) {    /* buffer full */
+        mutex.unlock();
         return 0;
-
+    }
+    
     *ep = c;
     ep++;
 
     if(ep > buf+bufsize)
         ep = buf;
 
+    mutex.unlock();
     return 1;
 }
 
@@ -49,9 +53,11 @@
 {
     unsigned char ret;
 
-    if(sp == ep)
+    mutex.lock();
+    if(sp == ep){
+        mutex.unlock();
         return 0;    /* buffer empty */
-
+    }
     ret = *sp;
     *sp = 0;
     sp++;
@@ -59,16 +65,19 @@
     if(sp > buf+bufsize)
         sp = buf;
 
+    mutex.unlock();
     return ret;
 }
 
 int
 RingBuffer::check(void)
 {
+    mutex.lock();
     int n = ep-sp;
     if(n<0)
         n = bufsize-n;
 
+    mutex.unlock();
     return n;
 }