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

src/Comodojo/Extender/Components/ArrayAccess.php

Indentation +29 added lines, -29 removed lines

@@ -29,45 +29,45 @@
      *
      * @return string $index The offset
      */
-     public function offsetGet($index) {
+        public function offsetGet($index) {
 
-         return $this->data[$index];
+            return $this->data[$index];
 
-     }
+        }
 
-     /**
-     * Assigns a value to index offset
-     *
-     * @param string $index The offset to assign the value to
-     * @param mixed  $value The value to set
-     */
-     public function offsetSet($index, $value) {
+        /**
+         * Assigns a value to index offset
+         *
+         * @param string $index The offset to assign the value to
+         * @param mixed  $value The value to set
+         */
+        public function offsetSet($index, $value) {
 
-         $this->data[$index] = $value;
+            $this->data[$index] = $value;
 
-     }
+        }
 
-     /**
-     * Unsets an index
-     *
-     * @param string $index The offset to unset
-     */
-     public function offsetUnset($index) {
+        /**
+         * Unsets an index
+         *
+         * @param string $index The offset to unset
+         */
+        public function offsetUnset($index) {
 
-         unset($this->data[$index]);
+            unset($this->data[$index]);
 
-     }
+        }
 
-     /**
-     * Check if an index exists
-     *
-     * @param string $index Offset
-     * @return boolean
-     */
-     public function offsetExists($index) {
+        /**
+         * Check if an index exists
+         *
+         * @param string $index Offset
+         * @return boolean
+         */
+        public function offsetExists($index) {
 
-         return $this->offsetGet($index) !== null;
+            return $this->offsetGet($index) !== null;
 
-     }
+        }
 
 }

src/Comodojo/Extender/Tasks/Worklog.php

Indentation +4 added lines, -4 removed lines

@@ -47,21 +47,21 @@
             ->createQueryBuilder()
             ->insert($this->table)
             ->values(array (
-				'id' => 0,
+                'id' => 0,
                 'status' => '?',
                 'pid' => '?',
                 'name' => '?',
                 'jid' => '?',
                 'task' => '?',
-				'parameters' => '?',
+                'parameters' => '?',
                 'start' => '?'
             ))
             ->setParameter(0, 'RUNNING')
-			->setParameter(1, $pid)
+            ->setParameter(1, $pid)
             ->setParameter(2, $name)
             ->setParameter(3, $jobid)
             ->setParameter(4, $task)
-			->setParameter(5, serialize($parameters))
+            ->setParameter(5, serialize($parameters))
             ->setParameter(6, $start)
             ->execute();