comodojo / extender.framework

src/Comodojo/Extender/Components/Ipc.php

Doc Comments +3 added lines

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

src/Comodojo/Extender/Jobs/Manager.php

Doc Comments +3 added lines

@@ -62,6 +62,9 @@
 
     }
 
+    /**
+     * @param integer|null $pid
+     */
     public function isStarting($uid, $pid) {
 
         $job = $this->queued_jobs[$uid];

src/Comodojo/Extender/Jobs/Runner.php

Doc Comments +3 added lines

@@ -384,6 +384,9 @@
 
     }
 
+    /**
+     * @param string $message
+     */
     private function abortQueued($message) {
 
         foreach ($this->manager->queued() as $uid => $job) {

Spacing +13 added lines, -13 removed lines

@@ -123,10 +123,10 @@ 
 
     public function run() {
 
-        foreach ($this->manager->queued() as $uid => $job) {
+        foreach ( $this->manager->queued() as $uid => $job ) {
 
-            $this->events->emit( new JobEvent('start', $job) );
-            $this->events->emit( new JobStatusEvent('start', $job) );
+            $this->events->emit(new JobEvent('start', $job));
+            $this->events->emit(new JobStatusEvent('start', $job));
 
             if ( $this->multithread === false ) {
 
@@ -143,8 +143,8 @@ 
 
                 $this->manager->isCompleted($uid, $result->success, $result->result, $result->wid);
 
-                $this->events->emit( new JobEvent('stop', $job) );
-                $this->events->emit( new JobStatusEvent('stop', $job) );
+                $this->events->emit(new JobEvent('stop', $job));
+                $this->events->emit(new JobStatusEvent('stop', $job));
 
                 continue;
 
@@ -158,8 +158,8 @@ 
 
                 $this->manager->isAborted($uid, $e->getMessage());
 
-                $this->events->emit( new JobEvent('stop', $job) );
-                $this->events->emit( new JobStatusEvent('stop', $job) );
+                $this->events->emit(new JobEvent('stop', $job));
+                $this->events->emit(new JobStatusEvent('stop', $job));
 
                 continue;
 
@@ -169,7 +169,7 @@ 
 
             if ( $this->max_childs > 0 && count($this->manager->running()) >= $this->max_childs ) {
 
-                while( count($this->manager->running()) >= $this->max_childs ) {
+                while ( count($this->manager->running()) >= $this->max_childs ) {
 
                     $this->catcher();
 
@@ -342,8 +342,8 @@ 
 
                 $this->logger->notice("Job ".$job->name."(id: ".$job->id.", uid: $uid) ends in $status");
 
-                $this->events->emit( new JobEvent('stop', $job) );
-                $this->events->emit( new JobStatusEvent('stop', $job) );
+                $this->events->emit(new JobEvent('stop', $job));
+                $this->events->emit(new JobStatusEvent('stop', $job));
 
             } else {
 
@@ -373,8 +373,8 @@ 
 
                     $this->logger->notice("Job ".$job->name."(id: ".$job->id.", uid: $uid) ends in error");
 
-                    $this->events->emit( new JobEvent('stop', $job) );
-                    $this->events->emit( new JobStatusEvent('stop', $job) );
+                    $this->events->emit(new JobEvent('stop', $job));
+                    $this->events->emit(new JobStatusEvent('stop', $job));
 
                 }
 
@@ -386,7 +386,7 @@ 
 
     private function abortQueued($message) {
 
-        foreach ($this->manager->queued() as $uid => $job) {
+        foreach ( $this->manager->queued() as $uid => $job ) {
 
             $this->manager->isAborted($uid, $message);
 

src/Comodojo/Extender/Utils/ProcessTools.php

Doc Comments +3 added lines

@@ -76,6 +76,9 @@
 
     }
 
+    /**
+     * @param integer $pid
+     */
     public static function setNiceness($niceness = null, $pid = null) {
 
         $niceness = self::filterNiceness($niceness);

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;