ackintosh / snidel

src/Snidel/TaskQueue.php

Doc Comments +3 added lines

@@ -11,6 +11,9 @@
     private $queuedCount = 0;
     private $dequeuedCount = 0;
 
+    /**
+     * @param integer $ownerPid
+     */
     public function __construct($ownerPid)
     {
         $this->ownerPid = $ownerPid;

src/Snidel/Task.php

Doc Comments +2 added lines, -2 removed lines

@@ -16,7 +16,7 @@ 
     /**
      * @param   callable    $callable
      * @param   array       $args
-     * @param   string      $string
+     * @param string|null $tag
      */
     public function __construct($callable, $args, $tag)
     {
@@ -60,7 +60,7 @@ 
     }
 
     /**
-     * @return  string|null
+     * @return  string
      */
     public function getTag()
     {

src/Snidel/ForkContainer.php

Doc Comments +9 added lines, -3 removed lines

@@ -45,6 +45,7 @@ 
 
     /**
      * @param   int     $ownerPid
+     * @param Log $log
      */
     public function __construct($ownerPid, $log, $concurrency = 5)
     {
@@ -60,6 +61,7 @@ 
 
     /**
      * @param   \Ackintosh\Snidel\Task
+     * @param Task $task
      * @return  void
      */
     public function enqueue($task)
@@ -155,6 +157,7 @@ 
      * fork worker process
      *
      * @param   \Ackintosh\Snidel\Task
+     * @param Task $task
      * @return  void
      * @throws  \RuntimeException
      */
@@ -262,7 +265,7 @@ 
     }
 
     /**
-     * @return  array
+     * @return  integer[]
      */
     public function getChildPids()
     {
@@ -280,6 +283,9 @@ 
         return $this->forks[$pid];
     }
 
+    /**
+     * @param string $tag
+     */
     public function getCollection($tag = null)
     {
         if ($tag === null) {
@@ -293,7 +299,7 @@ 
      * return forks
      *
      * @param   string  $tag
-     * @return  \Ackintosh\Snidel\Fork[]
+     * @return  ForkCollection
      */
     private function getCollectionWithTag($tag)
     {
@@ -313,7 +319,7 @@ 
     }
 
     /**
-     * @return  \Ackintosh\Sniden\Error
+     * @return  Error
      */
     public function getError()
     {

src/Snidel/ResultQueue.php

Doc Comments +4 added lines

@@ -12,6 +12,9 @@ 
 
     private $dequeuedCount = 0;
 
+    /**
+     * @param integer $ownerPid
+     */
     public function __construct($ownerPid)
     {
         $this->ownerPid = $ownerPid;
@@ -21,6 +24,7 @@ 
 
     /**
      * @param   \Ackintosh\Snidel\Fork
+     * @param Fork $fork
      */
     public function enqueue($fork)
     {

src/Snidel/Log.php

Switch Indentation +9 added lines, -9 removed lines

@@ -50,15 +50,15 @@
         }
         $pid = getmypid();
         switch (true) {
-        case $this->ownerPid === $pid:
-            $role = 'owner';
-            break;
-        case $this->masterPid === $pid:
-            $role = 'master';
-            break;
-        default:
-            $role = 'worker';
-            break;
+            case $this->ownerPid === $pid:
+                $role = 'owner';
+                break;
+            case $this->masterPid === $pid:
+                $role = 'master';
+                break;
+            default:
+                $role = 'worker';
+                break;
         }
         fputs(
             $this->destination,