ackintosh / snidel

src/Snidel.php

Spacing +9 added lines, -9 removed lines

@@ -61,8 +61,8 @@ 
         foreach ($this->signals as $sig) {
             $this->pcntl->signal(
                 $sig,
-                function ($sig) use($log, $self) {
-                    $log->info('received signal. signo: ' . $sig);
+                function($sig) use($log, $self) {
+                    $log->info('received signal. signo: '.$sig);
                     $self->setReceivedSignal($sig);
 
                     $log->info('--> sending a signal " to children.');
@@ -74,7 +74,7 @@ 
             );
         }
 
-        $this->log->info('parent pid: ' . $this->ownerPid);
+        $this->log->info('parent pid: '.$this->ownerPid);
     }
 
     /**
@@ -112,7 +112,7 @@ 
             throw $e;
         }
 
-        $this->log->info('queued task #' . $this->container->queuedCount());
+        $this->log->info('queued task #'.$this->container->queuedCount());
     }
 
     /**
@@ -139,7 +139,7 @@ 
 
         if (getmypid() === $this->ownerPid) {
             // parent
-            $this->log->info('created child process. pid: ' . $fork->getPid());
+            $this->log->info('created child process. pid: '.$fork->getPid());
         } else {
             // @codeCoverageIgnoreStart
             // child
@@ -152,7 +152,7 @@ 
              */
             $log = $this->log;
             $resultHasWritten = false;
-            register_shutdown_function(function () use (&$resultHasWritten, $fork, $task, $log, $token) {
+            register_shutdown_function(function() use (&$resultHasWritten, $fork, $task, $log, $token) {
                 if (!$resultHasWritten) {
                     $dataRepository = new DataRepository();
                     $data = $dataRepository->load(getmypid());
@@ -234,7 +234,7 @@ 
             $this->wait();
         }
         if ($tag !== null && !$this->container->hasTag($tag)) {
-            throw new \InvalidArgumentException('unknown tag: ' . $tag);
+            throw new \InvalidArgumentException('unknown tag: '.$tag);
         }
 
         return $this->container->getCollection($tag);
@@ -249,7 +249,7 @@ 
     public function sendSignalToChildren($sig)
     {
         foreach ($this->container->getChildrend() as $child) {
-            $this->log->info('----> sending a signal to child. pid: ' . $child->getPid());
+            $this->log->info('----> sending a signal to child. pid: '.$child->getPid());
             posix_kill($child->getPid(), $sig);
         }
     }
@@ -350,7 +350,7 @@ 
 
             $childPid = $result->getFork()->getPid();
             if ($result->isFailure()) {
-                $message = 'an error has occurred in child process. pid: ' . $childPid;
+                $message = 'an error has occurred in child process. pid: '.$childPid;
                 $this->log->error($message);
                 throw new \RuntimeException($message);
             }