dont add if queue len to large already
authorAlan <alan@roojs.com>
Thu, 12 Oct 2023 04:56:11 +0000 (12:56 +0800)
committerAlan <alan@roojs.com>
Thu, 12 Oct 2023 04:56:11 +0000 (12:56 +0800)
DataObjects/Core_notify_server.php

index aa625c1..10db21f 100644 (file)
@@ -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) {