Add mutexes to AudioBuffer

audiobuffer.cpp

@@ -13,29 +13,55 @@ AudioBuffer::~AudioBuffer()
 
 qint64 AudioBuffer::readData(char *data, qint64 len)
 {
-    const qint64 total = qMin((qint64)buffer.size(), len);
-    memcpy(data, buffer.constData(), total);
-    buffer = buffer.mid(total);
+    bufferMutex.lock();
+    try {
+        const qint64 total = qMin((qint64)buffer.size(), len);
+        memcpy(data, buffer.constData(), total);
+        buffer = buffer.mid(total);
+    }
+    catch (...)
+    {
+        bufferMutex.unlock();
+        return 0;
+    }
+    bufferMutex.unlock();
     return total;
 }
 
 qint64 AudioBuffer::writeData(const char* data, qint64 len)
 {
-    buffer.append(data, len);
+    bufferMutex.lock();
+    try {
+        buffer.append(data, len);
+    }
+    catch (...)
+    {
+        bufferMutex.unlock();
+        return 0;
+    }
+    bufferMutex.unlock();
     return len;
 }
 
 qint64 AudioBuffer::bytesAvailable() const
 {
-    return buffer.size() + QIODevice::bytesAvailable();
+    bufferMutex.lock();
+    long long size = buffer.size() + QIODevice::bytesAvailable();
+    bufferMutex.unlock();
+    return size;
 }
 
 qint64 AudioBuffer::bufferSize() const
 {
-    return buffer.size();
+    bufferMutex.lock();
+    long long size = buffer.size();
+    bufferMutex.unlock();
+    return size;
 }
 
 void AudioBuffer::clear()
 {
+    bufferMutex.lock();
     buffer.clear();
+    bufferMutex.unlock();
 }

audiobuffer.h

@@ -3,6 +3,7 @@
 
 #include <QIODevice>
 #include <QByteArray>
+#include <QMutex>
 
 class AudioBuffer : public QIODevice
 {
@@ -19,6 +20,7 @@ public:
 
 private:
     QByteArray buffer;
+    mutable QMutex bufferMutex;
 };
 
 #endif // AUDIOBUFFER_H