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/Manager.php

Indentation +2 added lines, -2 removed lines

@@ -29,7 +29,7 @@ 
  * THE SOFTWARE.
  */
 
- class Manager implements Iterator, Countable {
+    class Manager implements Iterator, Countable {
 
     use IteratorTrait;
     use CountableTrait;
@@ -274,4 +274,4 @@ 
 
     }
 
- }
+    }

Spacing +10 added lines, -10 removed lines

@@ -93,8 +93,8 @@ 
             ->setInstance($worker)
             ->setLooptime($looptime)
             ->setForever($forever)
-            ->setInputChannel(new SharedMemory((int)'1'.hexdec($worker->getId())))
-            ->setOutputChannel(new SharedMemory((int)'2'.hexdec($worker->getId())));
+            ->setInputChannel(new SharedMemory((int) '1'.hexdec($worker->getId())))
+            ->setOutputChannel(new SharedMemory((int) '2'.hexdec($worker->getId())));
 
         $this->data[$name] = $w;
 
@@ -141,8 +141,8 @@ 
             $worker->getInputChannel()->close();
             $worker->getOutputChannel()->close();
             // open brand new channels
-            $worker->setInputChannel(new SharedMemory((int)'1'.hexdec($worker->getInstance()->getId())))
-                ->setOutputChannel(new SharedMemory((int)'2'.hexdec($worker->getInstance()->getId())));
+            $worker->setInputChannel(new SharedMemory((int) '1'.hexdec($worker->getInstance()->getId())))
+                ->setOutputChannel(new SharedMemory((int) '2'.hexdec($worker->getInstance()->getId())));
         }
 
         // fork worker
@@ -195,7 +195,7 @@ 
 
     public function stop($name = null) {
 
-        foreach ($this->data as $wname => $worker) {
+        foreach ( $this->data as $wname => $worker ) {
 
             $wpid = $worker->getPid();
 
@@ -207,7 +207,7 @@ 
                 // try to gently ask the worker to close
                 $worker->getOutputChannel()->send('stop');
 
-                while (time() < $time) {
+                while ( time() < $time ) {
 
                     if ( !$this->running($wpid) ) break;
                     usleep(20000);
@@ -219,7 +219,7 @@ 
                 $worker->getOutputChannel()->close();
 
                 // terminate the worker if still alive
-                if ($this->running($wpid)) ProcessTools::term($wpid, 5, SIGTERM);
+                if ( $this->running($wpid) ) ProcessTools::term($wpid, 5, SIGTERM);
 
             }
 
@@ -231,7 +231,7 @@ 
 
         if ( empty($name) ) {
             $result = [];
-            foreach ($this->data as $name => $worker) {
+            foreach ( $this->data as $name => $worker ) {
                 $result[$name] = $worker->getOutputChannel()->send('pause') > 0;
             }
             return $result;
@@ -245,7 +245,7 @@ 
 
         if ( empty($name) ) {
             $result = [];
-            foreach ($this->data as $name => $worker) {
+            foreach ( $this->data as $name => $worker ) {
                 $result[$name] = $worker->getOutputChannel()->send('resume') > 0;
             }
             return $result;
@@ -266,7 +266,7 @@ 
         if ( $name === null ) {
 
             $result = [];
-            foreach ($this->data as $name => $worker) {
+            foreach ( $this->data as $name => $worker ) {
                 $result[$name] = $this->getStatus($worker);
             }
             return $result;

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

Braces +1 added lines, -1 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");

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

Braces +1 added lines, -1 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");

src/Comodojo/Daemon/Socket/Server.php

Indentation +2 added lines, -2 removed lines

@@ -288,9 +288,9 @@
 
                     if ($message === null) {
                     // if ($message == null) {
-                         $this->hangup($client);
+                            $this->hangup($client);
                     } else if ( $message === false ) {
-                         continue;
+                            continue;
                     } else {
                         $output = $this->serve($message);
                         $this->write($client, $output);

Spacing +15 added lines, -15 removed lines

@@ -169,7 +169,7 @@ 
 
             do {
                 $this->loop();
-            } while ($this->active);
+            } while ( $this->active );
 
         } catch (Exception $e) {
 
@@ -205,7 +205,7 @@ 
 
         $select = @socket_select($sockets, $write, $except, $this->timeout);
 
-        if ($select === false) {
+        if ( $select === false ) {
 
             if ( $this->checkSocketError() && $this->active ) {
                 $this->logger->debug("Socket reset due to incoming signal");
@@ -219,13 +219,13 @@ 
 
         }
 
-        if( $select < 1 ) {
+        if ( $select < 1 ) {
             return;
         }
 
-        if( in_array($this->socket, $sockets) ) {
+        if ( in_array($this->socket, $sockets) ) {
 
-            for ($i=0; $i < $select; $i++) {
+            for ( $i = 0; $i < $select; $i++ ) {
 
                 if ( empty($this->connections[$i]) ) {
 
@@ -251,17 +251,17 @@ 
 
         }
 
-        for ($i = 0; $i < $this->max_connections; $i++) {
+        for ( $i = 0; $i < $this->max_connections; $i++ ) {
 
-            if (isset($this->connections[$i])) {
+            if ( isset($this->connections[$i]) ) {
 
                 $client = $this->connections[$i];
 
-                if (in_array($client->getSocket(), $sockets)) {
+                if ( in_array($client->getSocket(), $sockets) ) {
 
                     $message = $this->read($client);
 
-                    if ($message === null) {
+                    if ( $message === null ) {
                     // if ($message == null) {
                          $this->hangup($client);
                     } else if ( $message === false ) {
@@ -293,16 +293,16 @@ 
         $datagram = '';
         $socket = $connection->getSocket();
 
-        while (true) {
+        while ( true ) {
             $recv = @socket_read($socket, $this->read_buffer, PHP_NORMAL_READ);
             if ( $recv === false ) return null;
             $datagram .= $recv;
-            if (empty($recv) || strstr($recv, PHP_EOL)) break;
+            if ( empty($recv) || strstr($recv, PHP_EOL) ) break;
         }
 
         $datagram = trim($datagram);
 
-        if ( !empty($datagram) && $datagram !== false) {
+        if ( !empty($datagram) && $datagram !== false ) {
 
             $message = new Request();
 
@@ -323,7 +323,7 @@ 
 
         $response = new Response();
 
-        if ( $request->content_type == 'application/json') {
+        if ( $request->content_type == 'application/json' ) {
             $this->rpc_server->setProtocol(RpcServer::JSONRPC);
         }
 
@@ -352,7 +352,7 @@ 
 
         $this->logger->debug("Opening connection ($idx), sending greeter");
 
-        $this->events->emit( new SocketEvent('client.connect', $this->process) );
+        $this->events->emit(new SocketEvent('client.connect', $this->process));
 
         $message = new Greeter();
 
@@ -371,7 +371,7 @@ 
         $this->connections[$index]->destroy();
         unset($this->connections[$index]);
 
-        $this->events->emit( new SocketEvent('client.hangup', $this->process) );
+        $this->events->emit(new SocketEvent('client.hangup', $this->process));
 
     }
 

src/Comodojo/Daemon/Socket/SocketTransport.php

Indentation +1 added lines, -1 removed lines

@@ -238,7 +238,7 @@
     }
 
     /**
-    * Check if an encrypted envelope is consisent or not
+     * Check if an encrypted envelope is consisent or not
      *
      * @param   string    $data
      *

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 {