Yoji KURODA / RingBuffer_RTOS

General purpose ring buffer library. RTOS proof, mutex protected.

Dependents:   RingBuffer_RTOS_test

Fork of RingBuffer by Yoji KURODA

RingBuffer.cpp@1:1c3a10f2eb04, 2012-08-31 (annotated)

Committer:
ykuroda
Date:
Fri Aug 31 17:13:40 2012 +0000
Revision:
1:1c3a10f2eb04
Parent:
0:db7fa84ff50e
Child:
2:ea6d02ba96ae
bug fix

Who changed what in which revision?

UserRevisionLine numberNew contents of line
ykuroda 1:1c3a10f2eb04 1 //
ykuroda 1:1c3a10f2eb04 2 // RingBuffer.cpp ... General purpose ring buffer library
ykuroda 1:1c3a10f2eb04 3 //
ykuroda 1:1c3a10f2eb04 4 // Copyright 2012 Yoji KURODA
ykuroda 1:1c3a10f2eb04 5 //
ykuroda 1:1c3a10f2eb04 6 // 2009.11.13 ... Originally written in C by Y.Kuroda for Renesas H83664
ykuroda 1:1c3a10f2eb04 7 // 2012.08.31 ... Code convert for mbed in C++
ykuroda 1:1c3a10f2eb04 8 //
ykuroda 1:1c3a10f2eb04 9
ykuroda 0:db7fa84ff50e 10 #include "string.h"
ykuroda 0:db7fa84ff50e 11 #include "RingBuffer.h"
ykuroda 0:db7fa84ff50e 12
ykuroda 0:db7fa84ff50e 13
ykuroda 0:db7fa84ff50e 14 /*
ykuroda 0:db7fa84ff50e 15 * Machine Independent Area
ykuroda 0:db7fa84ff50e 16 */
ykuroda 0:db7fa84ff50e 17 RingBuffer::RingBuffer(int _bufsize)
ykuroda 0:db7fa84ff50e 18 : bufsize(_bufsize)
ykuroda 0:db7fa84ff50e 19 {
ykuroda 0:db7fa84ff50e 20 buf = new unsigned char [bufsize+1];
ykuroda 0:db7fa84ff50e 21
ykuroda 0:db7fa84ff50e 22 sp = ep = (unsigned int)buf;
ykuroda 0:db7fa84ff50e 23 memset(buf,0,bufsize);
ykuroda 0:db7fa84ff50e 24 }
ykuroda 0:db7fa84ff50e 25
ykuroda 0:db7fa84ff50e 26 RingBuffer::~RingBuffer()
ykuroda 0:db7fa84ff50e 27 {
ykuroda 0:db7fa84ff50e 28 delete [] buf;
ykuroda 0:db7fa84ff50e 29 }
ykuroda 0:db7fa84ff50e 30
ykuroda 0:db7fa84ff50e 31 int
ykuroda 0:db7fa84ff50e 32 RingBuffer::save(unsigned char c)
ykuroda 0:db7fa84ff50e 33 {
ykuroda 0:db7fa84ff50e 34 if( (ep==sp-1)||
ykuroda 0:db7fa84ff50e 35 ((sp==(unsigned int)buf)&&
ykuroda 0:db7fa84ff50e 36 (ep==(unsigned int)buf+bufsize-1)) ) /* buffer full */
ykuroda 0:db7fa84ff50e 37 return 0;
ykuroda 0:db7fa84ff50e 38
ykuroda 0:db7fa84ff50e 39 *(unsigned char*)ep = c;
ykuroda 0:db7fa84ff50e 40 ep++;
ykuroda 0:db7fa84ff50e 41
ykuroda 0:db7fa84ff50e 42 if(ep > (unsigned int)buf+bufsize)
ykuroda 0:db7fa84ff50e 43 ep = (unsigned int)buf;
ykuroda 0:db7fa84ff50e 44 return 1;
ykuroda 0:db7fa84ff50e 45 }
ykuroda 0:db7fa84ff50e 46
ykuroda 0:db7fa84ff50e 47 unsigned char
ykuroda 0:db7fa84ff50e 48 RingBuffer::read(void)
ykuroda 0:db7fa84ff50e 49 {
ykuroda 0:db7fa84ff50e 50 unsigned char ret;
ykuroda 0:db7fa84ff50e 51
ykuroda 0:db7fa84ff50e 52 if(sp == ep)
ykuroda 0:db7fa84ff50e 53 return 0; /* buffer empty */
ykuroda 0:db7fa84ff50e 54
ykuroda 0:db7fa84ff50e 55 ret = *(unsigned char*)sp;
ykuroda 0:db7fa84ff50e 56 *(unsigned char*)sp = 0;
ykuroda 0:db7fa84ff50e 57 sp++;
ykuroda 0:db7fa84ff50e 58
ykuroda 0:db7fa84ff50e 59 if(sp> (unsigned int)buf+bufsize)
ykuroda 0:db7fa84ff50e 60 sp = (unsigned int)buf;
ykuroda 0:db7fa84ff50e 61 return ret;
ykuroda 0:db7fa84ff50e 62 }
ykuroda 0:db7fa84ff50e 63
ykuroda 0:db7fa84ff50e 64 int
ykuroda 0:db7fa84ff50e 65 RingBuffer::check(void)
ykuroda 0:db7fa84ff50e 66 {
ykuroda 0:db7fa84ff50e 67 int n = ep-sp;
ykuroda 0:db7fa84ff50e 68 if(n<0)
ykuroda 0:db7fa84ff50e 69 n = bufsize-n;
ykuroda 0:db7fa84ff50e 70
ykuroda 0:db7fa84ff50e 71 return n;
ykuroda 0:db7fa84ff50e 72 }
ykuroda 0:db7fa84ff50e 73