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