comodojo / extender.framework

src/Comodojo/Extender/Base/Daemon.php

Doc Comments +3 added lines

@@ -185,6 +185,9 @@
 
     }
 
+    /**
+     * @param integer $looptime
+     */
     public static function getLoopTime($looptime) {
 
         return filter_var($looptime, FILTER_VALIDATE_INT, array(

Spacing +8 added lines, -8 removed lines

@@ -109,29 +109,29 @@ 
 
         $this->logger->notice("Starting daemon (looping each ".$this->looptime." secs, pid: ".$this->pid.")");
 
-        $this->events->emit( new DaemonEvent('start', $this) );
+        $this->events->emit(new DaemonEvent('start', $this));
 
-        while ($this->loopactive) {
+        while ( $this->loopactive ) {
 
             $start = microtime(true);
 
             pcntl_signal_dispatch();
 
-            $this->events->emit( new DaemonEvent('preloop', $this) );
+            $this->events->emit(new DaemonEvent('preloop', $this));
 
-            if ( $this->runlock->check() && $this->loopactive) {
+            if ( $this->runlock->check() && $this->loopactive ) {
 
-                $this->events->emit( new DaemonEvent('loopstart', $this) );
+                $this->events->emit(new DaemonEvent('loopstart', $this));
 
                 $this->loop();
 
-                $this->events->emit( new DaemonEvent('loopstop', $this) );
+                $this->events->emit(new DaemonEvent('loopstop', $this));
 
                 $this->loopcount++;
 
             }
 
-            $this->events->emit( new DaemonEvent('postloop', $this) );
+            $this->events->emit(new DaemonEvent('postloop', $this));
 
             $this->loopelapsed = (microtime(true) - $start);
 
@@ -143,7 +143,7 @@ 
 
         $this->logger->notice("Stopping daemon (pid: ".$this->pid.")");
 
-        $this->events->emit( new DaemonEvent('stop', $this) );
+        $this->events->emit(new DaemonEvent('stop', $this));
 
         $this->end(0);
 

Braces +1 added lines, -2 removed lines

@@ -45,8 +45,7 @@
         LoggerInterface $logger,
         Emitter $events,
         $looptime = 1,
-        $niceness = null)
-    {
+        $niceness = null) {
 
         parent::__construct($configuration, $logger, $events, $niceness);
 

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