comodojo /
extender.framework
| @@ 58-76 (lines=19) @@ | ||
| 55 | ||
| 56 | } |
|
| 57 | ||
| 58 | public function isStarting($uid, $pid) { |
|
| 59 | ||
| 60 | $job = $this->queued_jobs[$uid]; |
|
| 61 | ||
| 62 | $this->logger->debug('Job '.$job->name.' (uid '.$job->uid.') is starting with pid '.$pid); |
|
| 63 | ||
| 64 | $job->pid = $pid; |
|
| 65 | ||
| 66 | $job->start_timestamp = microtime(true); |
|
| 67 | ||
| 68 | $this->running_jobs[$uid] = $job; |
|
| 69 | ||
| 70 | unset($this->queued_jobs[$uid]); |
|
| 71 | ||
| 72 | $this->dump(); |
|
| 73 | ||
| 74 | return $this; |
|
| 75 | ||
| 76 | } |
|
| 77 | ||
| 78 | public function isCompleted($uid, $success, $result, $wid = null) { |
|
| 79 | ||
| @@ 59-77 (lines=19) @@ | ||
| 56 | ||
| 57 | } |
|
| 58 | ||
| 59 | public function isStarting($uid, $pid) { |
|
| 60 | ||
| 61 | $job = $this->queued_jobs[$uid]; |
|
| 62 | ||
| 63 | $this->logger->debug('Job '.$job->name.' (uid '.$job->uid.') is starting with pid '.$pid); |
|
| 64 | ||
| 65 | $job->pid = $pid; |
|
| 66 | ||
| 67 | $job->start_timestamp = microtime(true); |
|
| 68 | ||
| 69 | $this->running_jobs[$uid] = $job; |
|
| 70 | ||
| 71 | unset($this->queued_jobs[$uid]); |
|
| 72 | ||
| 73 | $this->dump(); |
|
| 74 | ||
| 75 | return $this; |
|
| 76 | ||
| 77 | } |
|
| 78 | ||
| 79 | public function isCompleted($uid, $success, $result, $wid = null) { |
|
| 80 | ||
