Buffer read and peek return bool

Author: pschatzmann

examples/build-arch-log.txt

@@ -4,11 +4,11 @@ esp32:esp32:esp32s3 ./examples-stream/streams-generator-serial -> rc=0
 esp32:esp32:esp32s2 ./examples-stream/streams-generator-serial -> rc=0
 esp32:esp32:esp32c6 ./examples-stream/streams-generator-serial -> rc=0
 esp32:esp32:esp32h2 ./examples-stream/streams-generator-serial -> rc=0
-esp8266:esp8266:generic ./examples-stream/streams-generator-serial -> rc=0
+esp8266:esp8266:generic ./examples-stream/streams-generator-serial -> rc=1
 rp2040:rp2040:generic ./examples-stream/streams-generator-serial -> rc=0
-arduino:avr:nano ./examples-stream/streams-generator-serial -> rc=0
+arduino:avr:nano ./examples-stream/streams-generator-serial -> rc=1
 arduino:samd:arduino_zero_native ./examples-stream/streams-generator-serial -> rc=0
 arduino:renesas_uno:unor4wifi ./examples-stream/streams-generator-serial -> rc=0
 arduino:mbed_nano:nano33ble ./examples-stream/streams-generator-serial -> rc=0
-arduino:zephyr:nano33ble ./examples-stream/streams-generator-serial -> rc=0
-arduino:mbed_rp2040:pico ./examples-stream/streams-generator-serial -> rc=0
+arduino:zephyr:nano33ble ./examples-stream/streams-generator-serial -> rc=1
+arduino:mbed_rp2040:pico ./examples-stream/streams-generator-serial -> rc=1

examples/tests/etc/test-audiolibs/test-audiolibs.ino

@@ -0,0 +1,6 @@
+#include "AudioTools.h"
+#include "AudioTools/AudioLibs/All.h"
+
+void setup(){}
+
+void loop(){}

src/AudioTools/AudioLibs/All.h

@@ -0,0 +1,43 @@
+#pragma once
+// include to identify future compile errors
+#include "A2DPStream.h"         
+#include "AudioFFT.h"       
+#include "HLSStream.h"        
+#include "R2ROutput.h"
+#include "AudioKissFFT.h"   
+#include "I2SCodecStream.h"   
+#include "AudioBoardStream.h"   
+#include "AudioKit.h"       
+#include "RTSP.h"
+#include "AudioClientRTSP.h"    
+#include "LEDOutput.h"        
+#include "SPDIFOutput.h"
+#include "StdioStream.h"
+#include "AudioEffectsSuite.h"  
+#include "AudioServerEx.h"  
+#include "MaximilianDSP.h"    
+#include "TfLiteAudioStream.h"
+#include "AudioSTK.h"       
+#include "MemoryManager.h"    
+#include "AudioESP32ULP.h"      
+#include "Concurrency.h"    
+#include "VBANStream.h"
+#include "MozziStream.h"      
+#include "VS1053Stream.h"
+#include "PIDController.h"    
+#include "FFTEffects.h"     
+//#include "WM8960Stream.h"
+//#include "AudioFaustDSP.h"      
+//#include "AudioFaust.h"         
+//#include "PureDataStream.h"
+//#include "Jupyter.h"          
+//#include "PortAudioStream.h"
+//#include "MiniAudioStream.h"  
+//#include "AudioCmsisFFT.h"      
+//#include "AudioRealFFT.h"   
+//#include "AudioESP32FFT.h"      
+//#include "AudioEspressifFFT.h"  
+//#include "LEDOutputUnoR4.h"   
+//#include "AudioMP34DT05.h"  
+//#include "AudioESP8266.h"       
+//#include "FFTDisplay.h"     

src/AudioTools/Concurrency/RP2040/BufferRP2040.h

@@ -69,16 +69,15 @@ class BufferRP2040T : public BaseBuffer<T> {
   }
 
   // reads a single value
