From 4084768a3eb72026e901118e05fd17115dd785b3 Mon Sep 17 00:00:00 2001
From: Thulinma <jaron@vietors.com>
Date: Tue, 5 Jul 2022 15:21:04 +0200
Subject: [PATCH] Improved incoming push accept timing

---
 src/output/output.cpp | 7 ++++---
 1 file changed, 4 insertions(+), 3 deletions(-)

diff --git a/src/output/output.cpp b/src/output/output.cpp
index 5c785bb0..1fa86eee 100644
--- a/src/output/output.cpp
+++ b/src/output/output.cpp
@@ -2050,7 +2050,7 @@ namespace Mist{
         INFO_MSG("Waiting for stream reset before attempting push input accept (%" PRIu64 " <= %" PRIu64 "+500)", twoTime, oneTime);
         while (streamStatus != STRMSTAT_OFF && keepGoing()){
           userSelect.clear();
-          Util::wait(1000);
+          Util::wait(250);
           streamStatus = Util::getStreamStatus(streamName);
         }
         reconnect();
@@ -2059,14 +2059,15 @@ namespace Mist{
     while (((streamStatus != STRMSTAT_WAIT && streamStatus != STRMSTAT_READY) || !meta) && keepGoing()){
       INFO_MSG("Waiting for %s buffer to be ready... (%u)", streamName.c_str(), streamStatus);
       disconnect();
-      Util::wait(1000);
       streamStatus = Util::getStreamStatus(streamName);
       if (streamStatus == STRMSTAT_OFF || streamStatus == STRMSTAT_WAIT || streamStatus == STRMSTAT_READY){
         INFO_MSG("Reconnecting to %s buffer... (%u)", streamName.c_str(), streamStatus);
-        Util::wait(500);
         reconnect();
         streamStatus = Util::getStreamStatus(streamName);
       }
+      if (((streamStatus != STRMSTAT_WAIT && streamStatus != STRMSTAT_READY) || !meta) && keepGoing()){
+        Util::wait(100);
+      }
     }
     if (streamStatus == STRMSTAT_READY || streamStatus == STRMSTAT_WAIT){reconnect();}
     if (!meta){