47 lines
1.5 KiB
PHP
47 lines
1.5 KiB
PHP
|
<?php
|
||
|
|
|
||
|
|
class OpportunisticQMPlugin extends Plugin {
|
||
|
|
public $qmkey = false;
|
||
|
|
public $secs_per_action = 1; // total seconds to run script per action
|
||
|
|
public $rel_to_pageload = true; // relative to pageload or queue start
|
||
|
|
|
||
|
|
public function onRouterInitialized($m)
|
||
|
|
{
|
||
|
|
$m->connect('main/runqueue', array('action' => 'runqueue'));
|
||
|
|
}
|
||
|
|
|
||
|
|
/**
|
||
|
|
* When the page has finished rendering, let's do some cron jobs
|
||
|
|
* if we have the time.
|
||
|
|
*/
|
||
|
|
public function onEndActionExecute($status, Action $action)
|
||
|
|
{
|
||
|
|
if ($action instanceof RunqueueAction) {
|
||
|
|
return true;
|
||
|
|
}
|
||
|
|
|
||
|
|
global $_startTime;
|
||
|
|
|
||
|
|
$args = array(
|
||
|
|
'qmkey' => common_config('opportunisticqm', 'qmkey'),
|
||
|
|
'max_execution_time' => $this->secs_per_action,
|
||
|
|
'started_at' => $this->rel_to_pageload ? $_startTime : null,
|
||
|
|
);
|
||
|
|
$qm = new OpportunisticQueueManager($args);
|
||
|
|
$qm->runQueue();
|
||
|
|
return true;
|
||
|
|
}
|
||
|
|
|
||
|
|
public function onPluginVersion(&$versions)
|
||
|
|
{
|
||
|
|
$versions[] = array('name' => 'OpportunisticQM',
|
||
|
|
'version' => GNUSOCIAL_VERSION,
|
||
|
|
'author' => 'Mikael Nordfeldth',
|
||
|
|
'homepage' => 'http://www.gnu.org/software/social/',
|
||
|
|
'description' =>
|
||
|
|
// TRANS: Plugin description.
|
||
|
|
_m('Opportunistic queue manager plugin for background processing.'));
|
||
|
|
return true;
|
||
|
|
}
|
||
|
|
}
|