-  T read() {
-    T data = 0;
-    readArray(&data, 1);
-    return data;
+  bool read(T& data) {
+    return readArray(&data, 1)==1;
   }
 
+
   // peeks the actual entry from the buffer
-  T peek() {
-    LOGE("peek not implmented");
-    return 0;
+  bool peek(T &result) override {
+    LOGE("peek not implemented");
+    return false;
   }
 
   // reads multiple values

src/AudioTools/Concurrency/RTOS/BufferRTOS.h

@@ -67,10 +67,9 @@ class BufferRTOS : public BaseBuffer<T> {
   void setReadFromISR(bool active) { read_from_isr = active; }
 
   // reads a single value
-  T read() override {
+  bool read(T &result) override {
     T data = 0;
-    readArray(&data, sizeof(T));
-    return data;
+    return readArray(&data, 1)==1;
   }
 
   // reads multiple values
@@ -112,9 +111,9 @@ class BufferRTOS : public BaseBuffer<T> {
   }
 
   // peeks the actual entry from the buffer
-  T peek() override {
-    LOGE("peek not implmented");
-    return 0;
+  bool peek(T &result) override {
+    LOGE("peek not implemented");
+    return false;
   }
 
   // checks if the buffer is full

src/AudioTools/Concurrency/SynchronizedBuffer.h

@@ -1,4 +1,3 @@
-
 #pragma once
 #include "AudioToolsConfig.h"
 #include "AudioTools/CoreAudio/AudioTypes.h"
@@ -28,41 +27,31 @@ class SynchronizedBuffer : public BaseBuffer<T> {
   }
 
   // reads a single value
-  T read() override {
+  bool read(T &result) override {
     TRACED();
     LockGuard guard(p_mutex);
-    return p_buffer->read();
+    return p_buffer->read(result);
   }
 
   // reads multiple values
   int readArray(T data[], int len) {
     TRACED();
     LockGuard guard(p_mutex);
     int lenResult = MIN(len, available());
-    for (int j = 0; j < lenResult; j++) {
-      data[j] = p_buffer->read();
-    }
-    return lenResult;
+    return p_buffer->readArray(data, lenResult);
   }
 
   int writeArray(const T data[], int len) {
     LOGD("%s: %d", LOG_METHOD, len);
     LockGuard guard(p_mutex);
-    int result = 0;
-    for (int j = 0; j < len; j++) {
-      if (p_buffer->write(data[j]) == 0) {
-        break;
-      }
-      result = j + 1;
-    }
-    return result;
+    return p_buffer->writeArray(data, len);
   }
 
   // peeks the actual entry from the buffer
-  T peek() override {
+  bool peek(T &result) override {
     TRACED();
     LockGuard guard(p_mutex);
-    return p_buffer->peek();
+    return p_buffer->peek(result);
   }
 
   // checks if the buffer is full

src/AudioTools/CoreAudio/AudioAnalog/AnalogAudioArduino.h

@@ -242,8 +242,9 @@ class AnalogAudioArduino : public AudioStream {
       // Logic for writing audio data
     } else if (self->config.rx_tx_mode == TX_MODE) {
       int channels = self->config.channels;
+      uint8_t sample = 0;
       for (int j = 0; j < channels; j++) {
-        int16_t sample = self->buffer->read();
+        self->buffer->read(sample);
         int pin = self->config.pins_data[j];
         analogWrite(pin, sample);
         //LOGW("analogWrite(%d, %d)", pin, sample);

src/AudioTools/CoreAudio/AudioEffects/AudioEffect.h

@@ -441,7 +441,9 @@ class PitchShift : public AudioEffect {
     if (!active())
       return input;
     buffer.write(input);
-    return buffer.read();
+    effect_t result;
+    buffer.read(result);
+    return result;
   }
 
   PitchShift *clone() { return new PitchShift(*this); }