v2.37-fill-span: bound watchdog fill exemption + pump renewal by whole fill episode (fill_until)

ingest.py

@@ -6,7 +6,7 @@ import os, threading, time
 from datetime import datetime
 from zoneinfo import ZoneInfo
 
-APP_VERSION = 'relay-v2.36-fill-renewal'
+APP_VERSION = 'relay-v2.37-fill-span'
 
 
 def env_rtmp_destination():

relay.py

@@ -763,7 +763,8 @@ class Sender:
                     # خياطة ليس دليل موت خرج (مقيس: 13:06:13 و13:21:46 و10:24:57).
                     # نجدّد بمهل قصيرة ما دام الحشو قائمًا، وسقف الحشو (90 ث) نفسه
                     # يحدّ الصبر الكلي، فلا تعليق أبديًا ولا قتل لجلسة تُنقَذ.
-                    if sess is not None and sess.get('filling') and not sess.get('force_stop'):
+                    if (sess is not None and sess.get('filling') and not sess.get('force_stop')
+                            and time.monotonic() < float(sess.get('fill_until') or 0)):
                         deadline = time.monotonic() + 2.0
                         continue
                     raise SourceStalled('أنبوب FFmpeg ممتلئ ولا يقرأ منذ %.0f ث' % max(0.0, -left))
@@ -799,7 +800,7 @@ class Sender:
         stdin، ويوتيوب يبقى مستقبِلًا على آخر ما وصل — لذا يُقاس تدفق البيانات لا حالة العملية.
         """
         sess.setdefault('stdin_lock', threading.Lock())
-        sess.setdefault('filling', False); sess.setdefault('filling_at', 0.0); sess.setdefault('fill_emit_at', 0.0); sess.setdefault('reattach_at', 0.0)
+        sess.setdefault('filling', False); sess.setdefault('filling_at', 0.0); sess.setdefault('fill_emit_at', 0.0); sess.setdefault('reattach_at', 0.0); sess.setdefault('fill_since', 0.0); sess.setdefault('fill_until', 0.0)
         it = response.iter_content(None).__iter__()
         deadline = time.monotonic() + sess['max_seconds']
         chunk_wait = min(read_timeout, max(1.0, self._stall_seconds() / 3.0)) if self._stall_seconds() else read_timeout
@@ -1089,7 +1090,7 @@ class Sender:
                 'stall_reason': '', 'spawned': False, 'spawn_error': '',
                 'writing': False, 'output_failure': False, 'connection_event': False,
                 'ff_last': time.monotonic(),
-                'stdin_lock': threading.Lock(), 'filling': False, 'filling_at': 0.0, 'fill_emit_at': 0.0, 'reattach_at': 0.0}
+                'stdin_lock': threading.Lock(), 'filling': False, 'filling_at': 0.0, 'fill_emit_at': 0.0, 'fill_since': 0.0, 'fill_until': 0.0, 'reattach_at': 0.0}
         self.set(status='الاتصال بيوتيوب', source=candidate['label'], output_seconds=0,
                  last_output_at=None, stalled=False, last_source_at=sess['last'], source_bytes=0,
                  rtmp_phase='')
@@ -1285,6 +1286,7 @@ class Sender:
                             sess['filling']=False;continue
                         if fill_state['started'] is None:
                             fill_state['started']=now_f;fill_state['last_emit']=0.0
+                            sess['fill_since']=now_f;sess['fill_until']=now_f+fill_max+25.0
                             self.log(user,'[FILL] صمت المصدر %.0f ث؛ حشو بإطار مجمّد حتى لا يرى يوتيوب فجوة (سقف %.0f ث)'%(silent_for,fill_max))
                             log_event(user,'GAP_FILL_START',{'silent_seconds':round(silent_for,1),'cap_seconds':fill_max})
                             telemetry_event(tele_key,user,'GAP_FILL_START',{'silent_seconds':round(silent_for,1),'cap_seconds':fill_max})
@@ -1406,7 +1408,7 @@ class Sender:
                         continue
                 if (stall_limit and now - _fresh > stall_limit and
                         (not recent_attach or sess.get('output_failure') or sess.get('writing')) and
-                        not (sess.get('filling') and now-float(sess.get('filling_at') or 0)<10) and
+                        not (sess.get('filling') and now<float(sess.get('fill_until') or 0)) and
                         (not sess.get('swapping') or swap_for > stall_limit)):
                     # A full stdin pipe proves the source delivered a chunk but FFmpeg stopped
                     # consuming it. Reopening TikTok cannot repair a blocked RTMPS output.