No need to produce more frames then consumed

Author: ewowi

src/MoonLight/Modules/ModuleLightsControl.h

@@ -372,7 +372,7 @@ class ModuleLightsControl : public Module {
             extern SemaphoreHandle_t swapMutex;
 
             xSemaphoreTake(swapMutex, portMAX_DELAY);
-            _socket->emitEvent("monitor", (char*)layerP.lights.channelsD, MIN(layerP.lights.header.nrOfChannels, layerP.lights.maxChannels));
+            _socket->emitEvent("monitor", (char*)layerP.lights.channelsE, MIN(layerP.lights.header.nrOfChannels, layerP.lights.maxChannels));
             xSemaphoreGive(swapMutex);
           }
         });

src/main.cpp

@@ -128,22 +128,28 @@ void effectTask(void* pvParameters) {
 
   while (true) {
     if (layerP.lights.useDoubleBuffer) {
-      // effectTask always writes to channelsBack, reads previous channelsBack
-      layerP.loop();  // getRGB and setRGB both use channelsBack
-
-      if (millis() - last20ms >= 20) {
-        last20ms = millis();
-        layerP.loop20ms();
-      }
-
-      // Atomic swap channels
       xSemaphoreTake(swapMutex, portMAX_DELAY);
-      uint8_t* temp = layerP.lights.channelsD;
-      layerP.lights.channelsD = layerP.lights.channelsE;
-      layerP.lights.channelsE = temp;
-      newFrameReady = true;
+      bool canProduce = !newFrameReady;
       xSemaphoreGive(swapMutex);
 
+      if (canProduce) {
+        // effectTask always writes to channelsBack, reads previous channelsBack
+        layerP.loop();  // getRGB and setRGB both use channelsBack
+
+        if (millis() - last20ms >= 20) {
+          last20ms = millis();
+          layerP.loop20ms();
+        }
+
+        // Atomic swap channels
+        xSemaphoreTake(swapMutex, portMAX_DELAY);
+        uint8_t* temp = layerP.lights.channelsD;
+        layerP.lights.channelsD = layerP.lights.channelsE;
+        layerP.lights.channelsE = temp;
+        newFrameReady = true;
+        xSemaphoreGive(swapMutex);
+      }
+
     } else {
       // Single buffer mode
       xSemaphoreTake(swapMutex, portMAX_DELAY);
@@ -167,9 +173,9 @@ void driverTask(void* pvParameters) {
   // layerP.setup() done in effectTask
 
   while (true) {
-    xSemaphoreTake(swapMutex, portMAX_DELAY);
     esp32sveltekit.lps++;
-
+    
+    xSemaphoreTake(swapMutex, portMAX_DELAY);
     if (layerP.lights.useDoubleBuffer) {
       if (newFrameReady) {
         newFrameReady = false;