ackintosh / snidel

src/Snidel/Task/Task.php

Doc Comments +2 added lines, -3 removed lines

@@ -19,7 +19,6 @@ 
     /**
      * @param   callable    $callable
      * @param   array       $args
-     * @param   string      $string
      */
     public function __construct($callable, $args, $tag)
     {
@@ -45,7 +44,7 @@ 
     }
 
     /**
-     * @return  string|null
+     * @return  string
      */
     public function getTag()
     {
@@ -53,7 +52,7 @@ 
     }
 
     /**
-     * @return  Ackintosh\Snidel\Result\Result
+     * @return  Result
      */
     public function execute()
     {

src/Snidel.php

Spacing +9 added lines, -9 removed lines

@@ -64,8 +64,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.');
@@ -77,7 +77,7 @@ 
             );
         }
 
-        $this->log->info('parent pid: ' . $this->ownerPid);
+        $this->log->info('parent pid: '.$this->ownerPid);
     }
 
     /**
@@ -115,7 +115,7 @@ 
             throw $e;
         }
 
-        $this->log->info('queued task #' . $this->forkContainer->queuedCount());
+        $this->log->info('queued task #'.$this->forkContainer->queuedCount());
     }
 
     /**
@@ -142,7 +142,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
@@ -155,7 +155,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());
@@ -237,7 +237,7 @@ 
             $this->wait();
         }
         if ($tag !== null && !$this->forkContainer->hasTag($tag)) {
-            throw new \InvalidArgumentException('unknown tag: ' . $tag);
+            throw new \InvalidArgumentException('unknown tag: '.$tag);
         }
 
         return $this->forkContainer->getCollection($tag);
@@ -252,7 +252,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);
         }
     }
@@ -353,7 +353,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);
             }

src/Snidel/ForkContainer.php

Spacing +6 added lines, -6 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,7 +147,7 @@ 
         } 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);
@@ -155,7 +155,7 @@ 
             $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);
@@ -186,10 +186,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) {
@@ -198,7 +198,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->setFailure();