rybakit / phive-queue

src/PheanstalkQueue.php

Doc Comments +3 added lines

@@ -79,6 +79,9 @@
         $this->doClear('delayed');
     }
 
+    /**
+     * @param string $state
+     */
     protected function doClear($state)
     {
         try {

src/SysVQueue.php

Doc Comments +7 added lines

@@ -38,6 +38,10 @@ 
      */
     private $queue;
 
+    /**
+     * @param boolean $serialize
+     * @param integer $perms
+     */
     public function __construct($key, $serialize = null, $perms = null)
     {
         $this->key = $key;
@@ -118,6 +122,9 @@ 
         return $this->queue;
     }
 
+    /**
+     * @param integer|null $errorCode
+     */
     private static function getErrorMessage($errorCode)
     {
         if ($errorCode) {

tests/Handler/PheanstalkHandler.php

Doc Comments +3 added lines

@@ -41,6 +41,9 @@
         $this->pheanstalk = new Pheanstalk($this->getOption('host'), $this->getOption('port'));
     }
 
+    /**
+     * @param string $state
+     */
     private function doClear($tubeName, $state)
     {
         try {

tests/Queue/Performance.php

Doc Comments +8 added lines

@@ -47,6 +47,10 @@ 
         return [[0], [1]];
     }
 
+    /**
+     * @param integer $queueSize
+     * @param string $item
+     */
     protected function benchmarkPush($queueSize, $item, $delay)
     {
         $eta = $delay ? time() + $delay : null;
@@ -59,6 +63,10 @@ 
         return microtime(true) - $start;
     }
 
+    /**
+     * @param integer $total
+     * @param double $runtime
+     */
     protected function printPerformanceResult($total, $runtime)
     {
         printf("   Total operations:      %d\n", $total);