@@ -28,7 +28,7 @@ int CircularBufferFile::close()
28
28
return 0 ;
29
29
}
30
30
31
- CircularBufferFile::~CircularBufferFile (){}
31
+ CircularBufferFile::~CircularBufferFile () {}
32
32
33
33
void CircularBufferFile::api_lock (void )
34
34
{
@@ -40,13 +40,14 @@ void CircularBufferFile::api_unlock(void)
40
40
_mutex.unlock ();
41
41
}
42
42
43
- ssize_t CircularBufferFile::write (const void * buffer, size_t size) {
44
- const char * b = static_cast <const char *>(buffer);
43
+ ssize_t CircularBufferFile::write (const void *buffer, size_t size)
44
+ {
45
+ const char *b = static_cast <const char *>(buffer);
45
46
if (size == 0 ) {
46
47
return 0 ;
47
48
}
48
49
api_lock ();
49
- for ( size_t i = 0 ; i < size; i++){
50
+ for (size_t i = 0 ; i < size; i++) {
50
51
_buffer.push (b[i]);
51
52
}
52
53
api_unlock ();
@@ -55,8 +56,9 @@ ssize_t CircularBufferFile::write(const void* buffer, size_t size) {
55
56
}
56
57
57
58
// Read is a forward iterator stream
58
- ssize_t CircularBufferFile::read (void *buffer, size_t size){
59
- char * b = static_cast <char *>(buffer);
59
+ ssize_t CircularBufferFile::read (void *buffer, size_t size)
60
+ {
61
+ char *b = static_cast <char *>(buffer);
60
62
size_t i = 0 ;
61
63
if (size == 0 ) {
62
64
return 0 ;
@@ -73,8 +75,7 @@ ssize_t CircularBufferFile::read(void *buffer, size_t size){
73
75
api_lock ();
74
76
}
75
77
i = 0 ;
76
- while (i < size && !_buffer.empty ())
77
- {
78
+ while (i < size && !_buffer.empty ()) {
78
79
_buffer.pop (b[i++]);
79
80
}
80
81
api_unlock ();
0 commit comments