kakserpom / phpdaemon

lib/FlashPolicyServer.php

Spacing +2 added lines, -2 removed lines

@@ -8,7 +8,7 @@ 
  */
 class FlashPolicyServer extends NetworkServer {
 
-	public $policyData;          // Cached policy-file.
+	public $policyData; // Cached policy-file.
 	/**
 	 * Setting default config options
 	 * Overriden from ConnectionPool::getConfigDefaults
@@ -17,7 +17,7 @@ 
 	protected function getConfigDefaults() {
 		return array(
 			// @todo add description strings
-			'file'                  =>  getcwd().'/conf/crossdomain.xml',
+			'file'                  =>  getcwd() . '/conf/crossdomain.xml',
 			'listen'				=> '0.0.0.0',
 			'port' 			        => 843,
 		);

lib/Daemon_Bootstrap.php

Spacing +9 added lines, -9 removed lines

@@ -122,7 +122,7 @@ 
 
 
 		if ('log' === $runmode) {
-			passthru('tail -n '.$n.' -f '.escapeshellarg(Daemon::$config->logstorage->value));
+			passthru('tail -n ' . $n . ' -f ' . escapeshellarg(Daemon::$config->logstorage->value));
 			exit;
 		}
 
@@ -131,7 +131,7 @@ 
 		}
 		
 		if (isset(Daemon::$config->locale->value) && Daemon::$config->locale->value !== '') {
-			setlocale(LC_ALL,explode(',', Daemon::$config->locale->value));
+			setlocale(LC_ALL, explode(',', Daemon::$config->locale->value));
 		}
 		
 		if (
@@ -329,7 +329,7 @@ 
 		elseif ($runmode == 'reopenlog') {
 			if (
 				(!Daemon_Bootstrap::$pid) 
-				|| (!posix_kill(Daemon_Bootstrap::$pid,SIGUSR1))
+				|| (!posix_kill(Daemon_Bootstrap::$pid, SIGUSR1))
 			) {
 				echo '[REOPEN-LOG] ERROR. It seems that phpDaemon is not running' . (Daemon_Bootstrap::$pid ? ' (PID ' . Daemon_Bootstrap::$pid . ')' : '') . ".\n";
 			}
@@ -337,7 +337,7 @@ 
 		elseif ($runmode == 'reload') {
 			if (
 				(!Daemon_Bootstrap::$pid) 
-				|| (!posix_kill(Daemon_Bootstrap::$pid,SIGUSR2))
+				|| (!posix_kill(Daemon_Bootstrap::$pid, SIGUSR2))
 			) {
 				echo '[RELOAD] ERROR. It seems that phpDaemon is not running' . (Daemon_Bootstrap::$pid ? ' (PID ' . Daemon_Bootstrap::$pid . ')' : '') . ".\n";
 			}
@@ -368,7 +368,7 @@ 
 			);
 			
 			foreach (Daemon::$config as $name => $entry) {
-				if (!$entry instanceof Daemon_ConfigEntry) {continue;}
+				if (!$entry instanceof Daemon_ConfigEntry) {continue; }
 				
 				$row = array(
 					'parameter' => $name,
@@ -392,7 +392,7 @@ 
 		elseif ($runmode == 'hardstop') {
 			echo '[HARDSTOP] Sending SIGINT to ' . Daemon_Bootstrap::$pid . '... ';
 
-			$ok = Daemon_Bootstrap::$pid && posix_kill(Daemon_Bootstrap::$pid,SIGINT);
+			$ok = Daemon_Bootstrap::$pid && posix_kill(Daemon_Bootstrap::$pid, SIGINT);
 
 			echo $ok ? 'OK.' : 'ERROR. It seems that phpDaemon is not running.';
 
@@ -437,7 +437,7 @@ 
 
 		echo "\nAlso you can use some optional parameters to override the same configuration variables:\n";
 
-		foreach(self::$params as $name => $desc) {
+		foreach (self::$params as $name => $desc) {
 			if (empty($desc)) {
 				continue;
 			} 
@@ -478,7 +478,7 @@ 
 	 * @return void
 	 */
 	public static function stop($mode = 1) {
-		$ok = Daemon_Bootstrap::$pid && posix_kill(Daemon_Bootstrap::$pid, $mode === 3 ? SIGINT:SIGTERM);
+		$ok = Daemon_Bootstrap::$pid && posix_kill(Daemon_Bootstrap::$pid, $mode === 3 ? SIGINT : SIGTERM);
 
 		if (!$ok) {
 			echo '[WARN]. It seems that phpDaemon is not running' . (Daemon_Bootstrap::$pid ? ' (PID ' . Daemon_Bootstrap::$pid . ')' : '') . ".\n";
@@ -506,7 +506,7 @@ 
 		$out = array();
 		$last_arg = NULL;
 		
-		for($i = 1, $il = sizeof($args); $i < $il; ++$i) {
+		for ($i = 1, $il = sizeof($args); $i < $il; ++$i) {
 			if (preg_match('~^--(.+)~', $args[$i], $match)) {
 				$parts = explode('=', $match[1]);
 				$key = preg_replace('~[^a-z0-9]+~', '', $parts[0]);

lib/AppInstance.php

Spacing +7 added lines, -7 removed lines

@@ -9,10 +9,10 @@ 
  */
 class AppInstance {
 
-	public $status = 0;        // runtime status
-	public $passphrase;        // optional passphrase
-	public $ready = FALSE;     // ready to start?
-	public $name;              // name of instance
+	public $status = 0; // runtime status
+	public $passphrase; // optional passphrase
+	public $ready = FALSE; // ready to start?
+	public $name; // name of instance
 	public $config;
 	public $enableRPC = false;
 	public $requestClass;
@@ -172,16 +172,16 @@ 
 			$k = strtolower(str_replace('-', '', $k));
 
 			if (!isset($this->config->{$k})) {
-			  if (is_scalar($v))	{
+			  if (is_scalar($v)) {
 					$this->config->{$k} = new Daemon_ConfigEntry($v);
 				} else {
 					$this->config->{$k} = $v;
 				}
 			} elseif ($v instanceof Daemon_ConfigSection) {
 			// @todo
-			}	else {
+			} else {
 				$current = $this->config->{$k};
-			  if (is_scalar($v))	{
+			  if (is_scalar($v)) {
 					$this->config->{$k} = new Daemon_ConfigEntry($v);
 				} else {
 					$this->config->{$k} = $v;

lib/FS.php

Spacing +10 added lines, -10 removed lines

@@ -24,7 +24,7 @@ 
 	public static $fdCache;
 	public static $fdCacheSize = 128;
 	public static function init() {
-		if (!self::$supported =	Daemon::loadModuleIfAbsent('eio')) {
+		if (!self::$supported = Daemon::loadModuleIfAbsent('eio')) {
 			Daemon::log('FS: missing pecl-eio, Filesystem I/O performance compromised. Consider installing pecl-eio.');
 			return;
 		}
@@ -37,7 +37,7 @@ 
 		}
 		self::updateConfig();
 		self::$fd = eio_get_event_stream();
-		self::$ev = new Event(Daemon::$process->eventBase, self::$fd, Event::READ | Event::PERSIST, function ($fd, $events, $arg) {
+		self::$ev = new Event(Daemon::$process->eventBase, self::$fd, Event::READ | Event::PERSIST, function($fd, $events, $arg) {
 			while (eio_nreqs()) {
 	        	eio_poll();
 		    }
@@ -91,7 +91,7 @@ 
 			call_user_func($cb, $path, FS::statPrepare(@stat($path)));
 			return;
 		}
-		return eio_stat($path, $pri, function($path, $stat) use ($cb) {call_user_func($cb, $path, FS::statPrepare($stat));}, $path);
+		return eio_stat($path, $pri, function($path, $stat) use ($cb) {call_user_func($cb, $path, FS::statPrepare($stat)); }, $path);
 	}
 	
 	public static function unlink($path, $cb = null, $pri = EIO_PRI_DEFAULT) {
@@ -118,7 +118,7 @@ 
 			call_user_func($cb, $path, FS::statPrepare(lstat($path)));
 			return;
 		}
-		return eio_lstat($path, $pri, function($path, $stat) use ($cb) {call_user_func($cb, $path, FS::statPrepare($stat));}, $path);
+		return eio_lstat($path, $pri, function($path, $stat) use ($cb) {call_user_func($cb, $path, FS::statPrepare($stat)); }, $path);
 	}
 	
 	public static function realpath($path, $cb, $pri = EIO_PRI_DEFAULT) {
@@ -182,7 +182,7 @@ 
 		return eio_mkdir($path, $mode, $pri, $cb, $path);
 	}
 	
-	public static function readdir($path, $cb = null, $flags,  $pri = EIO_PRI_DEFAULT) {
+	public static function readdir($path, $cb = null, $flags, $pri = EIO_PRI_DEFAULT) {
 		if (!FS::$supported) {
 			$r = glob($path);
 			if ($cb) {
@@ -211,7 +211,7 @@ 
 			call_user_func($cb, $path, false);
 			return;
 		}
-		FS::open($path, 'r', function ($file) use ($cb, $path, $pri, $outfd, $offset, $length) {
+		FS::open($path, 'r', function($file) use ($cb, $path, $pri, $outfd, $offset, $length) {
 			if (!$file) {
 				call_user_func($cb, $path, false);
 				return;
@@ -238,7 +238,7 @@ 
 			call_user_func($cb, $path, file_get_contents($path));
 			return;
 		}
-		FS::open($path, 'r', function ($file) use ($cb, $pri, $path) {
+		FS::open($path, 'r', function($file) use ($cb, $pri, $path) {
 			if (!$file) {
 				call_user_func($cb, $path, false);
 				return;
@@ -253,7 +253,7 @@ 
 			call_user_func($cb, $r !== false);
 			return;
 		}
-		FS::open($path, 'r', function ($file) use ($cb, $chunkcb, $pri) {
+		FS::open($path, 'r', function($file) use ($cb, $chunkcb, $pri) {
 			if (!$file) {
 				call_user_func($cb, $file->path, false);
 				return;
@@ -283,8 +283,8 @@ 
 				$item = FS::$fdCache->put($fdCacheKey, null);
 				$item->addListener($cb);
 			}
-			return eio_open($path, $flags , $mode,
-			  $pri, function ($arg, $fd) use ($cb, $path, $flags, $fdCacheKey, $noncache) {
+			return eio_open($path, $flags, $mode,
+			  $pri, function($arg, $fd) use ($cb, $path, $flags, $fdCacheKey, $noncache) {
 			  	
 				if (!$fd) {
 					if ($noncache) {

lib/Request.php

Spacing +1 added lines, -3 removed lines

@@ -412,9 +412,7 @@
  
 		if (Daemon::$compatMode) {
 			return;
-		}
- 
-		++Daemon::$process->counterGC;
+		}++Daemon::$process->counterGC;
  
 		if (Daemon::$compatMode) {
 			return;

lib/FileWatcher.php

Spacing +2 added lines, -2 removed lines

@@ -33,7 +33,7 @@ 
 		if (!isset($this->files[$path])) {
 			$this->files[$path] = array();
 			if ($this->inotify) {
-				$this->descriptors[inotify_add_watch($this->inotify, $path,$flags?:IN_MODIFY)] = $path;
+				$this->descriptors[inotify_add_watch($this->inotify, $path, $flags ?: IN_MODIFY)] = $path;
 			}
 		}
 		$this->files[$path][] = $subscriber;
@@ -44,7 +44,7 @@ 
 	
 		$path = realpath($path);
 	
-		if (!isset($this->files[$path])) {return false;}
+		if (!isset($this->files[$path])) {return false; }
 		if (($k = array_search($subscriber, $this->files[$path], true)) !== false) {
 			unset($this->files[$path][$k]);
 		}

lib/MongoClientAsyncCursor.php

Spacing +9 added lines, -9 removed lines

@@ -1,14 +1,14 @@
 <?php
 class MongoClientAsyncCursor {
-	public $id;                 // Cursor's ID.
-	public $col;                // Collection's name.
-	public $items = array();    // Array of objects
-	public $item;               // Current object
-	public $conn;     	        // Network connection
-	public $finished = false;   // Is this cursor finished?
-	public $failure = false;    // Is this query failured?
-	public $await = false;      // awaitCapable?
-	public $destroyed = false;  // Is this cursor destroyed?
+	public $id; // Cursor's ID.
+	public $col; // Collection's name.
+	public $items = array(); // Array of objects
+	public $item; // Current object
+	public $conn; // Network connection
+	public $finished = false; // Is this cursor finished?
+	public $failure = false; // Is this query failured?
+	public $await = false; // awaitCapable?
+	public $destroyed = false; // Is this cursor destroyed?
 
 	/**
 	 * Constructor

lib/PriorityQueueCallbacks.php

Spacing +1 added lines, -1 removed lines

@@ -9,7 +9,7 @@
 	public function dequeue() {
 		return $this->extract();
 	}
-	public function compare($pri1, $pri2)  { 
+	public function compare($pri1, $pri2) { 
 		if ($pri1 === $pri2) {
 			return 0;
 		}

lib/Daemon_ConfigEntryArray.php

Spacing +1 added lines, -1 removed lines

@@ -14,7 +14,7 @@
 		if (is_array($value)) {
 			return $value;
 		}
-		$value = preg_replace_callback('~(".*?")|(\'.*?\')|(\s*,\s*)~s', function ($m) {
+		$value = preg_replace_callback('~(".*?")|(\'.*?\')|(\s*,\s*)~s', function($m) {
 			if (!empty($m[3])) {
 				return "\x00";
 			}