From 38f5daba6b881d9d5476a6e016b07f46a9665d4f Mon Sep 17 00:00:00 2001 From: Neozonz Date: Sun, 19 Jan 2014 06:00:14 -0500 Subject: [PATCH] Search blocks by desc and order by for deletes --- public/include/classes/share.class.php | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/public/include/classes/share.class.php b/public/include/classes/share.class.php index d0fd0144..0a8035ca 100644 --- a/public/include/classes/share.class.php +++ b/public/include/classes/share.class.php @@ -244,7 +244,7 @@ class Share Extends Base { while ($affected > 0) { // Sleep first to allow any IO to cleanup sleep($this->config['purge']['sleep']); - $stmt = $this->mysqli->prepare("DELETE FROM $this->table WHERE id > ? AND id <= ? LIMIT " . $this->config['purge']['shares']); + $stmt = $this->mysqli->prepare("DELETE FROM $this->table WHERE id > ? AND id <= ? ORDER BY id LIMIT " . $this->config['purge']['shares']); $start = microtime(true); if ($this->checkStmt($stmt) && $stmt->bind_param('ii', $previous_upstream, $current_upstream) && $stmt->execute()) { $affected = $stmt->affected_rows; @@ -331,7 +331,7 @@ class Share Extends Base { AND id > ? AND UNIX_TIMESTAMP(time) >= ? AND UNIX_TIMESTAMP(time) <= ( ? + 60 ) - ORDER BY id ASC LIMIT 1"); + ORDER BY id DESC LIMIT 1"); if ($this->checkStmt($stmt) && $stmt->bind_param('iii', $last, $aBlock['time'], $aBlock['time']) && $stmt->execute() && $result = $stmt->get_result()) { $this->oUpstream = $result->fetch_object(); $this->share_type = 'upstream_share'; @@ -347,7 +347,7 @@ class Share Extends Base { WHERE our_result = 'Y' AND id > ? AND UNIX_TIMESTAMP(time) >= ? - ORDER BY id ASC LIMIT 1"); + ORDER BY id DESC LIMIT 1"); if ($this->checkStmt($stmt) && $stmt->bind_param('ii', $last, $aBlock['time']) && $stmt->execute() && $result = $stmt->get_result()) { $this->oUpstream = $result->fetch_object(); $this->share_type = 'any_share';