src/Comodojo/Extender/Jobs/Manager.php 1 location
|
@@ 44-56 (lines=13) @@
|
| 41 |
|
|
| 42 |
|
} |
| 43 |
|
|
| 44 |
|
public function isQueued(Job $job) { |
| 45 |
|
|
| 46 |
|
$this->logger->debug('Adding job '.$job->name.' (uid '.$job->uid.') to queue'); |
| 47 |
|
|
| 48 |
|
$uid = $job->uid; |
| 49 |
|
|
| 50 |
|
$this->queued_jobs[$uid] = $job; |
| 51 |
|
|
| 52 |
|
$this->dump(); |
| 53 |
|
|
| 54 |
|
return true; |
| 55 |
|
|
| 56 |
|
} |
| 57 |
|
|
| 58 |
|
public function isStarting($uid, $pid) { |
| 59 |
|
|
src/Comodojo/Extender/Task/Locker.php 1 location
|
@@ 45-57 (lines=13) @@
|
| 42 |
|
|
| 43 |
|
} |
| 44 |
|
|
| 45 |
|
public function isQueued(Job $job) { |
| 46 |
|
|
| 47 |
|
$this->logger->debug('Adding job '.$job->name.' (uid '.$job->uid.') to queue'); |
| 48 |
|
|
| 49 |
|
$uid = $job->uid; |
| 50 |
|
|
| 51 |
|
$this->queued_jobs[$uid] = $job; |
| 52 |
|
|
| 53 |
|
$this->dump(); |
| 54 |
|
|
| 55 |
|
return true; |
| 56 |
|
|
| 57 |
|
} |
| 58 |
|
|
| 59 |
|
public function isStarting($uid, $pid) { |
| 60 |
|
|