ackintosh / snidel

src/Snidel/Fork/Container.php

Doc Comments +7 added lines, -2 removed lines

@@ -53,6 +53,7 @@ 
 
     /**
      * @param   int     $ownerPid
+     * @param \Ackintosh\Snidel\Log $log
      */
     public function __construct($ownerPid, $log, $concurrency = 5)
     {
@@ -68,6 +69,7 @@ 
 
     /**
      * @param   \Ackintosh\Snidel\Task
+     * @param \Ackintosh\Snidel\Task\Task $task
      * @return  void
      * @throws  \RuntimeException
      */
@@ -89,7 +91,7 @@ 
     }
 
     /**
-     * @return  \Ackintosh\Snidel\Fork\Fork
+     * @return  Result
      */
     private function dequeue()
     {
@@ -293,6 +295,9 @@ 
         }
     }
 
+    /**
+     * @param string $tag
+     */
     public function getCollection($tag = null)
     {
         if ($tag === null) {
@@ -335,7 +340,7 @@ 
     }
 
     /**
-     * @return  \Ackintosh\Sniden\Error
+     * @return  Error
      */
     public function getError()
     {

Unused Use Statements -1 removed lines

@@ -9,7 +9,6 @@
 use Ackintosh\Snidel\Result\Queue as ResultQueue;
 use Ackintosh\Snidel\Result\Collection;
 use Ackintosh\Snidel\Error;
-use Ackintosh\Snidel\Exception\SharedMemoryControlException;
 use Ackintosh\Snidel\Worker;
 use Ackintosh\Snidel\ActiveWorkerSet;
 

src/Snidel.php

Spacing +5 added lines, -5 removed lines

@@ -60,8 +60,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.');
@@ -73,7 +73,7 @@ 
             );
         }
 
-        $this->log->info('parent pid: ' . $this->ownerPid);
+        $this->log->info('parent pid: '.$this->ownerPid);
     }
 
     /**
@@ -111,7 +111,7 @@ 
             throw $e;
         }
 
-        $this->log->info('queued task #' . $this->container->queuedCount());
+        $this->log->info('queued task #'.$this->container->queuedCount());
     }
 
     /**
@@ -154,7 +154,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);