From ad53a03f834ad73b4fc713f5915de9248e4d742e Mon Sep 17 00:00:00 2001 From: Michael Date: Sun, 4 Jun 2017 09:00:07 +0000 Subject: [PATCH] It should be "e" not "p" --- include/poller.php | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/include/poller.php b/include/poller.php index 22fb65a4f8..ed870c3588 100644 --- 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);