idanoo/php-resque
1
0
Fork 0
mirror of https://github.com/idanoo/php-resque.git synced 2024-11-25 01:35:14 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

method comment changes

Browse Source
This commit is contained in:
Chaitanya Kuber 2012-03-01 19:21:58 -06:00
parent ef859b6fc5
commit 3b59fa5dbc
1 changed files with 6 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
lib/Resque/Worker.php
View File

@ -53,7 +53,7 @@ class Resque_Worker
* @var Resque_Job Current job, if any, being processed by this worker. * @var Resque_Job Current job, if any, being processed by this worker.
*/ */
private $currentJob = null; private $currentJob = null;
/** /**
* @var int Process ID of child worker processes. * @var int Process ID of child worker processes.
*/ */
@ -61,6 +61,7 @@ class Resque_Worker
/** /**
* Return all workers known to Resque as instantiated instances. * Return all workers known to Resque as instantiated instances.
* @return array
*/ */
public static function all() public static function all()
{ {
@ -192,12 +193,12 @@ class Resque_Worker
$this->child = $this->fork(); $this->child = $this->fork();
// Forked and we're the child. Run the job. // Forked and we're the child. Run the job.
if($this->child === 0 || $this->child === false) { if ($this->child === 0 || $this->child === false) {
$status = 'Processing ' . $job->queue . ' since ' . strftime('%F %T'); $status = 'Processing ' . $job->queue . ' since ' . strftime('%F %T');
$this->updateProcLine($status); $this->updateProcLine($status);
$this->log($status, self::LOG_VERBOSE); $this->log($status, self::LOG_VERBOSE);
$this->perform($job); $this->perform($job);
if($this->child === 0) { if ($this->child === 0) {
exit(0); exit(0);
} }
} }
@ -228,11 +229,12 @@ class Resque_Worker
/** /**
* Process a single job. * Process a single job.
* *
* @param object|null $job The job to be processed. * @param Resque_Job $job The job to be processed.
*/ */
public function perform(Resque_Job $job) public function perform(Resque_Job $job)
{ {
try { try {
$this->log("afterFork being triggered", self::LOG_VERBOSE);
Resque_Event::trigger('afterFork', $job); Resque_Event::trigger('afterFork', $job);
$job->perform(); $job->perform();
} }