hazza/Phraseanet
1
0
Fork 0
mirror of https://github.com/alchemy-fr/Phraseanet.git synced 2025-10-14 05:23:21 +00:00
Code Issues Packages Projects Releases Wiki Activity

Update tasks

Browse Source
This commit is contained in:
Romain Neutron
2012-09-21 15:02:24 +02:00
parent baf3f6692a
commit bafb4edca9
15 changed files with 140 additions and 153 deletions
Download Patch File Download Diff File Expand all files Collapse all files

57
lib/classes/task/manager.class.php
View File

@@ -9,7 +9,8 @@
* file that was distributed with this source code.
*/
use \Monolog\Logger;
use Alchemy\Phrasea\Core\Configuration;
use Monolog\Logger;
use Alchemy\Phrasea\Application;
/**
@@ -24,12 +25,12 @@ class task_manager
const STATE_STARTED = 'started';
const STATE_TOSTOP = 'tostop';
protected $appbox;
protected $app;
protected $tasks;
public function __construct(appbox &$appbox)
public function __construct(Application $app)
{
$this->appbox = $appbox;
$this->app = $app;
return $this;
}
@@ -68,18 +69,16 @@ class task_manager
public function getTasks($refresh = false, Logger $logger = null)
{
if ($this->tasks && ! $refresh) {
if ($this->tasks && !$refresh) {
return $this->tasks;
}
$core = \bootstrap::getCore();
if ( ! $logger) {
$logger = $core['monolog'];
if (!$logger) {
$logger = $this->app['monolog'];
}
$sql = "SELECT task2.* FROM task2 ORDER BY task_id ASC";
$stmt = $this->appbox->get_connection()->prepare($sql);
$stmt = $this->app['phraseanet.appbox']->get_connection()->prepare($sql);
$stmt->execute();
$rs = $stmt->fetchAll(PDO::FETCH_ASSOC);
$stmt->closeCursor();
@@ -90,11 +89,11 @@ class task_manager
$row['pid'] = NULL;
$classname = $row['class'];
if ( ! class_exists($classname)) {
if (!class_exists($classname)) {
continue;
}
try {
$tasks[$row['task_id']] = new $classname($row['task_id'], $app, $logger);
$tasks[$row['task_id']] = new $classname($row['task_id'], $this->app, $logger);
} catch (Exception $e) {
}
@@ -110,17 +109,15 @@ class task_manager
* @param int $task_id
* @return task_abstract
*/
public function getTask(Application $app, $task_id, Logger $logger = null)
public function getTask($task_id, Logger $logger = null)
{
$core = \bootstrap::getCore();
if ( ! $logger) {
$logger = $core['monolog'];
if (!$logger) {
$logger = $this->app['monolog'];
}
$tasks = $this->getTasks($app, false, $logger);
$tasks = $this->getTasks(false, $logger);
if ( ! isset($tasks[$task_id])) {
if (!isset($tasks[$task_id])) {
throw new Exception_NotFound('Unknown task_id ' . $task_id);
}
@@ -145,11 +142,11 @@ class task_manager
self::STATE_TOSTOP
);
if ( ! in_array($status, $av_status))
if (!in_array($status, $av_status))
throw new Exception(sprintf('unknown status `%s` ', $status));
$sql = "UPDATE sitepreff SET schedstatus = :schedstatus, schedqtime=NOW()";
$stmt = $this->appbox->get_connection()->prepare($sql);
$stmt = $this->app['phraseanet.appbox']->get_connection()->prepare($sql);
$stmt->execute(array(':schedstatus' => $status));
$stmt->closeCursor();
@@ -158,19 +155,17 @@ class task_manager
public function getSchedulerState()
{
$appbox = appbox::get_instance(\bootstrap::getCore());
$sql = "SELECT UNIX_TIMESTAMP()-UNIX_TIMESTAMP(schedqtime) AS qdelay
, schedqtime AS updated_on
, schedstatus AS status FROM sitepreff";
$stmt = $this->appbox->get_connection()->prepare($sql);
$stmt = $this->app['phraseanet.appbox']->get_connection()->prepare($sql);
$stmt->execute();
$ret = $stmt->fetch(PDO::FETCH_ASSOC);
$stmt->closeCursor();
$pid = NULL;
$lockdir = $appbox->get_registry()->get('GV_RootPath') . 'tmp/locks/';
$lockdir = $this->app['phraseanet.registry']->get('GV_RootPath') . 'tmp/locks/';
if (($schedlock = fopen($lockdir . 'scheduler.lock', 'a+')) != FALSE) {
if (flock($schedlock, LOCK_EX | LOCK_NB) === FALSE) {
// already locked : running !
@@ -190,7 +185,7 @@ class task_manager
if ($pid === NULL && $ret['status'] !== 'stopped') {
// auto fix
$this->appbox->get_connection()->exec('UPDATE sitepreff SET schedstatus=\'stopped\'');
$this->app['phraseanet.appbox']->get_connection()->exec('UPDATE sitepreff SET schedstatus=\'stopped\'');
$ret['status'] = 'stopped';
}
$ret['pid'] = $pid;
@@ -200,17 +195,17 @@ class task_manager
public static function getAvailableTasks()
{
$registry = registry::get_instance();
$taskdir = array($registry->get('GV_RootPath') . "lib/classes/task/period/"
, $registry->get('GV_RootPath') . "config/classes/task/period/"
$taskdir = array(
__DIR__ . "/period/",
__DIR__ . "/../../../config/classes/task/period/",
);
$tasks = array();
foreach ($taskdir as $path) {
if (($hdir = @opendir($path)) != FALSE) {
$max = 9999;
while (($max -- > 0) && (($file = readdir($hdir)) !== false)) {
if ( ! is_file($path . '/' . $file) || substr($file, 0, 1) == "." || substr($file, -10) != ".class.php") {
while (($max-- > 0) && (($file = readdir($hdir)) !== false)) {
if (!is_file($path . '/' . $file) || substr($file, 0, 1) == "." || substr($file, -10) != ".class.php") {
continue;
}