@@ -134,7 +134,7 @@ discard block |
||
| 134 | 134 | |
| 135 | 135 | if ($pid) { |
| 136 | 136 | // owner |
| 137 | - $this->log->info('pid: ' . getmypid()); |
|
| 137 | + $this->log->info('pid: '.getmypid()); |
|
| 138 | 138 | |
| 139 | 139 | return $this->masterPid; |
| 140 | 140 | } elseif ($pid === -1) { |
@@ -142,14 +142,14 @@ discard block |
||
| 142 | 142 | } else { |
| 143 | 143 | // master |
| 144 | 144 | $taskQueue = new TaskQueue($this->ownerPid); |
| 145 | - $this->log->info('pid: ' . $this->masterPid); |
|
| 145 | + $this->log->info('pid: '.$this->masterPid); |
|
| 146 | 146 | |
| 147 | 147 | foreach ($this->signals as $sig) { |
| 148 | 148 | $this->pcntl->signal($sig, SIG_DFL, true); |
| 149 | 149 | } |
| 150 | 150 | |
| 151 | 151 | while ($task = $taskQueue->dequeue()) { |
| 152 | - $this->log->info('dequeued task #' . $taskQueue->dequeuedCount()); |
|
| 152 | + $this->log->info('dequeued task #'.$taskQueue->dequeuedCount()); |
|
| 153 | 153 | if ($this->token->accept()) { |
| 154 | 154 | $this->forkWorker($task); |
| 155 | 155 | } |
@@ -176,10 +176,10 @@ discard block |
||
| 176 | 176 | |
| 177 | 177 | if (getmypid() === $this->masterPid) { |
| 178 | 178 | // master |
| 179 | - $this->log->info('forked worker. pid: ' . $fork->getPid()); |
|
| 179 | + $this->log->info('forked worker. pid: '.$fork->getPid()); |
|
| 180 | 180 | } else { |
| 181 | 181 | // worker |
| 182 | - $this->log->info('has forked. pid: ' . getmypid()); |
|
| 182 | + $this->log->info('has forked. pid: '.getmypid()); |
|
| 183 | 183 | // @codeCoverageIgnoreStart |
| 184 | 184 | |
| 185 | 185 | foreach ($this->signals as $sig) { |
@@ -187,7 +187,7 @@ discard block |
||
| 187 | 187 | } |
| 188 | 188 | |
| 189 | 189 | $resultQueue = new ResultQueue($this->ownerPid); |
| 190 | - register_shutdown_function(function () use ($fork, $resultQueue) { |
|
| 190 | + register_shutdown_function(function() use ($fork, $resultQueue) { |
|
| 191 | 191 | if ($fork->hasNoResult() || !$fork->isQueued()) { |
| 192 | 192 | $result = new Result(); |
| 193 | 193 | $result->setFailure(); |