From bf4c3855253f5330943cd86509d756255c8c6596 Mon Sep 17 00:00:00 2001
From: Alan <alan@roojs.com>
Date: Thu, 12 Oct 2023 12:56:11 +0800
Subject: [PATCH] dont add if queue len to large already

---
 DataObjects/Core_notify_server.php | 7 ++++---
 1 file changed, 4 insertions(+), 3 deletions(-)

diff --git a/DataObjects/Core_notify_server.php b/DataObjects/Core_notify_server.php
index aa625c1b..10db21f9 100644
--- a/DataObjects/Core_notify_server.php
+++ b/DataObjects/Core_notify_server.php
@@ -191,8 +191,7 @@ class Pman_Core_DataObjects_Core_notify_server extends DB_DataObject
                 sent < '2000-01-01'
                 and
                 event_id = 0
-                and
-                act_start < NOW() +  INTERVAL 3 HOUR 
+        
                 and
                 server_id IN (" . implode(",", $ids) . ")
         ");
@@ -209,7 +208,9 @@ class Pman_Core_DataObjects_Core_notify_server extends DB_DataObject
         $target_len = floor(  ($totalq + $total_add) / $num_servers );
         
         foreach($in_q as $sid => $cq) {
-            
+            if ( $target_len - $cq < 1) {
+                continue;
+            }
             $up[ $sid ] = array_slice($to_add, 0, $target_len - $cq);
         }
         foreach($to_add as $i) {
-- 
2.39.2