From 61c91b3cdb2c9dd655f3adf0f461f5cefb3b2e9b Mon Sep 17 00:00:00 2001
From: jacqueline <me@jacqueline.id.au>
Date: Fri, 10 Feb 2023 15:32:21 +1100
Subject: Mostly working pipeline, including proper EOF signalling

---
 src/audio/audio_task.cpp | 10 ++++++++--
 1 file changed, 8 insertions(+), 2 deletions(-)

(limited to 'src/audio/audio_task.cpp')

diff --git a/src/audio/audio_task.cpp b/src/audio/audio_task.cpp
index 47b115cc..078aa461 100644
--- a/src/audio/audio_task.cpp
+++ b/src/audio/audio_task.cpp
@@ -28,6 +28,7 @@ namespace audio {
 static const char* kTag = "task";
 
 auto StartAudioTask(const std::string& name,
+                    std::optional<BaseType_t> core_id,
                     std::shared_ptr<IAudioElement> element)
     -> std::unique_ptr<AudioElementHandle> {
   auto task_handle = std::make_unique<TaskHandle_t>();
@@ -36,8 +37,13 @@ auto StartAudioTask(const std::string& name,
   AudioTaskArgs* args = new AudioTaskArgs{.element = element};
 
   ESP_LOGI(kTag, "starting audio task %s", name.c_str());
-  xTaskCreate(&AudioTaskMain, name.c_str(), element->StackSizeBytes(), args,
-              kTaskPriorityAudio, task_handle.get());
+  if (core_id) {
+    xTaskCreatePinnedToCore(&AudioTaskMain, name.c_str(), element->StackSizeBytes(), args,
+                kTaskPriorityAudio, task_handle.get(), *core_id);
+  } else {
+    xTaskCreate(&AudioTaskMain, name.c_str(), element->StackSizeBytes(), args,
+                kTaskPriorityAudio, task_handle.get());
+  }
 
   return std::make_unique<AudioElementHandle>(std::move(task_handle), element);
 }
-- 
cgit v1.2.3