comodojo / extender.framework

src/Extender.php

Indentation +89 added lines, -89 removed lines

@@ -653,175 +653,175 @@
 
     private function cycle() {
 
-      // fire extender ready event
+        // fire extender ready event
 
-      $this->events->fire("extender", "VOID", $this);
+        $this->events->fire("extender", "VOID", $this);
 
-      // dispatch signals (if multithread active)
+        // dispatch signals (if multithread active)
 
-      if ( $this->getMultithreadMode() ) pcntl_signal_dispatch();
+        if ( $this->getMultithreadMode() ) pcntl_signal_dispatch();
 
-      // if extender is paused (SIGINT), skip to extend
+        // if extender is paused (SIGINT), skip to extend
 
-      if ( $this->paused ) return;
+        if ( $this->paused ) return;
 
-      // fix relative timestamp
+        // fix relative timestamp
 
-      $this->timestamp = microtime(true);
+        $this->timestamp = microtime(true);
 
-      // fire tasktable event
+        // fire tasktable event
 
-      $this->tasks = $this->events->fire("extender.tasks", "TASKSTABLE", $this->tasks);
+        $this->tasks = $this->events->fire("extender.tasks", "TASKSTABLE", $this->tasks);
 
-      // get the next planned activity interval
+        // get the next planned activity interval
 
-      $plans = Planner::get();
+        $plans = Planner::get();
 
-      if ( !is_null($plans) AND $this->timestamp < $plans ) {
+        if ( !is_null($plans) AND $this->timestamp < $plans ) {
 
-          // nothing to do right now, still waiting if in daemon mode
+            // nothing to do right now, still waiting if in daemon mode
 
-          $this->logger->info("Next planned job: ".date('c', $plans));
+            $this->logger->info("Next planned job: ".date('c', $plans));
 
-          $this->logger->notice("Extender completed\n");
+            $this->logger->notice("Extender completed\n");
 
-          if ( $this->getDaemonMode() === false ) {
+            if ( $this->getDaemonMode() === false ) {
 
-              $this->shutdown(true);
+                $this->shutdown(true);
 
-              self::end(0);
+                self::end(0);
 
-          }
+            }
 
-          return;
+            return;
 
-      }
+        }
 
-      // if no plan is retrieved, try to retrieve it from scheduler
+        // if no plan is retrieved, try to retrieve it from scheduler
 
-      try {
+        try {
 
-          // get schedules and dispatch schedule event
+            // get schedules and dispatch schedule event
 
-          list($schedules, $planned) = Scheduler::getSchedules($this->logger, $this->timestamp);
+            list($schedules, $planned) = Scheduler::getSchedules($this->logger, $this->timestamp);
 
-          // write next planned activity interval
+            // write next planned activity interval
 
-          if ( !is_null($planned) AND $planned != 0 ) Planner::set($planned);
+            if ( !is_null($planned) AND $planned != 0 ) Planner::set($planned);
 
-          $scheduled = new Schedule();
+            $scheduled = new Schedule();
 
-          $scheduled->setSchedules($schedules);
+            $scheduled->setSchedules($schedules);
 
-          // expose the current shcedule via events
+            // expose the current shcedule via events
 
-          $scheduled = $this->events->fire("extender.schedule", "SCHEDULE", $scheduled);
+            $scheduled = $this->events->fire("extender.schedule", "SCHEDULE", $scheduled);
 
-          // if no jobs in queue, exit gracefully
+            // if no jobs in queue, exit gracefully
 
-          if ( $scheduled->howMany() == 0 ) {
+            if ( $scheduled->howMany() == 0 ) {
 
-              $this->logger->info("No jobs to process right now, exiting");
+                $this->logger->info("No jobs to process right now, exiting");
 
-              $this->logger->notice("Extender completed\n");
+                $this->logger->notice("Extender completed\n");
 
-              if ( $this->getDaemonMode() === false ) {
+                if ( $this->getDaemonMode() === false ) {
 
-                  $this->shutdown(true);
+                    $this->shutdown(true);
 
-                  self::end(0);
+                    self::end(0);
 
-              }
+                }
 
-              return;
+                return;
 
-          }
+            }
 
-          // compose jobs
+            // compose jobs
 
-          foreach ( $scheduled->getSchedules() as $schedule ) {
+            foreach ( $scheduled->getSchedules() as $schedule ) {
 
-              if ( $this->tasks->isRegistered($schedule['task']) ) {
+                if ( $this->tasks->isRegistered($schedule['task']) ) {
 
-                  $job = new Job();
+                    $job = new Job();
 
-                  $job->setName($schedule['name'])
-                      ->setId($schedule['id'])
-                      ->setParameters(unserialize($schedule['params']))
-                      ->setTask($schedule['task'])
-                      ->setClass($this->tasks->getClass($schedule['task']));
+                    $job->setName($schedule['name'])
+                        ->setId($schedule['id'])
+                        ->setParameters(unserialize($schedule['params']))
+                        ->setTask($schedule['task'])
+                        ->setClass($this->tasks->getClass($schedule['task']));
 
-                  $this->runner->addJob($job);
+                    $this->runner->addJob($job);
 
-              } else {
+                } else {
 
-                  $this->logger->warning("Skipping job due to unknown task", array(
-                      "ID"     => $schedule['id'],
-                      "NAME"   => $schedule['name'],
-                      "TASK"   => $schedule['task']
-                  ));
+                    $this->logger->warning("Skipping job due to unknown task", array(
+                        "ID"     => $schedule['id'],
+                        "NAME"   => $schedule['name'],
+                        "TASK"   => $schedule['task']
+                    ));
 
-              }
+                }
 
-          }
+            }
 
-          // lauch runner
+            // lauch runner
 
-          $result = $this->runner->run();
+            $result = $this->runner->run();
 
-          // free runner for next cycle
+            // free runner for next cycle
 
-          $this->runner->free();
+            $this->runner->free();
 
-          // compose results
+            // compose results
 
-          $results = new JobsResult($result);
+            $results = new JobsResult($result);
 
-          // update schedules
+            // update schedules
 
-          Scheduler::updateSchedules($this->logger, $result);
+            Scheduler::updateSchedules($this->logger, $result);
 
-          // increment counters
+            // increment counters
 
-          foreach ( $result as $r ) {
+            foreach ( $result as $r ) {
 
-              if ( $r[2] ) $this->completed_processes++;
+                if ( $r[2] ) $this->completed_processes++;
 
-              else $this->failed_processes++;
+                else $this->failed_processes++;
 
-          }
+            }
 
-      } catch (Exception $e) {
+        } catch (Exception $e) {
 
-          $this->logger->error($e->getMessage());
+            $this->logger->error($e->getMessage());
 
-          if ( $this->getDaemonMode() === false ) {
+            if ( $this->getDaemonMode() === false ) {
 
-              self::end(1);
+                self::end(1);
 
-          }
+            }
 
-      }
+        }
 
-      // fire result event
+        // fire result event
 
-      $this->events->fire("extender.result", "VOID", $results);
+        $this->events->fire("extender.result", "VOID", $results);
 
-      $this->logger->notice("Extender completed\n");
+        $this->logger->notice("Extender completed\n");
 
-      // show summary (if -s)
+        // show summary (if -s)
 
-      if ( $this->summary_mode ) self::showSummary($this->timestamp, $result, $this->color);
+        if ( $this->summary_mode ) self::showSummary($this->timestamp, $result, $this->color);
 
-      Status::dump($this->timestamp_absolute, $this->parent_pid, $this->completed_processes, $this->failed_processes, $this->paused);
+        Status::dump($this->timestamp_absolute, $this->parent_pid, $this->completed_processes, $this->failed_processes, $this->paused);
 
-      if ( $this->getDaemonMode() === false ) {
+        if ( $this->getDaemonMode() === false ) {
 
-          $this->shutdown(true);
+            $this->shutdown(true);
 
-          self::end(0);
+            self::end(0);
 
-      }
+        }
 
     }
 

