SproutCMS

/modules/Demo/Controllers/Admin/DemoItemAdminController.php   Highlighted file source

Line 25: use Sprout\Helpers\WorkerCtrl;
Line 63: $url = "admin/call/{$this->controller_name}/runWorker";
Line 64: $tools['worker'] = '<li class="worker"><a href="' . Enc::html($url) . '">Run demo worker</a></li>';
Line 176: public function runWorker()
Line 178: $worker = WorkerCtrl::start('SproutModules\\Karmabunny\\Demo\\Helpers\\DemoWorker', 100, 500, 1000);
Line 179: Url::redirect($worker['log_url']);

/sprout/config/routes.php   Highlighted file source

Line 129: $config['worker_job/run/([0-9]+)/([a-zA-Z0-9]+)'] = 'WorkerJobController/run/$1/$2';

/sprout/Controllers/Admin/PageAdminController.php   Highlighted file source

Line 25: use Sprout\Exceptions\WorkerJobException;
Line 71: use Sprout\Helpers\WorkerCtrl;
Line 2539: $info = WorkerCtrl::start('Sprout\\Helpers\\WorkerLinkChecker');
Line 2541: $info = WorkerCtrl::start('Sprout\\Helpers\\WorkerLinkChecker', $_POST['email']);
Line 2543: } catch (WorkerJobException $ex) {
Line 2613: WorkerCtrl::start('Sprout\\Helpers\\WorkerLinkChecker');

/sprout/Controllers/DbToolsController.php   Highlighted file source

Line 95: [ 'url' => 'admin/extra/worker_job/manual_run', 'name' => 'Manual run worker job', 'desc' => 'Manually run a worker job in a browser' ],
Line 118: [ 'url' => 'admin/intro/worker_job', 'name' => 'Worker job log', 'desc' => 'Log of worker (background) processes' ],

/sprout/Exceptions/WorkerJobException.php   Highlighted file source

Line 22: class WorkerJobException extends Exception

/sprout/Helpers/Worker.php   Highlighted file source

Line 20: * Functions called by worker libraries to indicate status, etc
Line 22: class Worker
Line 32: * Called just before the worker thread is started.
Line 40: throw new Exception('Worker jobs MUST be run in CLI mode.');
Line 45: set_exception_handler(array('Sprout\\Helpers\\Worker', 'exceptionHandler'));
Line 46: register_shutdown_function(array('Sprout\\Helpers\\Worker', 'shutdown'));
Line 56: Pdb::update('worker_jobs', $update_fields, array('id' => $job_id));
Line 62: $q = "UPDATE {$pf}worker_jobs
Line 71: $q = "UPDATE {$pf}worker_jobs
Line 86: * Save and output log message for the currently running worker job
Line 138: * Report that a worker job failed.
Line 152: $q = "UPDATE {$pf}worker_jobs SET
Line 159: self::message('Worker terminated');
Line 165: * Report the successful completion of the worker job.
Line 183: $q = "UPDATE {$pf}worker_jobs SET
Line 196: * Exception and error handling for worker jobs

/sprout/Helpers/WorkerCtrl.php   Highlighted file source

Line 20: use Sprout\Exceptions\WorkerJobException;
Line 24: * Functions to update and report on worker status
Line 26: class WorkerCtrl
Line 30: * Starts a new worker
Line 31: * Workers are run in their own process (using the PHP CLI)
Line 42: * @throws WorkerJobException If the job failed to start
Line 51: if (!($inst instanceof WorkerBase)) {
Line 52: throw new InvalidArgumentException('Provided class is not a subclass of "Worker".');
Line 56: $q = "DELETE FROM ~worker_jobs WHERE DATE_ADD(date_modified, INTERVAL 6 MONTH) < NOW()";
Line 78: $job_id = Pdb::insert('worker_jobs', $update_fields);
Line 82: Cron::message("Starting worker job # {$job_id}, class '{$class_name}'.");
Line 85: // Set up an environment for the worker task
Line 86: putenv('PHP_S_WORKER=1');
Line 95: Pdb::update('worker_jobs', ['php_bin' => 'NOT FOUND'], ['id' => $job_id]);
Line 96: throw new WorkerJobException('Unable to find working PHP binary, which is needed for executing background tasks');
Line 101: Pdb::update('worker_jobs', ['php_bin' => 'Unuseable (CGI): ' . $php], ['id' => $job_id]);
Line 102: throw new WorkerJobException('Found a PHP binary, but it\'s a CGI binary; CLI binary required for executing background tasks');
Line 105: Pdb::update('worker_jobs', ['php_bin' => $php], ['id' => $job_id]);
Line 108: $arg = escapeshellarg("worker_job/run/{$job_id}/{$job_code}");
Line 113: $ex = new WorkerJobException('Failed to start process');
Line 124: $q = "SELECT status FROM ~worker_jobs WHERE id = ?";
Line 135: $ex = new WorkerJobException($err);
Line 142: 'log_url' => 'admin/edit/worker_job/' . $job_id
Line 174: * Return the status and metric values for a given worker job.
Line 183: $q = "SELECT status, metric1val, metric2val, metric3val FROM ~worker_jobs WHERE id = ?";

/sprout/Helpers/WorkerRedoSizes.php   Highlighted file source

Line 17: class WorkerRedoSizes extends WorkerBase
Line 28: Worker::message("Only processing size '{$size}'.");
Line 30: Worker::message("Processing all sizes.");
Line 39: Worker::message($row['filename']);
Line 44: Worker::success();

/sprout/tests/WorkerLinkCheckerTest.php   Highlighted file source

Line 14: use Sprout\Helpers\WorkerLinkChecker;
Line 16: class WorkerLinkCheckerTest extends PHPUnit_Framework_TestCase
Line 44: $obj = new WorkerLinkChecker();
Line 69: $obj = new WorkerLinkChecker();