summaryrefslogtreecommitdiffstatshomepage
path: root/core/includes/batch.queue.inc
diff options
context:
space:
mode:
Diffstat (limited to 'core/includes/batch.queue.inc')
-rw-r--r--core/includes/batch.queue.inc71
1 files changed, 0 insertions, 71 deletions
diff --git a/core/includes/batch.queue.inc b/core/includes/batch.queue.inc
deleted file mode 100644
index 8464836987b7..000000000000
--- a/core/includes/batch.queue.inc
+++ /dev/null
@@ -1,71 +0,0 @@
-<?php
-
-
-/**
- * @file
- * Queue handlers used by the Batch API.
- *
- * Those implementations:
- * - ensure FIFO ordering,
- * - let an item be repeatedly claimed until it is actually deleted (no notion
- * of lease time or 'expire' date), to allow multipass operations.
- */
-
-/**
- * Batch queue implementation.
- *
- * Stale items from failed batches are cleaned from the {queue} table on cron
- * using the 'created' date.
- */
-class BatchQueue extends SystemQueue {
-
- public function claimItem($lease_time = 0) {
- $item = db_query_range('SELECT data, item_id FROM {queue} q WHERE name = :name ORDER BY item_id ASC', 0, 1, array(':name' => $this->name))->fetchObject();
- if ($item) {
- $item->data = unserialize($item->data);
- return $item;
- }
- return FALSE;
- }
-
- /**
- * Retrieve all remaining items in the queue.
- *
- * This is specific to Batch API and is not part of the DrupalQueueInterface,
- */
- public function getAllItems() {
- $result = array();
- $items = db_query('SELECT data FROM {queue} q WHERE name = :name ORDER BY item_id ASC', array(':name' => $this->name))->fetchAll();
- foreach ($items as $item) {
- $result[] = unserialize($item->data);
- }
- return $result;
- }
-}
-
-/**
- * Batch queue implementation used for non-progressive batches.
- */
-class BatchMemoryQueue extends MemoryQueue {
-
- public function claimItem($lease_time = 0) {
- if (!empty($this->queue)) {
- reset($this->queue);
- return current($this->queue);
- }
- return FALSE;
- }
-
- /**
- * Retrieve all remaining items in the queue.
- *
- * This is specific to Batch API and is not part of the DrupalQueueInterface,
- */
- public function getAllItems() {
- $result = array();
- foreach ($this->queue as $item) {
- $result[] = $item->data;
- }
- return $result;
- }
-}