Completed
Push — master ( 7f90df...f249d3 )
by Akihito
02:24
created
src/Snidel/ForkContainer.php 1 patch
Spacing   +6 added lines, -6 removed lines patch added patch discarded remove patch
@@ -134,7 +134,7 @@  discard block
 block discarded – undo
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
 block discarded – undo
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
 block discarded – undo
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
 block discarded – undo
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();
Please login to merge, or discard this patch.