fix: قراءة واحدة مشتركة للمعالج/الرام من cgroup

app.py

@@ -632,30 +632,81 @@ def _cgroup_quota_cpus():
         pass
     return None
 
+def _cgroup_mem():
+    """حدّ الذاكرة والمستهلك منها **لهذه الحاوية** بالميغابايت (لا للخادم المشترك).
+
+    /proc/meminfo يصف الآلة المضيفة كاملة (16 نواة و126 غيغا) بينما لوحة Hugging
+    Face تعرض حصّة الـSpace نفسها (2 vCPU و16 غيغا) — فكان الرقمان يصفان شيئين
+    مختلفين. cgroup v2 يعطي ما تراه الحاوية فعلًا، فيتطابق الرقمان.
+    """
+    def _read(path):
+        try:
+            return open(path).read().strip()
+        except Exception:
+            return ''
+    limit=(_read('/sys/fs/cgroup/memory.max') or _read('/sys/fs/cgroup/memory.high')
+           or _read('/sys/fs/cgroup/memory/memory.limit_in_bytes'))
+    if limit=='max':
+        limit=_read('/sys/fs/cgroup/memory.high')
+    used=_read('/sys/fs/cgroup/memory.current') or _read('/sys/fs/cgroup/memory/memory.usage_in_bytes')
+    try:
+        used_mb=int(used)//1048576 if used else None
+    except ValueError:
+        used_mb=None
+    try:
+        limit_mb=int(limit)//1048576 if limit and limit!='max' else None
+    except ValueError:
+        limit_mb=None
+    # قيمة خيالية (أكبر من ذاكرة المضيف) تعني «بلا حدّ» على هذا النظام.
+    if limit_mb and limit_mb>1024*1024:
+        limit_mb=None
+    return limit_mb,used_mb
+
+
 _cpu_lock=threading.Lock()
 _cpu_sample={'t':None,'ns':None}
+# قراءة واحدة يتشاركها كل القرّاء خلال هذه النافذة. السبب: العيّنة ذات حالة
+# (فرقٌ عن الاستدعاء السابق)، وكان /health و/api/state يصفّر كلٌّ منهما أساس
+# الآخر ⇒ رقمان مختلفان للحظة واحدة، أو «—» إذا قلّ الفاصل عن 0.4ث.
+_RES_TTL=2.0
+_res_cache={'t':None,'data':None}
 
 def resource_snapshot():
-    """Host loadavg (shared machine) plus this Space cgroup quota (cpu-basic = 2)."""
-    out={'load1':None,'cpus':os.cpu_count() or 1,'mem_total_mb':None,'mem_avail_mb':None,
-         'quota_cpus':None,'cpu_cores_used':None,'cpu_pct_of_quota':None}
-    try:
-        out['load1']=float(open('/proc/loadavg').read().split()[0])
-    except Exception:
-        pass
-    try:
-        info={}
-        for line in open('/proc/meminfo'):
-            parts=line.split()
-            if len(parts)>=2:info[parts[0].rstrip(':')]=int(parts[1])
-        out['mem_total_mb']=info.get('MemTotal',0)//1024
-        out['mem_avail_mb']=info.get('MemAvailable', info.get('MemFree',0))//1024
-    except Exception:
-        pass
-    out['quota_cpus']=_cgroup_quota_cpus()
-    ns=_cgroup_usage_ns()
-    now=time.monotonic()
+    """حصّة هذا الـSpace من المعالج والذاكرة (cgroup)، لا عتاد الخادم المشترك.
+
+    القفل يغطّي الدالة كاملة: استدعاءان متزامنان يعيدان نفس القراءة بدل أن
+    يُفسد كلٌّ منهما عيّنة الآخر.
+    """
     with _cpu_lock:
+        now=time.monotonic()
+        cached=_res_cache['data']
+        if cached is not None and _res_cache['t'] is not None and now-_res_cache['t']<_RES_TTL:
+            return dict(cached)
+        out={'load1':None,'cpus':os.cpu_count() or 1,'mem_total_mb':None,'mem_avail_mb':None,
+             'quota_cpus':None,'cpu_cores_used':None,'cpu_pct_of_quota':None}
+        try:
+            out['load1']=float(open('/proc/loadavg').read().split()[0])
+        except Exception:
+            pass
+        lim,used=_cgroup_mem()
+        if lim:
+            out['mem_total_mb']=lim
+            out['mem_avail_mb']=max(0,lim-(used or 0))
+        else:
+            try:
+                info={}
+                for line in open('/proc/meminfo'):
+                    parts=line.split()
+                    if len(parts)>=2:info[parts[0].rstrip(':')]=int(parts[1])
+                out['mem_total_mb']=info.get('MemTotal',0)//1024
+                out['mem_avail_mb']=info.get('MemAvailable', info.get('MemFree',0))//1024
+            except Exception:
+                pass
+        out['quota_cpus']=_cgroup_quota_cpus()
+        if out['quota_cpus']:
+            # «عدد الأنوية» في اللوحة هو حصّة الـSpace لا أنوية الخادم المشترك.
+            out['cpus']=out['quota_cpus']
+        ns=_cgroup_usage_ns()
         prev=_cpu_sample
         if prev['t'] is not None and prev['ns'] is not None and ns is not None and now-prev['t']>=0.4:
             cores=(ns-prev['ns'])/1e9/(now-prev['t'])
@@ -664,9 +715,15 @@ def resource_snapshot():
             q=out['quota_cpus']
             if q and q>0:
                 out['cpu_pct_of_quota']=round(min(999.0, max(0.0, 100.0*cores/q)),2)
+        elif cached is not None:
+            # نافذة أقصر من 0.4ث: أعد آخر نسبة معروفة بدل «—».
+            out['cpu_cores_used']=cached.get('cpu_cores_used')
+            out['cpu_pct_of_quota']=cached.get('cpu_pct_of_quota')
         _cpu_sample['t']=now
         _cpu_sample['ns']=ns
-    return out
+        _res_cache['t']=now
+        _res_cache['data']=dict(out)
+        return dict(out)
 
 def _check_account(user):
     """One monitor cycle. Starts DirectRelay when OAuth automation is off."""
@@ -934,6 +991,7 @@ def state():
         try:active=sum(1 for e in youtube.senders.values() if e.get('thread') and e['thread'].is_alive())
         except Exception:pass
         last_error, last_error_user=_pick_last_error(tasks)
+        _res=resource_snapshot()
         return {'tasks':task_list,'logs':events[-80:],'version':APP_VERSION,'last_error_user':last_error_user,
                 'max_accounts':MAX_ACCOUNTS if MAX_ACCOUNTS is not None else 'بلا حد',
                 'tiktok':tiktok_state,'check_interval':INTERVAL,
@@ -941,7 +999,7 @@ def state():
                 'monitor_running':_monitor_alive.is_set(),
                 'active_relays':hub.active_count(),'last_monitor_cycle':_last_monitor_cycle,
                 'max_concurrent_relays':max_concurrent_relays(),
-                **{k:resource_snapshot().get(k) for k in ('load1','cpus','mem_total_mb','mem_avail_mb','quota_cpus','cpu_cores_used','cpu_pct_of_quota')},
+                **{k:_res.get(k) for k in ('load1','cpus','mem_total_mb','mem_avail_mb','quota_cpus','cpu_cores_used','cpu_pct_of_quota')},
                 'last_error':last_error,'rtmp_configured':rtmp_configured(),
                 'oauth_configured':youtube.api.configured(),
                 'metadata_automation':_oauth_automation_on(),