@@ 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 | { |