Concurrency for RP2040

Author: pschatzmann

examples/examples-communication/a2dp/basic-player-a2dp/basic-player-a2dp.ino

@@ -23,7 +23,7 @@ const char* ext="mp3";
 AudioSourceSDFAT source(startFilePath, ext, PIN_AUDIO_KIT_SD_CARD_CS);
 MP3DecoderHelix decoder;
 //Setup of synchronized buffer
-SynchronizedNBuffer<uint8_t> buffer(buffer_size,buffer_count, portMAX_DELAY, 10);
+SynchronizedNBuffer buffer(buffer_size,buffer_count, portMAX_DELAY, 10);
 QueueStream<uint8_t> out(buffer); // convert Buffer to Stream
 AudioPlayer player(source, out, decoder);
 BluetoothA2DPSource a2dp;

examples/examples-communication/http-client/streams-url_mp3-pwm/streams-url_mp3-pwm.ino

@@ -0,0 +1,49 @@
+/**
+ * @file streams-url_mp3-out.ino
+ * @author Phil Schatzmann
+ * @brief decode MP3 stream from url and output it with the help of PWM
+ * @version 0.1
+ * @date 2021-96-25
+ * 
+ * @copyright Copyright (c) 2021
+ */
+
+// install https://github.com/pschatzmann/arduino-libhelix.git
+
+#include "AudioTools.h"
+#include "AudioTools/AudioCodecs/CodecMP3Helix.h"
+
+
+URLStream url("ssid","password");
+PWMAudioOutput out; // final output of decoded stream
+EncodedAudioStream dec(&out, new MP3DecoderHelix()); // Decoding stream
+StreamCopy copier(dec, url); // copy url to decoder
+
+
+void setup(){
+  Serial.begin(115200);
+  AudioToolsLogger.begin(Serial, AudioToolsLogLevel::Info);  
+
+  // setup out
+  auto config = out.defaultConfig(TX_MODE);
+  //config.resolution = 8;  // must be between 8 and 11 -> drives pwm frequency (8 is default)
+  // alternative 1
+  //config.start_pin = 3;
+  // alternative 2
+  int pins[] = {22, 23};
+  // alternative 3
+  //Pins pins = {3};
+  //config.setPins(pins); 
+  out.begin(config);
+
+  // setup I2S based on sampling rate provided by decoder
+  dec.begin();
+
+// mp3 radio
+  url.begin("http://stream.srg-ssr.ch/m/rsj/mp3_128","audio/mp3");
+
+}
+
+void loop(){
+  copier.copy();
+}

examples/tests/basic/test-queue/test-queue.ino

@@ -1,6 +1,6 @@
 #include "AudioTools.h"
 #include "AudioTools/Concurrency/QueueLockFree.h"
-#include "AudioTools/Concurrency/QueueRTOS.h"
+#include "AudioTools/Concurrency/RTOS/QueueRTOS.h"
 
 // test different queue implementations:
 

examples/tests/concurrency/BufferRTOS/BufferRTOS.ino

@@ -9,7 +9,7 @@
  *
  */
 #include "AudioTools.h"
-#include "AudioTools/AudioLibs/Concurrency.h"
+#include "AudioTools/Concurrency/RTOS.h"
 
 BufferRTOS<int16_t> buffer(512 * 10);
 

examples/tests/concurrency/NBuffer/NBuffer.ino

@@ -9,7 +9,6 @@
  *
  */
 #include "AudioTools.h"
-#include "AudioTools/AudioLibs/Concurrency.h"
 
 NBuffer<int16_t> buffer(512, 4);
 

examples/tests/concurrency/SynchronizedNBuffer/SynchronizedNBuffer.ino

@@ -1,15 +1,15 @@
 
 #include "AudioTools.h"
 #include "AudioTools/AudioLibs/AudioBoardStream.h"
-#include "AudioTools/AudioLibs/Concurrency.h"
+#include "AudioTools/Concurrency/RTOS.h"
 
 AudioInfo info(44100, 2, 16);
 // source and sink
 SineWaveGenerator<int16_t> sineWave(32000);               
 GeneratedSoundStream<int16_t> sound(sineWave); 
 AudioBoardStream out(AudioKitEs8388V1);
 // queue
-// SynchronizedNBuffer<uint8_t> buffer(1024, 10);
+// SynchronizedNBuffer buffer(1024, 10);
 BufferRTOS<uint8_t> buffer(1024 * 10);
 QueueStream<uint8_t> queue(buffer);
 // copy

examples/tests/concurrency/audio-test/audio-test.ino

@@ -9,9 +9,9 @@
  *
  */
 #include "AudioTools.h"
-#include "AudioTools/AudioLibs/Concurrency.h"
+#include "AudioTools/Concurrency/RTOS.h"
 
-audio_tools::Mutex mutex;
+MutexRTOS mutex;
 NBuffer<int16_t> nbuffer(512, 10);
 SynchronizedBuffer<int16_t> buffer(nbuffer, mutex);
 

examples/tests/concurrency/synchNBuffer/synchNBuffer.ino

@@ -9,9 +9,9 @@
  *
  */
 #include "AudioTools.h"
-#include "AudioTools/AudioLibs/Concurrency.h"
+#include "AudioTools/Concurrency/RTOS.h"
 
-audio_tools::Mutex mutex;
+MutexRTOS mutex;
 RingBuffer<int16_t> nbuffer(512 * 4);
 SynchronizedBuffer<int16_t> buffer(nbuffer, mutex);
 

examples/tests/concurrency/synchRingBuffer/synchRingBuffer.ino

@@ -21,7 +21,7 @@ const char *startFilePath = "/";
 const char *ext = "mp3";
 AudioSourceSDFAT source(startFilePath, ext, PIN_AUDIO_KIT_SD_CARD_CS);
 MP3DecoderHelix decoder;
-SynchronizedNBuffer<uint8_t> buffer(buffer_size, buffer_count, portMAX_DELAY,
+SynchronizedNBuffer buffer(buffer_size, buffer_count, portMAX_DELAY,
                                     10);
 QueueStream<uint8_t> out(buffer);  // convert Buffer to Stream
 AudioPlayer player(source, out, decoder);