DIAG: env diff + delayed listener re-dump

app.py

@@ -69,22 +69,23 @@ def _dump_env(pid):
     print(f"DIAGENV{pid} " + " ".join(f"{k}={v}" for k, v in picks.items()))
 
 
-def _dump():
-    print("DIAGENV " + " ".join(
-        f"{k}={os.environ.get(k)}" for k in (
-            "GRADIO_SSR_MODE", "PORT", "GRADIO_SERVER_PORT",
-            "GRADIO_SERVER_NAME", "GRADIO_NODE_PATH", "SPACES_ZERO_GPU",
-            "SPACES_ZERO_DEVICE_API_URL", "ZEROGPU_V2",
-            "GRADIO_NUM_WORKERS", "NODE_PATH", "HOME",
-        )
-    ))
-    print("DIAGPROC " + " | ".join(x for x in (
-        _procinfo(p) for p in ("1", "2", "224", "239", "7860")
-    ) if x))
-    _dump_env("1")
-    _dump_env("224")
+def _dump_env_diff():
+    try:
+        e1 = open("/proc/1/environ").read().replace("\x00", "\n").splitlines()
+        e2 = open("/proc/224/environ").read().replace("\x00", "\n").splitlines()
+        d1, d2 = dict(l.split("=", 1) for l in e1 if "=" in l), dict(l.split("=", 1) for l in e2 if "=" in l)
+        only1 = sorted(set(d1) - set(d2))
+        only2 = sorted(set(d2) - set(d1))
+        print("DIAGDIFF only1=" + ",".join(only1) if only1 else "DIAGDIFF only1=none")
+        print("DIAGDIFF only2=" + ",".join(only2) if only2 else "DIAGDIFF only2=none")
+    except OSError:
+        pass
+
+
+def _listeners():
     ino = _fmt_ino()
     import socket as sk
+    out = []
     for proto in ("/proc/net/tcp", "/proc/net/tcp6"):
         try:
             with open(proto) as f:
@@ -97,15 +98,41 @@ def _dump():
                     af = sk.AF_INET6 if proto.endswith("6") else sk.AF_INET
                     ip = sk.inet_ntop(af, bytes.fromhex(ip_hex))
                     port = int(port_hex, 16)
-                    owner = ino.get(p[9], "?")
-                    print(f"DIAGL {ip}:{port} pid={owner}")
+                    out.append((ip, port, ino.get(p[9], "?")))
         except OSError:
             continue
+    return out
+
+
+def _dump():
+    print("DIAGENV " + " ".join(
+        f"{k}={os.environ.get(k)}" for k in (
+            "GRADIO_SSR_MODE", "PORT", "GRADIO_SERVER_PORT",
+            "GRADIO_SERVER_NAME", "GRADIO_NODE_PATH", "SPACES_ZERO_GPU",
+            "SPACES_ZERO_DEVICE_API_URL", "ZEROGPU_V2",
+            "GRADIO_NUM_WORKERS", "NODE_PATH", "HOME",
+        )
+    ))
+    print("DIAGPROC " + " | ".join(x for x in (
+        _procinfo(p) for p in ("1", "2", "224", "239", "7860")
+    ) if x))
+    _dump_env("1")
+    _dump_env("224")
+    print("DIAGL " + " | ".join(f"{ip}:{port}={owner}" for ip, port, owner in _listeners()))
 
 
 demo.launch(server_name="0.0.0.0", prevent_thread_lock=True)
 
 _dump()
+_dump_env_diff()
 
 import time
+time.sleep(20)
+print("DIAGL2 " + " | ".join(
+    f"{ip}:{port}={owner}" for ip, port, owner in _listeners()
+))
+if os.path.exists("/proc/224"):
+    print("DIAG224 alive after 20s")
+else:
+    print("DIAG224 EXITED")
 time.sleep(3600)