| @@ 149-158 (lines=10) @@ | ||
| 146 | $this->notify(); |
|
| 147 | } |
|
| 148 | ||
| 149 | public function markAsTimedOut(ParallelProcess $process) |
|
| 150 | { |
|
| 151 | $process->triggerTimeout(); |
|
| 152 | ||
| 153 | unset($this->inProgress[$process->getPid()]); |
|
| 154 | ||
| 155 | $this->failed[$process->getPid()] = $process; |
|
| 156 | ||
| 157 | $this->notify(); |
|
| 158 | } |
|
| 159 | ||
| 160 | public function markAsFailed(ParallelProcess $process) |
|
| 161 | { |
|
| @@ 160-169 (lines=10) @@ | ||
| 157 | $this->notify(); |
|
| 158 | } |
|
| 159 | ||
| 160 | public function markAsFailed(ParallelProcess $process) |
|
| 161 | { |
|
| 162 | $process->triggerError(); |
|
| 163 | ||
| 164 | unset($this->inProgress[$process->getPid()]); |
|
| 165 | ||
| 166 | $this->failed[$process->getPid()] = $process; |
|
| 167 | ||
| 168 | $this->notify(); |
|
| 169 | } |
|
| 170 | ||
| 171 | public function offsetExists($offset) |
|
| 172 | { |
|