ackintosh / snidel

src/Snidel/ForkCollection.php

Spacing +1 added lines, -1 removed lines

@@ -20,7 +20,7 @@
     public function toArray()
     {
         return array_map(
-            function ($fork) {
+            function($fork) {
                 return $fork->getResult()->getReturn();
             },
             $this->forks

src/Snidel/Log.php

Spacing +1 added lines, -1 removed lines

@@ -49,7 +49,7 @@
                 $type,
                 $pid,
                 ($this->ownerPid === $pid) ? 'p' : 'c',
-                $message . PHP_EOL
+                $message.PHP_EOL
             )
         );
     }

src/Snidel/Token.php

Spacing +1 added lines, -1 removed lines

@@ -28,7 +28,7 @@
     {
         $this->ownerPid = $ownerPid;
         $this->concurrency = $concurrency;
-        $this->ipcKey = new IpcKey($ownerPid, 'snidel_token_' . uniqid((string) mt_rand(1, 100), true));
+        $this->ipcKey = new IpcKey($ownerPid, 'snidel_token_'.uniqid((string) mt_rand(1, 100), true));
         $this->id = msg_get_queue($this->ipcKey->generate());
         $this->initializeQueue();
     }

src/Snidel/MapContainer.php

Spacing +1 added lines, -1 removed lines

@@ -137,6 +137,6 @@
             return $index;
         }
 
-        throw new MapContainerException('childPid not found. pid: ' . $childPid);
+        throw new MapContainerException('childPid not found. pid: '.$childPid);
     }
 }

src/Snidel/ForkContainer.php

Spacing +2 added lines, -2 removed lines

@@ -98,8 +98,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);

src/Snidel/IpcKey.php

Spacing +3 added lines, -3 removed lines

@@ -26,7 +26,7 @@ 
      */
     public function generate()
     {
-        $pathname = '/tmp/' . $this->prefix . $this->ownerPid;
+        $pathname = '/tmp/'.$this->prefix.$this->ownerPid;
         if (!file_exists($pathname)) {
             touch($pathname);
         }
@@ -52,8 +52,8 @@ 
      */
     public function delete()
     {
-        if (file_exists('/tmp/' . $this->prefix . $this->ownerPid)) {
-            unlink('/tmp/' . $this->prefix . $this->ownerPid);
+        if (file_exists('/tmp/'.$this->prefix.$this->ownerPid)) {
+            unlink('/tmp/'.$this->prefix.$this->ownerPid);
         }
     }
 }

src/Snidel.php

Spacing +15 added lines, -15 removed lines

@@ -81,8 +81,8 @@ 
         foreach ($this->signals as $sig) {
             $this->pcntl->signal(
                 $sig,
-                function ($sig) use($log, $token, $self) {
-                    $log->info('received signal. signo: ' . $sig);
+                function($sig) use($log, $token, $self) {
+                    $log->info('received signal. signo: '.$sig);
                     $self->setReceivedSignal($sig);
 
                     $log->info('--> sending a signal to children.');
@@ -98,7 +98,7 @@ 
             );
         }
 
-        $this->log->info('parent pid: ' . $this->ownerPid);
+        $this->log->info('parent pid: '.$this->ownerPid);
     }
 
     /**
@@ -134,7 +134,7 @@ 
             throw $e;
         }
 
-        $this->log->info('queued task #' . $this->forkContainer->queuedCount());
+        $this->log->info('queued task #'.$this->forkContainer->queuedCount());
     }
 
     /**
@@ -150,20 +150,20 @@ 
 
         if ($pid) {
             // owner
-            $this->log->info('pid: ' . getmypid());
+            $this->log->info('pid: '.getmypid());
         } elseif ($pid === -1) {
             // error
         } else {
             // master
             $taskQueue = new TaskQueue($this->ownerPid);
-            $this->log->info('pid: ' . $this->masterProcessId);
+            $this->log->info('pid: '.$this->masterProcessId);
 
             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);
                 }
@@ -192,10 +192,10 @@ 
 
         if (getmypid() === $this->masterProcessId) {
             // 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) {
@@ -203,7 +203,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();
@@ -254,7 +254,7 @@ 
 
         if (getmypid() === $this->ownerPid) {
             // parent
-            $this->log->info('created child process. pid: ' . $fork->getPid());
+            $this->log->info('created child process. pid: '.$fork->getPid());
             $this->childPids[] = $fork->getPid();
         } else {
             // @codeCoverageIgnoreStart
@@ -269,7 +269,7 @@ 
             $dataRepository     = $this->dataRepository;
             $log                = $this->log;
             $processToken       = $this->processToken;
-            register_shutdown_function(function () use ($fork, $dataRepository, $log, $processToken) {
+            register_shutdown_function(function() use ($fork, $dataRepository, $log, $processToken) {
                 $data = $dataRepository->load(getmypid());
                 try {
                     $data->write($fork);
@@ -335,7 +335,7 @@ 
         }
 
         if (!$this->forkContainer->hasTag($tag)) {
-            throw new \InvalidArgumentException('unknown tag: ' . $tag);
+            throw new \InvalidArgumentException('unknown tag: '.$tag);
         }
 
         return $this->forkContainer->getCollection($tag);
@@ -350,7 +350,7 @@ 
     public function sendSignalToChildren($sig)
     {
         foreach ($this->childPids 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);
         }
     }
@@ -452,7 +452,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);
             }