It should be "e" not "p"

diff --git a/include/poller.php b/include/poller.php
index 22fb65a4f8fda474f225fa45971daef9e82426ec..ed870c358807c2d5bb76197d2b26a0fb0ecad7ed 100644 (file)
--- a/include/poller.php
+++ b/include/poller.php
@@ -545,7 +545,7 @@ function poller_worker_process() {
        $highest_priority = 0;
 
        if (poller_passing_slow($highest_priority)) {
-               dba::p('LOCK TABLES `workerqueue` WRITE');
+               dba::e('LOCK TABLES `workerqueue` WRITE');
 
                // Are there waiting processes with a higher priority than the currently highest?
                $r = q("SELECT * FROM `workerqueue`
@@ -567,7 +567,7 @@ function poller_worker_process() {
                        return $r;
                }
        } else {
-               dba::p('LOCK TABLES `workerqueue` WRITE');
+               dba::e('LOCK TABLES `workerqueue` WRITE');
        }
 
        // If there is no result (or we shouldn't pass lower processes) we check without priority limit
@@ -577,7 +577,7 @@ function poller_worker_process() {
 
        // We only unlock the tables here, when we got no data
        if (!dbm::is_result($r)) {
-               dba::p('UNLOCK TABLES');
+               dba::e('UNLOCK TABLES');
        }
 
        return $r;
@@ -597,7 +597,7 @@ function poller_claim_process($queue) {
 
        $success = dba::update('workerqueue', array('executed' => datetime_convert(), 'pid' => $mypid),
                        array('id' => $queue["id"], 'pid' => 0));
-       dba::p('UNLOCK TABLES');
+       dba::e('UNLOCK TABLES');
 
        if (!$success) {
                logger("Couldn't update queue entry ".$queue["id"]." - skip this execution", LOGGER_DEBUG);