comodojo / extender.framework

src/Comodojo/Extender/Task/Manager.php

Spacing +4 added lines, -4 removed lines

@@ -128,9 +128,9 @@ 
 
     public function addBulk(array $requests) {
 
-        foreach ($requests as $id => $request) {
+        foreach ( $requests as $id => $request ) {
 
-            if ($request instanceof \Comodojo\Extender\Task\Request) {
+            if ( $request instanceof \Comodojo\Extender\Task\Request ) {
                 $this->add($request);
             } else {
                 $this->logger->error("Skipping invalid request with local id $id: class mismatch");
@@ -163,7 +163,7 @@ 
 
         $this->installErrorHandler();
 
-        foreach ($this->tracker->getQueued() as $uid => $request) {
+        foreach ( $this->tracker->getQueued() as $uid => $request ) {
 
             if ( $this->multithread === false ) {
 
@@ -191,7 +191,7 @@ 
 
                 if ( $this->max_childs > 0 && $this->tracker->countRunning() >= $this->max_childs ) {
 
-                    while( $this->tracker->countRunning() >= $this->max_childs ) {
+                    while ( $this->tracker->countRunning() >= $this->max_childs ) {
 
                         $this->catcher();
 

src/Comodojo/Extender/Task/Runner.php

Spacing +7 added lines, -7 removed lines

@@ -88,7 +88,7 @@ 
 
             $thetask = $this->table->get($task)->getInstance($name, $parameters);
 
-            $this->events->emit( new TaskEvent('start', $thetask) );
+            $this->events->emit(new TaskEvent('start', $thetask));
 
             $pid = $thetask->getPid();
 
@@ -111,7 +111,7 @@ 
 
                 $status = Worklog::STATUS_COMPLETE;
 
-                $this->events->emit( new TaskEvent('complete', $thetask) );
+                $this->events->emit(new TaskEvent('complete', $thetask));
 
             } catch (TaskException $te) {
 
@@ -119,7 +119,7 @@ 
 
                 $result = $te->getMessage();
 
-                $this->events->emit( new TaskEvent('abort', $thetask) );
+                $this->events->emit(new TaskEvent('abort', $thetask));
 
             } catch (Exception $e) {
 
@@ -127,13 +127,13 @@ 
 
                 $result = $e->getMessage();
 
-                $this->events->emit( new TaskEvent('error', $thetask) );
+                $this->events->emit(new TaskEvent('error', $thetask));
 
             }
 
             $this->restoreErrorHandler();
 
-            $this->events->emit( new TaskEvent('stop', $thetask) );
+            $this->events->emit(new TaskEvent('stop', $thetask));
 
             $this->stopwatch->stop();
 
@@ -167,7 +167,7 @@ 
 
         ob_end_clean();
 
-        $this->events->emit( new TaskEvent(self::statusToEvent($status), $thetask, $result) );
+        $this->events->emit(new TaskEvent(self::statusToEvent($status), $thetask, $result));
 
         return $result;
 
@@ -276,7 +276,7 @@ 
 
     protected function statusToEvent($status) {
 
-        switch ($status) {
+        switch ( $status ) {
             case Worklog::STATUS_COMPLETE:
                 return 'complete';
                 break;