$w = DB_DataObject::factory($this->table);
$total = 0;
+
+
+ $ff = HTML_FlexyFramework::get();
+ if (!empty($ff->Core_Notify['servers'])) {
+ if (!isset($ff->Core_Notify['servers'][gethostname()])) {
+ $this->jerr("Core_Notify['servers']['" . gethostname() ."'] is not set");
+ }
+ $w->server_id = array_search(gethostname(),array_keys($ff->Core_Notify['servers']));
+ }
+ if (!empty($this->evtype)) {
+ $w->evtype = $this->evtype;
+ }
+
+
+
if (!empty($opts['old'])) {
// show old and new...
$w->limit($opts['limit']); // we can run 1000 ...
}
- if (!empty($this->evtype)) {
- $w->evtype = $this->evtype;
- }
- $ff = HTML_FlexyFramework::get();
- if (!empty($ff->Core_Notify['servers'])) {
- if (!isset($ff->Core_Notify['servers'][gethostname()])) {
- $this->jerr("Core_Notify['servers']['" . gethostname() ."'] is not set");
- }
- $w->server_id = array_search(gethostname(),array_keys($ff->Core_Notify['servers']));
- }
$w->autoJoin();
- $w->find();
+ $total = $w->find();
$total--;
}
- $this->logecho("BATCH SIZE: ". (count($this->queue) + $total) );
+ $this->logecho("BATCH SIZE: Queue=". count($this->queue) . " TOTAL = " . $total );
if (empty($this->queue)) {
$this->logecho("COMPLETED MAIN QUEUE - running maxed out domains");
return;
}
+ if (!isset($ff->Core_Notify['servers'][gethostname()])) {
+ $this->jerr("Core_Notify['servers']['" . gethostname() ."'] is not set");
+ }
+ // only run this on the main server...
+ if (array_search(gethostname(),array_keys($ff->Core_Notify['servers'])) > 0) {
+ return;
+ }
+
$num_servers = count(array_keys($ff->Core_Notify['servers']));
$p = DB_DataObject::factory($this->table);
+ $p->whereAdd("
+ sent < '2000-01-01'
+ and
+ event_id = 0
+ and
+ act_start < NOW() + INTERVAL 3 HOUR
+ and
+ server_id < 0"
+
+ );
+ if ($p->count() < 1) {
+ return;
+ }
+ $p = DB_DataObject::factory($this->table);
// 6 seconds on this machne...
$p->query("
UPDATE
and
event_id = 0
and
- act_start < NOW()
+ act_start < NOW() + INTERVAL 3 HOUR
and
server_id < 0
ORDER BY
id ASC
LIMIT
- 20000
+ 10000
");
if ($this->max_pool_size === 1) {
- this->logecho("call passthru [{$email}] $cmd");
+ $this->logecho("call passthru [{$email}] $cmd");
passthru($cmd);
return;
}