database lock for frequent processes

diff --git a/Heartbeat.php b/Heartbeat.php
index 6a49092..27c1bf8 100644 (file)
--- a/Heartbeat.php
+++ b/Heartbeat.php
@@ -20,6 +20,12 @@ class Pman_Core_Heartbeat extends Pman
     function post($req)
     {
         $this->initErrorHandling();
+        
+        if ($this->database_is_locked()) {
+            die("FAILED");
+        }
+        
+        
         $cd = DB_DataObject::Factory('core_enum');
         $cd->setFrom(array(
             'etype' => 'heartbeat',
@@ -48,4 +54,6 @@ class Pman_Core_Heartbeat extends Pman
       //  print_r($err);
         die("FAILED");
     }
+    
+   
 }
\ No newline at end of file

diff --git a/Notify.php b/Notify.php
index f524ff2..55047c7 100644 (file)
--- a/Notify.php
+++ b/Notify.php
@@ -178,6 +178,12 @@ class Pman_Core_Notify extends Pman
    
     function get($r,$opts=array())    
     {
+        
+        if ($this->database_is_locked()) {
+            die("LATER - DATABASE IS LOCKED");
+        }
+        
+        
         $this->parseArgs($opts); 
          
         //date_default_timezone_set('UTC');

diff --git a/NotifySend.php b/NotifySend.php
index 0ba7692..a7b6874 100644 (file)
--- a/NotifySend.php
+++ b/NotifySend.php
@@ -87,7 +87,9 @@ class Pman_Core_NotifySend extends Pman
    
     function get($id,$opts=array())
     {
-
+        if ($this->database_is_locked()) {
+            die("LATER - DATABASE IS LOCKED");
+        }
         //print_r($opts);
         if (!empty($opts['DB_DataObject-debug'])) {
             DB_DataObject::debugLevel($opts['DB_DataObject-debug']);