From: Alan <alan@roojs.com>
Date: Thu, 12 Oct 2023 04:56:11 +0000 (+0800)
Subject: dont add if queue len to large already
X-Git-Url: http://git.roojs.org/?p=Pman.Core;a=commitdiff_plain;h=bf4c3855253f5330943cd86509d756255c8c6596

dont add if queue len to large already
---

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) {