ackintosh / snidel

src/Snidel.php

Spacing +9 added lines, -9 removed lines

@@ -70,8 +70,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.');
@@ -83,7 +83,7 @@ 
             );
         }
 
-        $this->log->info('parent pid: ' . $this->ownerPid);
+        $this->log->info('parent pid: '.$this->ownerPid);
     }
 
     /**
@@ -119,7 +119,7 @@ 
             throw $e;
         }
 
-        $this->log->info('queued task #' . $this->forkContainer->queuedCount());
+        $this->log->info('queued task #'.$this->forkContainer->queuedCount());
     }
 
     /**
@@ -148,7 +148,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
@@ -161,7 +161,7 @@ 
              */
             $dataRepository     = $this->dataRepository;
             $log                = $this->log;
-            register_shutdown_function(function () use ($fork, $dataRepository, $log, $token) {
+            register_shutdown_function(function() use ($fork, $dataRepository, $log, $token) {
                 $data = $dataRepository->load(getmypid());
                 try {
                     $data->write($fork);
@@ -226,7 +226,7 @@ 
             $this->wait();
         }
         if (!$this->forkContainer->hasTag($tag)) {
-            throw new \InvalidArgumentException('unknown tag: ' . $tag);
+            throw new \InvalidArgumentException('unknown tag: '.$tag);
         }
 
         return $this->forkContainer->getCollection($tag);
@@ -241,7 +241,7 @@ 
     public function sendSignalToChildren($sig)
     {
         foreach ($this->forkContainer->getChildPids() as $pid) {
-            $this->log->info('----> sending a signal to child. pid: ' . $pid);
+            $this->log->info('----> sending a signal to child. pid: '.$pid);
             posix_kill($pid, $sig);
         }
     }
@@ -344,7 +344,7 @@ 
 
             $childPid = $fork->getPid();
             if ($fork->hasNotFinishedSuccessfully()) {
-                $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);
             }