-
Notifications
You must be signed in to change notification settings - Fork 0
/
Copy pathRingBufCPP.h
159 lines (125 loc) · 2.14 KB
/
RingBufCPP.h
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
#ifndef EM_RINGBUF_CPP_H
#define EM_RINGBUF_CPP_H
#include "RingBufHelpers.h"
template <typename Type, size_t MaxElements>
class RingBufCPP
{
public:
RingBufCPP()
{
RB_ATOMIC_START
{
_numElements = 0;
_head = 0;
}
RB_ATOMIC_END
}
/**
* Add element obj to the buffer
* Return: true on success
*/
bool add(const Type &obj)
{
bool ret = false;
RB_ATOMIC_START
{
if (!isFull()) {
_buf[_head] = obj;
_head = (_head + 1)%MaxElements;
_numElements++;
ret = true;
}
}
RB_ATOMIC_END
return ret;
}
/**
* Remove last element from buffer, and copy it to dest
* Return: true on success
*/
bool pull(Type *dest)
{
bool ret = false;
size_t tail;
RB_ATOMIC_START
{
if (!isEmpty()) {
tail = getTail();
*dest = _buf[tail];
_numElements--;
ret = true;
}
}
RB_ATOMIC_END
return ret;
}
/**
* Peek at num'th element in the buffer
* Return: a pointer to the num'th element
*/
Type* peek(size_t num)
{
Type *ret = NULL;
RB_ATOMIC_START
{
if (num < _numElements) //make sure not out of bounds
ret = &_buf[(getTail() + num)%MaxElements];
}
RB_ATOMIC_END
return ret;
}
/**
* Return: true if buffer is full
*/
bool isFull() const
{
bool ret;
RB_ATOMIC_START
{
ret = _numElements >= MaxElements;
}
RB_ATOMIC_END
return ret;
}
/**
* Return: number of elements in buffer
*/
size_t numElements() const
{
size_t ret;
RB_ATOMIC_START
{
ret = _numElements;
}
RB_ATOMIC_END
return ret;
}
/**
* Return: true if buffer is empty
*/
bool isEmpty() const
{
bool ret;
RB_ATOMIC_START
{
ret = !_numElements;
}
RB_ATOMIC_END
return ret;
}
protected:
/**
* Calculates the index in the array of the oldest element
* Return: index in array of element
*/
size_t getTail() const
{
return (_head + (MaxElements - _numElements))%MaxElements;
}
// underlying array
Type _buf[MaxElements];
size_t _head;
size_t _numElements;
private:
};
#endif