comodojo / daemon

src/Comodojo/Daemon/Worker/AbstractWorker.php

Spacing +1 added lines, -1 removed lines

@@ -32,7 +32,7 @@
 
     private $id;
 
-    public function __construct($name=null) {
+    public function __construct($name = null) {
 
         $this->id = uniqid();
 

src/Comodojo/Daemon/Worker/Loop.php

Spacing +5 added lines, -5 removed lines

@@ -49,7 +49,7 @@ 
 
         $this->events = $worker->getInstance()->getEvents();
 
-        $this->looptime = DataFilter::filterInteger($worker->getLooptime(), $min=1, $max=PHP_INT_MAX, $default=1);
+        $this->looptime = DataFilter::filterInteger($worker->getLooptime(), $min = 1, $max = PHP_INT_MAX, $default = 1);
 
         $this->events->subscribe('daemon.worker.stop', '\Comodojo\Daemon\Listeners\StopWorker');
         $this->events->subscribe('daemon.worker.pause', '\Comodojo\Daemon\Listeners\PauseWorker');
@@ -73,7 +73,7 @@ 
 
         // start looping
         $this->setStatus(self::LOOPING);
-        while ($this->active) {
+        while ( $this->active ) {
 
             if ( $this->paused ) {
                 $this->setStatus(self::PAUSED);
@@ -85,7 +85,7 @@ 
 
             $start = microtime(true);
 
-            $this->events->emit( new WorkerEvent('loopstart', $this, $this->worker) );
+            $this->events->emit(new WorkerEvent('loopstart', $this, $this->worker));
 
             $this->worker->getInstance()->loop();
 
@@ -93,7 +93,7 @@ 
 
             $elapsed = (microtime(true) - $start);
 
-            $this->events->emit( new WorkerEvent('loopstop', $this, $this->worker) );
+            $this->events->emit(new WorkerEvent('loopstop', $this, $this->worker));
 
             $lefttime = $this->looptime - $elapsed;
 
@@ -139,7 +139,7 @@ 
         $signal = $this->worker->getOutputChannel()->read();
 
         if ( !empty($signal) ) {
-            $this->events->emit( new WorkerEvent($signal, $this, $this->worker) );
+            $this->events->emit(new WorkerEvent($signal, $this, $this->worker));
             $this->worker->getOutputChannel()->delete();
         }
 

src/Comodojo/Daemon/Worker/SharedMemory.php

Spacing +1 added lines, -1 removed lines

@@ -46,7 +46,7 @@
 
     public function delete() {
 
-        return shmop_write($this->key, str_pad('',128), 0);
+        return shmop_write($this->key, str_pad('', 128), 0);
 
     }
 

src/Comodojo/Daemon/Listeners/WorkerWatchdog.php

Spacing +3 added lines, -3 removed lines

@@ -28,9 +28,9 @@ 
         $workers = $daemon->getWorkers();
         $logger = $daemon->getLogger();
 
-        foreach ($workers as $name => $worker) {
+        foreach ( $workers as $name => $worker ) {
 
-            if ($workers->running($worker->getPid())) {
+            if ( $workers->running($worker->getPid()) ) {
 
                 $logger->debug("Worker $name seems to be running");
 
@@ -38,7 +38,7 @@ 
 
                 $logger->warning("Worker $name has exited");
 
-                if ($worker->getForever()) {
+                if ( $worker->getForever() ) {
                     $logger->warning("Attempting to restart $name");
                     $workers->start($name, true);
                 } else {

src/Comodojo/Daemon/Daemon.php

Spacing +6 added lines, -6 removed lines

@@ -67,7 +67,7 @@ 
      * @property LoggerInterface $logger
      * @property int $pid
      */
-    public function __construct($properties = [], LoggerInterface $logger = null, EventsManager $events = null){
+    public function __construct($properties = [], LoggerInterface $logger = null, EventsManager $events = null) {
 
         if ( !Checks::multithread() ) {
             throw new Exception("Missing pcntl fork");
@@ -98,7 +98,7 @@ 
         $this->console = new CLImate();
         $this->console->description($properties->description);
         $args = new $properties->arguments;
-        $this->console->arguments->add( $args::create()->export() );
+        $this->console->arguments->add($args::create()->export());
 
     }
 
@@ -184,7 +184,7 @@ 
 
         $this->setup();
 
-        foreach ($this->workers as $name => $worker) {
+        foreach ( $this->workers as $name => $worker ) {
 
             $this->workers->start($name);
 
@@ -303,9 +303,9 @@ 
 
     private function detach() {
 
-        if (is_resource(STDOUT)) fclose(STDOUT);
-        if (is_resource(STDERR)) fclose(STDERR);
-        if (is_resource(STDIN)) fclose(STDIN);
+        if ( is_resource(STDOUT) ) fclose(STDOUT);
+        if ( is_resource(STDERR) ) fclose(STDERR);
+        if ( is_resource(STDIN) ) fclose(STDIN);
 
         // become a session leader
         $sid = posix_setsid();

src/Comodojo/Daemon/Process.php

Spacing +3 added lines, -3 removed lines

@@ -44,7 +44,7 @@ 
      * @param LoggerInterface $logger;
      * @param EventsManager $events;
      */
-    public function __construct($niceness = null, LoggerInterface $logger = null, EventsManager $events = null){
+    public function __construct($niceness = null, LoggerInterface $logger = null, EventsManager $events = null) {
 
         if ( !Checks::cli() ) {
             throw new RuntimeException("Process can run only in cli SAPI");
@@ -86,8 +86,8 @@ 
 
             $this->logger->debug("Received $signame ($signal) signal, firing associated event(s)");
 
-            $this->events->emit( new PosixEvent($signal, $this) );
-            $this->events->emit( new PosixEvent($signame, $this) );
+            $this->events->emit(new PosixEvent($signal, $this));
+            $this->events->emit(new PosixEvent($signame, $this));
 
         }
 

src/Comodojo/Daemon/Socket/SocketTransport.php

Spacing +4 added lines, -4 removed lines

@@ -19,7 +19,7 @@ 
         LoggerInterface $logger,
         $data,
         $content_type,
-        $encrypt=false
+        $encrypt = false
     ) {
 
         try {
@@ -187,12 +187,12 @@ 
 
         $datagram = '';
 
-        while (true) {
+        while ( true ) {
             $recv = @socket_read($this->socket, $this->read_buffer, PHP_NORMAL_READ);
             if ( $recv === false ) break;
             if ( $recv === 0 ) return null;
             $datagram .= $recv;
-            if(strstr($recv, PHP_EOL)) break;
+            if ( strstr($recv, PHP_EOL) ) break;
         }
 
         return trim($datagram);
@@ -207,7 +207,7 @@ 
 
             $this->aes->setKey($key);
 
-            $return = 'comodojo_encrypted_request-'.base64_encode( $this->aes->encrypt($data) );
+            $return = 'comodojo_encrypted_request-'.base64_encode($this->aes->encrypt($data));
 
         } else {
 

src/Comodojo/Daemon/Socket/MethodsInjector.php

Spacing +4 added lines, -4 removed lines

@@ -23,7 +23,7 @@ 
             RpcMethod::create("worker.list", function($params, $daemon) {
                 $workers = $daemon->getWorkers()->get();
                 $wlist = [];
-                foreach ($workers as $worker => $opts) {
+                foreach ( $workers as $worker => $opts ) {
                     $wlist[] = [
                         'name' => $worker,
                         'looptime' => $opts->getLoopTime(),
@@ -44,7 +44,7 @@ 
             ->setDescription("Get info about installed worker(s)")
             ->setReturnType('array')
             ->addSignature()
-            ->addParameter('string','name')
+            ->addParameter('string', 'name')
             ->setReturnType('int')
         );
 
@@ -56,7 +56,7 @@ 
             ->setDescription("Pause installed worker(s)")
             ->setReturnType('array')
             ->addSignature()
-            ->addParameter('string','name')
+            ->addParameter('string', 'name')
             ->setReturnType('boolean')
         );
 
@@ -68,7 +68,7 @@ 
             ->setDescription("Resume installed worker(s)")
             ->setReturnType('array')
             ->addSignature()
-            ->addParameter('string','name')
+            ->addParameter('string', 'name')
             ->setReturnType('boolean')
         );
 

src/Comodojo/Daemon/Socket/Connection.php

Spacing +1 added lines, -1 removed lines

@@ -55,7 +55,7 @@
         $err_code = socket_last_error($socket);
         $err_string = socket_strerror($err_code);
 
-        if ( $err_code === 11 || strtolower($err_string) == 'success') return true;
+        if ( $err_code === 11 || strtolower($err_string) == 'success' ) return true;
 
         return $err_string;