pcm_mixer: implement mixer_switch_sink

commit 9ffc8a00ce4a24a3727bec7f243b174769e36b1c
Author: mojyack <[email protected]>
Date:   Tue Mar 31 11:52:43 2026 +0900

    pcm_mixer: implement mixer_switch_sink
    
    Change-Id: I1549470774f96a6f470817cbc5fe4611812de6fa

diff --git a/firmware/export/pcm_mixer.h b/firmware/export/pcm_mixer.h
index 0607b474f6..be0e450d2e 100644
--- a/firmware/export/pcm_mixer.h
+++ b/firmware/export/pcm_mixer.h
@@ -23,6 +23,7 @@
 #define PCM_MIXER_H
 
 #include <sys/types.h>
+#include "pcm_sink.h"
 
 /** Simple config **/
 
@@ -111,6 +112,9 @@ void mixer_channel_play_pause(enum pcm_mixer_channel channel, bool play);
 /* Stop playback on a channel */
 void mixer_channel_stop(enum pcm_mixer_channel channel);
 
+/* Switch playback sink */
+bool mixer_switch_sink(enum pcm_sink_ids sink);
+
 /* Set channel's amplitude factor */
 void mixer_channel_set_amplitude(enum pcm_mixer_channel channel,
                                  unsigned int amplitude);
diff --git a/firmware/pcm_mixer.c b/firmware/pcm_mixer.c
index e49e3648b0..fb12e53373 100644
--- a/firmware/pcm_mixer.c
+++ b/firmware/pcm_mixer.c
@@ -286,6 +286,56 @@ static void mixer_start_pcm(void)
                   start, mix_frame_size);
 }
 
+/* Notify users of samplerate change */
+static  void mixer_handle_sampr_change(unsigned int sampr)
+{
+    for (size_t i = 0; i < ARRAYLEN(active_channels) && active_channels[i]; i += 1)
+    {
+        struct mixer_channel* chan = active_channels[i];
+
+        /* Notify upstreams */
+        if (chan->play_cbs)
+        {
+            if (chan->play_cbs->sampr_changed)
+            {
+                chan->play_cbs->sampr_changed(sampr);
+            }
+            if (chan->play_cbs->get_more)
+            {
+                /* Remake buffer */
+                const void *start = NULL;
+                size_t size;
+                chan->play_cbs->get_more(&start, &size);
+                if (start && size) {
+                    chan->start = start;
+                    chan->size = size;
+                    chan->last_size = 0;
+                } else {
+                    channel_stopped(chan);
+                }
+            }
+        }
+        /* Notify buffer monitor */
+        if (chan->buf_cbs)
+        {
+            if (chan->buf_cbs->sampr_changed)
+            {
+                chan->buf_cbs->sampr_changed(sampr);
+            }
+        }
+    }
+
+    /* Work out how much space we really need */
+    if (sampr > SAMPR_96)
+        mix_frame_size = 4;
+    else if (sampr > SAMPR_48)
+        mix_frame_size = 2;
+    else
+        mix_frame_size = 1;
+
+    mix_frame_size *= MIX_FRAME_SAMPLES * 4;
+}
+
 /** Public interfaces **/
 
 /* Start playback on a channel */
@@ -371,6 +421,19 @@ void mixer_channel_stop(enum pcm_mixer_channel channel)
     pcm_play_unlock();
 }
 
+/* Switch playback sink */
+bool mixer_switch_sink(enum pcm_sink_ids sink)
+{
+    if(pcm_current_sink() == sink)
+        return true;
+
+    if(!pcm_switch_sink(sink))
+        return false;
+
+    mixer_handle_sampr_change(SAMPR_NUM(pcm_get_frequency()));
+    return true;
+}
+
 /* Set channel's amplitude factor */
 void mixer_channel_set_amplitude(enum pcm_mixer_channel channel,
                                  unsigned int amplitude)
@@ -461,53 +524,7 @@ void mixer_set_frequency(unsigned int samplerate)
         return;
 
     pcm_set_frequency(samplerate);
-
-    for (size_t i = 0; i < ARRAYLEN(active_channels) && active_channels[i]; i += 1)
-    {
-        struct mixer_channel* chan = active_channels[i];
-
-        /* Notify upstreams */
-        if (chan->play_cbs)
-        {
-            if (chan->play_cbs->sampr_changed)
-            {
-                chan->play_cbs->sampr_changed(SAMPR_NUM(samplerate));
-            }
-            if (chan->play_cbs->get_more)
-            {
-                /* Remake buffer */
-                const void *start = NULL;
-                size_t size;
-                chan->play_cbs->get_more(&start, &size);
-                if (start && size) {
-                    chan->start = start;
-                    chan->size = size;
-                    chan->last_size = 0;
-                } else {
-                    channel_stopped(chan);
-                }
-            }
-        }
-        /* Notify buffer monitor */
-        if (chan->buf_cbs)
-        {
-            if (chan->buf_cbs->sampr_changed)
-            {
-                chan->buf_cbs->sampr_changed(SAMPR_NUM(samplerate));
-            }
-        }
-    }
-
-    /* Work out how much space we really need */
-    if (SAMPR_NUM(samplerate) > SAMPR_96)
-        mix_frame_size = 4;
-    else if (SAMPR_NUM(samplerate) > SAMPR_48)
-        mix_frame_size = 2;
-    else
-        mix_frame_size = 1;
-
-    mix_frame_size *= MIX_FRAME_SAMPLES * 4;
-
+    mixer_handle_sampr_change(SAMPR_NUM(pcm_get_frequency()));
     if (pcm_is_initialized())
         pcm_apply_settings();
 }
-- 
rockbox-cvs mailing list
[email protected]
https://lists.haxx.se/mailman/listinfo/rockbox-cvs