comodojo / extender.framework

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() {
 

test_socket_2.php

Spacing +1 added lines, -1 removed lines

@@ -6,7 +6,7 @@
 
     $client = \Comodojo\Daemon\Socket\Client::create('unix://extender.sock');
 
-    $data = $client->send('scheduler:refresh',[]);
+    $data = $client->send('scheduler:refresh', []);
 
 } catch (Exception $e) {
 

src/Comodojo/Extender/Components/Ipc.php

Doc Comments +7 added lines

@@ -48,6 +48,9 @@ 
 
     }
 
+    /**
+     * @param integer $uid
+     */
     public function init($uid) {
 
         $this->ipc[$uid] = [];
@@ -72,6 +75,10 @@ 
 
     }
 
+    /**
+     * @param integer $uid
+     * @param string $data
+     */
     public function write($uid, $data) {
 
         $writer = $this->ipc[$uid][self::WRITER];

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

Doc Comments +3 added lines, -3 removed lines

@@ -136,7 +136,7 @@ 
     /**
      * Get cron expression of this schedule
      *
-     * @return string
+     * @return CronExpression
      */
     public function getExpression() {
 
@@ -147,7 +147,7 @@ 
     /**
      * set cron expression for this schedule
      *
-     * @param srting $expression A cron-compatible expression
+     * @param CronExpression $expression A cron-compatible expression
      * @return Schedule
      */
     public function setExpression(CronExpression $expression) {
@@ -177,7 +177,7 @@ 
     /**
      * Set enable/disable status
      *
-     * @param bool $enable
+     * @param boolean $enabled
      * @return Schedule
      */
     public function setEnabled($enabled) {

src/Comodojo/Extender/Schedule/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 +3 added lines, -3 removed lines

@@ -138,7 +138,7 @@ 
         $date = new DateTime();
         $timestamps = [];
 
-        foreach ($items as $schedule) {
+        foreach ( $items as $schedule ) {
 
             $timestamps[] = $schedule->getNextPlannedRun($date)->getTimestamp();
 
@@ -152,7 +152,7 @@ 
 
         $em = $this->getEntityManager();
 
-        foreach ($results as $result) {
+        foreach ( $results as $result ) {
 
             $id = $result->jid;
 
@@ -196,7 +196,7 @@ 
 
         $records = [];
 
-        foreach ($schedules as $key => $schedule) {
+        foreach ( $schedules as $key => $schedule ) {
 
             try {