Merge branch 'pull'
This commit is contained in:
commit
88e6e4699a
2 changed files with 23 additions and 11 deletions
|
@ -37,6 +37,19 @@ function delivery_run($argv, $argc){
|
|||
$item_id = intval($argv[2]);
|
||||
$contact_id = intval($argv[3]);
|
||||
|
||||
// Some other process may have delivered this item already.
|
||||
|
||||
$r = q("select * from deliverq where cmd = '%s' and item = %d and contact = %d limit 1",
|
||||
dbesc($cmd),
|
||||
dbesc($item_id),
|
||||
dbesc($contact_id)
|
||||
);
|
||||
if(! count($r)) {
|
||||
return;
|
||||
}
|
||||
|
||||
// It's ours to deliver. Remove it from the queue.
|
||||
|
||||
q("delete from deliverq where cmd = '%s' and item = %d and contact = %d limit 1",
|
||||
dbesc($cmd),
|
||||
dbesc($item_id),
|
||||
|
|
|
@ -42,7 +42,6 @@ function queue_run($argv, $argc){
|
|||
if(! $interval)
|
||||
$interval = 2;
|
||||
|
||||
|
||||
$r = q("select * from deliverq where 1");
|
||||
if(count($r)) {
|
||||
foreach($r as $rr) {
|
||||
|
|
Loading…
Reference in a new issue