Update gunicorn_config.py

gunicorn_config.py

@@ -2,6 +2,9 @@
 Gunicorn configuration for Main DB Server.
 Optimized for 50+ servers making constant requests.
 Must handle 1000+ requests per minute reliably.
+
+IMPORTANT: preload_app is False so each worker initializes
+its own MainMemoryDB instance. Workers sync via /dev/shm shared files.
 """
 
 import os
@@ -47,8 +50,11 @@ graceful_timeout = 30
 max_requests = 0
 max_requests_jitter = 0
 
-# Preload app for faster worker startup and shared memory
-preload_app = True
+# DO NOT preload app - each worker must initialize its own DB instance
+# Workers sync data via shared memory files in /dev/shm/maindb/
+# If preload_app = True, forked workers get separate RAM copies
+# that never sync with each other = DATA INCONSISTENCY BUG
+preload_app = False
 
 # Use /dev/shm for temp files (RAM-based, faster than disk)
 worker_tmp_dir = "/dev/shm"
@@ -80,15 +86,38 @@ loglevel = os.environ.get("LOG_LEVEL", "info")
 # ═══════════════════════════════════════════════════════════════
 
 def on_starting(server):
+    """Called just before the master process is initialized."""
+    # Create shared memory directory before workers start
+    shared_dir = os.environ.get("SHARED_DATA_DIR", "/dev/shm/maindb")
+    os.makedirs(shared_dir, exist_ok=True)
+
     print("\n" + "═" * 60)
     print("  🗄️  Main DB Registry - Starting Production Server")
     print("  ⚡ 2 Workers + Gevent + 4000 Total Connections")
     print("  🔌 Keep-Alive: 65 seconds")
-    print("  📊 Designed for 50+ servers, 1000+ req/min")
+    print("  🔊 Designed for 50+ servers, 1000+ req/min")
+    print("  🔄 Workers sync via /dev/shm/maindb/ shared files")
+    print("  ⚠️  preload_app = False (each worker inits own DB)")
     print("═" * 60 + "\n")
 
 
+def post_fork(server, worker):
+    """Called after each worker is forked."""
+    print(f"  🔄 Worker PID {worker.pid} forked - will init DB on first request")
+
+
+def worker_int(worker):
+    """Called when a worker receives SIGINT."""
+    print(f"  ⚠️ Worker PID {worker.pid} received SIGINT")
+
+
+def worker_abort(worker):
+    """Called when a worker receives SIGABRT (timeout)."""
+    print(f"  ❌ Worker PID {worker.pid} aborted (timeout?)")
+
+
 def on_exit(server):
+    """Called just before exiting Gunicorn."""
     print("\n  🛑 Main DB Registry shutting down...")
     try:
         from memory import get_db
@@ -99,4 +128,14 @@ def on_exit(server):
         else:
             print(f"  ❌ Final backup failed: {errors}")
     except Exception as e:
-        print(f"  ⚠️ Shutdown backup error: {e}")
+        print(f"  ⚠️ Shutdown backup error: {e}")
+
+    # Clean up shared memory files
+    try:
+        shared_dir = os.environ.get("SHARED_DATA_DIR", "/dev/shm/maindb")
+        if os.path.exists(shared_dir):
+            import shutil
+            shutil.rmtree(shared_dir, ignore_errors=True)
+            print("  🧹 Cleaned up shared memory files")
+    except Exception as e:
+        print(f"  ⚠️ Cleanup error: {e}")