Spacing +1 added lines, -1 removed lines

@@ -482,7 +482,7 @@
                 )
             )) : 1;
 
-            while (true) {
+            while ( true ) {
 
                 $this->cycle();
 

src/Comodojo/Extender/Extender.php

Spacing +1 added lines, -1 removed lines

@@ -27,7 +27,7 @@
     ) {
 
         // parsing configuration
-        $this->configuration = new Configuration( DefaultConfiguration::get() );
+        $this->configuration = new Configuration(DefaultConfiguration::get());
         $this->configuration->merge($configuration);
 
         // fix the daemon start time

src/Comodojo/Extender/Listeners/StopSummary.php

Spacing +7 added lines, -7 removed lines

@@ -14,24 +14,24 @@
         $chars = 60;
 
         // show the header
-        $console->br()->border('-',$chars);
+        $console->br()->border('-', $chars);
         $console->bold()->flank('Extender execution summary');
-        $console->border('-',$chars);
+        $console->border('-', $chars);
         $console->out('Total run time: '.self::calculateRunTime($daemon->starttime));
-        $console->border('-',$chars);
+        $console->border('-', $chars);
         $padding = $console->padding(26);
-        $padding->label('Total processed jobs')->result($daemon->completedjobs+$daemon->failedjobs);
+        $padding->label('Total processed jobs')->result($daemon->completedjobs + $daemon->failedjobs);
         $padding = $console->padding(30);
         $padding->label('├─ Completed')->result('<light_green>'.$daemon->completedjobs.'</green>');
         $padding->label('└─ Failed')->result('<red>'.$daemon->failedjobs.'</red>');
-        $console->border('-',$chars);
+        $console->border('-', $chars);
 
     }
 
     private static function calculateRunTime($starttime) {
 
-        $start_formatted = sprintf("%06d",($starttime - floor($starttime)) * 1000000);
-        $start = new DateTime( date('Y-m-d H:i:s.'.$start_formatted, $starttime) );
+        $start_formatted = sprintf("%06d", ($starttime - floor($starttime)) * 1000000);
+        $start = new DateTime(date('Y-m-d H:i:s.'.$start_formatted, $starttime));
         $end = new DateTime();
 
         $diff = $end->diff($start);

src/Comodojo/Extender/Listeners/LoopLimit.php

Spacing +1 added lines, -1 removed lines

@@ -9,7 +9,7 @@
 
         $daemon = $event->getDaemon();
 
-        if ( $daemon->looplimit === $daemon->loopcount) {
+        if ( $daemon->looplimit === $daemon->loopcount ) {
             $daemon->logger->info('Stopping daemon due to loop limit ('.$daemon->looplimit.') reached');
             // $daemon->stop();
             $daemon->loopactive = false;

src/Comodojo/Extender/Listeners/LoopSummary.php

Spacing +2 added lines, -2 removed lines

@@ -14,10 +14,10 @@
 
         if ( empty($jobs) ) return;
 
-        $console->border('-',30);
+        $console->border('-', 30);
         $console->bold()->green('Extender loop summary');
         $console->out("Loop duration: ".round($daemon->loopelapsed));
-        $console->border('-',30);
+        $console->border('-', 30);
         $console->out("Executed jobs: ");
         $console->table($jobs);
 

src/Comodojo/Extender/Utils/Validator.php

Braces +1 added lines, -2 removed lines

@@ -55,8 +55,7 @@
 
             if ( $e_count == 5 ) $e_array[] = "*";
 
-        }
-        catch (Exception $e) {
+        } catch (Exception $e) {
 
             throw $e;
 

src/Comodojo/Extender/Events/TaskStatusEvent.php

Doc Comments +3 added lines

@@ -28,6 +28,9 @@
 
     private $task;
 
+    /**
+     * @param string $status
+     */
     public function __construct($status, TaskInterface $task) {
 
         $name = $task->getName();

src/Comodojo/Extender/Task/AbstractTask.php

Doc Comments +5 added lines, -8 removed lines

@@ -67,8 +67,7 @@ 
     /**
      * Get niceness of a running process
      *
-     * @param int|null $pid The pid to query, or current process if null
-     * @return int
+     * @return string
      */
     public function getName() {
 
@@ -79,8 +78,7 @@ 
     /**
      * Get niceness of a running process
      *
-     * @param int|null $pid The pid to query, or current process if null
-     * @return int
+     * @return TaskParameters
      */
     public function getParameters() {
 
@@ -91,8 +89,8 @@ 
     /**
      * Get niceness of a running process
      *
-     * @param int|null $pid The pid to query, or current process if null
-     * @return int
+     * @param string $name
+     * @return AbstractTask
      */
     public function setName($name) {
 
@@ -105,8 +103,7 @@ 
     /**
      * Get niceness of a running process
      *
-     * @param int|null $pid The pid to query, or current process if null
-     * @return int
+     * @return AbstractTask
      */
     public function setParameters(TaskParameters $parameters) {
 

src/Comodojo/Extender/Task/Table.php

Spacing +1 added lines, -1 removed lines

@@ -137,7 +137,7 @@
 
         $result = [];
 
-        foreach($tasks as $task) {
+        foreach ( $tasks as $task ) {
 
             if ( empty($task['name']) || empty($task['class']) ) {