ackintosh / snidel

src/Snidel/Fork/Container.php

Spacing +10 added lines, -10 removed lines

@@ -139,7 +139,7 @@ 
 
         if ($pid) {
             // owner
-            $this->log->info('pid: ' . getmypid());
+            $this->log->info('pid: '.getmypid());
 
             return $this->masterPid;
         } elseif ($pid === -1) {
@@ -147,19 +147,19 @@ 
         } else {
             // master
             $taskQueue = new TaskQueue($this->ownerPid);
-            $this->log->info('pid: ' . $this->masterPid);
+            $this->log->info('pid: '.$this->masterPid);
 
             $log = $this->log;
             foreach ($this->signals as $sig) {
-                $this->pcntl->signal($sig, function ($sig) use ($log) {
-                    $log->info('received signal: ' . $sig);
+                $this->pcntl->signal($sig, function($sig) use ($log) {
+                    $log->info('received signal: '.$sig);
                     exit;
                 });
             }
             $workerCount = 0;
 
             while ($task = $taskQueue->dequeue()) {
-                $this->log->info('dequeued task #' . $taskQueue->dequeuedCount());
+                $this->log->info('dequeued task #'.$taskQueue->dequeuedCount());
                 if ($workerCount >= $this->concurrency) {
                     $status = null;
                     $this->pcntl->waitpid(-1, $status);
@@ -190,10 +190,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) {
@@ -202,7 +202,7 @@ 
 
             $resultQueue = new ResultQueue($this->ownerPid);
             $resultHasQueued = false;
-            register_shutdown_function(function () use (&$resultHasQueued, $fork, $task, $resultQueue) {
+            register_shutdown_function(function() use (&$resultHasQueued, $fork, $task, $resultQueue) {
                 if (!$resultHasQueued) {
                     $result = new Result();
                     $result->setError(error_get_last());
@@ -246,13 +246,13 @@ 
      */
     public function sendSignalToMaster($sig = SIGTERM)
     {
-        $this->log->info('----> sending signal to master. signal: ' . $sig);
+        $this->log->info('----> sending signal to master. signal: '.$sig);
         posix_kill($this->masterPid, $sig);
         $this->log->info('<---- sent signal.');
 
         $status = null;
         $this->pcntl->waitpid($this->masterPid, $status);
-        $this->log->info('. status: ' . $status);
+        $this->log->info('. status: '.$status);
         $this->masterPid = null;
     }