summaryrefslogtreecommitdiff
path: root/_darcs/pristine/classes/Queue_item.php
diff options
context:
space:
mode:
authorEvan Prodromou <evan@controlyourself.ca>2009-01-08 20:56:09 +0000
committerEvan Prodromou <evan@controlyourself.ca>2009-01-08 20:56:09 +0000
commit07e9e2dc3241eef1b803e655a5273f79cb758806 (patch)
tree0846f3e3cbefd39041e580bffbc7556eb7f45c93 /_darcs/pristine/classes/Queue_item.php
parente67affdbbcdcaa9f43750389922b802d0b425ddb (diff)
Remove _darcs from git repository
Not sure how or why this got in there.
Diffstat (limited to '_darcs/pristine/classes/Queue_item.php')
-rw-r--r--_darcs/pristine/classes/Queue_item.php57
1 files changed, 0 insertions, 57 deletions
diff --git a/_darcs/pristine/classes/Queue_item.php b/_darcs/pristine/classes/Queue_item.php
deleted file mode 100644
index 9b909ec22..000000000
--- a/_darcs/pristine/classes/Queue_item.php
+++ /dev/null
@@ -1,57 +0,0 @@
-<?php
-/**
- * Table Definition for queue_item
- */
-require_once INSTALLDIR.'/classes/Memcached_DataObject.php';
-
-class Queue_item extends Memcached_DataObject
-{
- ###START_AUTOCODE
- /* the code below is auto generated do not remove the above tag */
-
- public $__table = 'queue_item'; // table name
- public $notice_id; // int(4) primary_key not_null
- public $transport; // varchar(8) primary_key not_null
- public $created; // datetime() not_null
- public $claimed; // datetime()
-
- /* Static get */
- function staticGet($k,$v=null)
- { return Memcached_DataObject::staticGet('Queue_item',$k,$v); }
-
- /* the code above is auto generated do not remove the tag below */
- ###END_AUTOCODE
-
- function sequenceKey()
- { return array(false, false); }
-
- static function top($transport) {
-
- $qi = new Queue_item();
- $qi->transport = $transport;
- $qi->orderBy('created');
- $qi->whereAdd('claimed is null');
-
- $qi->limit(1);
-
- $cnt = $qi->find(true);
-
- if ($cnt) {
- # XXX: potential race condition
- # can we force it to only update if claimed is still null
- # (or old)?
- common_log(LOG_INFO, 'claiming queue item = ' . $qi->notice_id . ' for transport ' . $transport);
- $orig = clone($qi);
- $qi->claimed = common_sql_now();
- $result = $qi->update($orig);
- if ($result) {
- common_log(LOG_INFO, 'claim succeeded.');
- return $qi;
- } else {
- common_log(LOG_INFO, 'claim failed.');
- }
- }
- $qi = null;
- return null;
- }
-}