ackintosh / snidel

src/Snidel/Fork/Container.php

Doc Comments +9 added lines, -4 removed lines

@@ -59,6 +59,7 @@ 
 
     /**
      * @param   int     $ownerPid
+     * @param \Ackintosh\Snidel\Log $log
      */
     public function __construct($ownerPid, $log, $concurrency = 5)
     {
@@ -74,6 +75,7 @@ 
 
     /**
      * @param   \Ackintosh\Snidel\Task
+     * @param \Ackintosh\Snidel\Task\Task $task
      * @return  void
      * @throws  \RuntimeException
      */
@@ -95,7 +97,7 @@ 
     }
 
     /**
-     * @return  \Ackintosh\Snidel\Fork\Fork
+     * @return  Result
      */
     private function dequeue()
     {
@@ -345,7 +347,7 @@ 
     }
 
     /**
-     * @return  array
+     * @return  Fork[]
      */
     public function getChildren()
     {
@@ -356,13 +358,16 @@ 
      * return fork
      *
      * @param   int     $pid
-     * @return  \Ackintosh\Snidel\Fork\Fork
+     * @return  Result
      */
     public function get($pid)
     {
         return $this->results[$pid];
     }
 
+    /**
+     * @param string $tag
+     */
     public function getCollection($tag = null)
     {
         if ($tag === null) {
@@ -405,7 +410,7 @@ 
     }
 
     /**
-     * @return  \Ackintosh\Sniden\Error
+     * @return  Error
      */
     public function getError()
     {

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);
             }