ackintosh / snidel

src/Snidel/ForkContainer.php

Spacing +8 added lines, -8 removed lines

@@ -129,7 +129,7 @@ 
 
         if ($pid) {
             // owner
-            $this->log->info('pid: ' . getmypid());
+            $this->log->info('pid: '.getmypid());
 
             return $this->masterPid;
         } elseif ($pid === -1) {
@@ -137,14 +137,14 @@ 
         } else {
             // master
             $taskQueue = new TaskQueue($this->ownerPid);
-            $this->log->info('pid: ' . $this->masterPid);
+            $this->log->info('pid: '.$this->masterPid);
 
             foreach ($this->signals as $sig) {
                 $this->pcntl->signal($sig, SIG_DFL, true);
             }
 
             while ($task = $taskQueue->dequeue()) {
-                $this->log->info('dequeued task #' . $taskQueue->dequeuedCount());
+                $this->log->info('dequeued task #'.$taskQueue->dequeuedCount());
                 if ($this->token->accept()) {
                     $this->forkWorker($task);
                 }
@@ -171,10 +171,10 @@ 
 
         if (getmypid() === $this->masterPid) {
             // master
-            $this->log->info('forked worker. pid: ' . $fork->getPid());
+            $this->log->info('forked worker. pid: '.$fork->getPid());
         } else {
             // worker
-            $this->log->info('has forked. pid: ' . getmypid());
+            $this->log->info('has forked. pid: '.getmypid());
             // @codeCoverageIgnoreStart
 
             foreach ($this->signals as $sig) {
@@ -182,7 +182,7 @@ 
             }
 
             $resultQueue = new ResultQueue($this->ownerPid);
-            register_shutdown_function(function () use ($fork, $resultQueue) {
+            register_shutdown_function(function() use ($fork, $resultQueue) {
                 if ($fork->hasNoResult() || !$fork->isQueued()) {
                     $result = new Result();
                     $result->setFailure();
@@ -315,8 +315,8 @@ 
      */
     private function getCollectionWithTag($tag)
     {
-        $collection = array_filter($this->forks, function ($fork) use ($tag) {
-            return $fork->getTag() ===  $tag;
+        $collection = array_filter($this->forks, function($fork) use ($tag) {
+            return $fork->getTag() === $tag;
         });
 
         return new ForkCollection($collection);