Mutex protected snapshot data

[pulseview.git] / pv / datasnapshot.cpp

diff --git a/pv/datasnapshot.cpp b/pv/datasnapshot.cpp
index 31acca163e71f1a1475298dca9173e0c43b0e666..040d506a95bb88d02a15e3564ecbe65619b24a95 100644 (file)
--- a/pv/datasnapshot.cpp
+++ b/pv/datasnapshot.cpp
@@ -24,6 +24,8 @@
 #include <stdlib.h>
 #include <string.h>
 
+using namespace boost;
+
 namespace pv {
 
 DataSnapshot::DataSnapshot(int unit_size) :
@@ -31,21 +33,25 @@ DataSnapshot::DataSnapshot(int unit_size) :
        _sample_count(0),
        _unit_size(unit_size)
 {
+       lock_guard<recursive_mutex> lock(_mutex);
        assert(_unit_size > 0);
 }
 
 DataSnapshot::~DataSnapshot()
 {
+       lock_guard<recursive_mutex> lock(_mutex);
        free(_data);
 }
 
 uint64_t DataSnapshot::get_sample_count()
 {
+       lock_guard<recursive_mutex> lock(_mutex);
        return _sample_count;
 }
 
 void DataSnapshot::append_data(void *data, uint64_t samples)
 {
+       lock_guard<recursive_mutex> lock(_mutex);
        _data = realloc(_data, (_sample_count + samples) * _unit_size);
        memcpy((uint8_t*)_data + _sample_count * _unit_size,
                data, samples * _unit_size);