comodojo / extender.framework

src/Comodojo/Extender/Orm/Entities/Worklog.php

Doc Comments +3 added lines, -4 removed lines

@@ -185,7 +185,7 @@ 
     /**
      * Get worklog item's parent
      *
-     * @return strin
+     * @return integer
      */
     public function getParentUid() {
 
@@ -222,7 +222,7 @@ 
      * Set associated task
      *
      * @param string $task
-     * @return Schedule
+     * @return Worklog
      */
     public function setTask($task) {
 
@@ -247,7 +247,7 @@ 
      * Set queue item's parameters
      *
      * @param TaskParameters $parameters
-     * @return Schedule
+     * @return Worklog
      */
     public function setParameters(TaskParameters $parameters) {
 
@@ -271,7 +271,6 @@ 
     /**
      * Set current job status
      *
-     * @param string $name
      * @return Worklog
      */
     public function setStatus($status) {

src/Comodojo/Extender/Queue/Manager.php

Doc Comments -2 removed lines

@@ -38,10 +38,8 @@
     /**
      * Class constructor
      *
-     * @param string $manager_name
      * @param Configuration $configuration
      * @param LoggerInterface $logger
-     * @param TasksTable $tasks
      * @param EventsManager $events
      * @param EntityManager $em
      */

Spacing +2 added lines, -2 removed lines

@@ -80,7 +80,7 @@ 
 
         $em = $this->getEntityManager();
 
-        foreach ($queue as $record) {
+        foreach ( $queue as $record ) {
             $em->remove($record);
         }
 
@@ -106,7 +106,7 @@ 
 
         $records = [];
 
-        foreach ($queue as $name => $request) {
+        foreach ( $queue as $name => $request ) {
             $records[] = $request instanceof Request ? $this->doAddRequest($name, $request, $em) : false;
         }
 

src/Comodojo/Extender/Task/Locker.php

Doc Comments +6 added lines

@@ -95,6 +95,9 @@ 
 
     }
 
+    /**
+     * @param null|integer $pid
+     */
     public function setRunning($uid, $pid) {
 
         $request = $this->queued[$uid];
@@ -214,6 +217,9 @@ 
 
     }
 
+    /**
+     * @param string $name
+     */
     public static function create($name, Configuration $configuration, LoggerInterface $logger) {
 
         return new Locker($name, $configuration, $logger);

src/Comodojo/Extender/Traits/BaseEntityTrait.php

Doc Comments +2 added lines, -2 removed lines

@@ -51,7 +51,7 @@ 
      * Set queue item's id
      *
      * @param string $id
-     * @return Schedule
+     * @return BaseEntityTrait
      */
     public function setId($id) {
 
@@ -76,7 +76,7 @@ 
      * Set queue item's name
      *
      * @param string $name
-     * @return Schedule
+     * @return BaseEntityTrait
      */
     public function setName($name) {
 

src/Comodojo/Extender/Traits/BaseWorklogTrait.php

Doc Comments +4 added lines, -4 removed lines

@@ -65,7 +65,7 @@ 
      * Set queue item's id
      *
      * @param string $id
-     * @return Schedule
+     * @return BaseScheduleEntityTrait
      */
     public function setId($id) {
 
@@ -90,7 +90,7 @@ 
      * Set queue item's name
      *
      * @param string $name
-     * @return Schedule
+     * @return BaseScheduleEntityTrait
      */
     public function setName($name) {
 
@@ -115,7 +115,7 @@ 
      * Set associated task
      *
      * @param string $task
-     * @return Schedule
+     * @return BaseScheduleEntityTrait
      */
     public function setTask($task) {
 
@@ -140,7 +140,7 @@ 
      * Set queue item's parameters
      *
      * @param TaskParameters $parameters
-     * @return Schedule
+     * @return BaseScheduleEntityTrait
      */
     public function setParameters(TaskParameters $parameters) {
 

src/Comodojo/Extender/Traits/EntityManagerTrait.php

Doc Comments +1 added lines, -2 removed lines

@@ -39,8 +39,7 @@
     /**
      * Set EntityManager
      *
-     * @param string $id
-     * @return Schedule
+     * @return EntityManagerTrait
      */
     public function setEntityManager(EntityManager $em) {
 

src/Comodojo/Extender/Task/Manager.php

Spacing +4 added lines, -4 removed lines

@@ -139,9 +139,9 @@ 
 
         $responses = [];
 
-        foreach ($requests as $id => $request) {
+        foreach ( $requests as $id => $request ) {
 
-            if ($request instanceof \Comodojo\Extender\Task\Request) {
+            if ( $request instanceof \Comodojo\Extender\Task\Request ) {
                 $this->add($request);
                 $responses[$id] = true;
             } else {
@@ -174,7 +174,7 @@ 
 
     protected function cycle() {
 
-        foreach ($this->locker->getQueued() as $uid => $request) {
+        foreach ( $this->locker->getQueued() as $uid => $request ) {
 
             if ( $this->multithread === false ) {
 
@@ -202,7 +202,7 @@ 
 
                 if ( $this->max_childs > 0 && $this->locker->countRunning() >= $this->max_childs ) {
 
-                    while( $this->locker->countRunning() >= $this->max_childs ) {
+                    while ( $this->locker->countRunning() >= $this->max_childs ) {
 
                         $this->catcher();
 

Doc Comments +3 added lines

@@ -429,6 +429,9 @@
 
     }
 
+    /**
+     * @param string $message
+     */
     private function generateSyntheticResult($uid, $message, $jid = null, $success = true) {
 
         return new Result([

src/Comodojo/Extender/Task/Runner.php

Spacing +5 added lines, -5 removed lines

@@ -97,7 +97,7 @@ 
 
             $thetask = $this->table->get($task)->getInstance($name, $parameters);
 
-            $this->events->emit( new TaskEvent('start', $thetask) );
+            $this->events->emit(new TaskEvent('start', $thetask));
 
             $pid = $thetask->getPid();
 
@@ -112,7 +112,7 @@ 
                 $this->stopwatch->getStartTime()
             );
 
-            $this->events->emit( new TaskStatusEvent('start', $thetask) );
+            $this->events->emit(new TaskStatusEvent('start', $thetask));
 
             try {
 
@@ -134,11 +134,11 @@ 
 
             }
 
-            $this->events->emit( new TaskStatusEvent($status ? 'success' : 'error', $thetask) );
+            $this->events->emit(new TaskStatusEvent($status ? 'success' : 'error', $thetask));
 
-            $this->events->emit( new TaskStatusEvent('stop', $thetask) );
+            $this->events->emit(new TaskStatusEvent('stop', $thetask));
 
-            $this->events->emit( new TaskEvent('stop', $thetask) );
+            $this->events->emit(new TaskEvent('stop', $thetask));
 
             $this->stopwatch->stop();
 

src/Comodojo/Extender/Task/Request.php

Spacing +1 added lines, -1 removed lines

@@ -356,7 +356,7 @@
 
     public function isChain() {
 
-        return ( $this->done !== null || $this->fail !== null || $this->pipe !== null );
+        return ($this->done !== null || $this->fail !== null || $this->pipe !== null);
 
     }
 

Doc Comments +7 added lines, -1 removed lines

@@ -116,6 +116,9 @@ 
 
     }
 
+    /**
+     * @param string $name
+     */
     public function setName($name) {
 
         $this->name = $name;
@@ -135,6 +138,9 @@ 
 
     }
 
+    /**
+     * @param string $task
+     */
     public function setTask($task) {
 
         $this->task = $task;
@@ -260,7 +266,7 @@ 
     /**
      * Get start timestamp (microseconds)
      *
-     * @return float
+     * @return integer
      */
     public function getStartTimestamp() {