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);
 
-      }
+        }
 
     }