pradosoft / prado

framework/Util/TSignalsDispatcher.php

Spacing +13 added lines, -13 removed lines

@@ -94,17 +94,17 @@ 
 		SIGALRM => self::FX_SIGNAL_ALARM, // Alarm signal.  Sent by pcntl_alarm when the time is over.
 		SIGHUP => self::FX_SIGNAL_HANG_UP, // Hangup signal. Sent to a process when its controlling terminal is closed.
 		SIGINT => self::FX_SIGNAL_INTERRUPT, // Interrupt signal. Typically generated by pressing Ctrl+C.
-		SIGQUIT => self::FX_SIGNAL_QUIT,  // Quit signal. Similar to SIGINT but produces a core dump when received by the process.
-		SIGTRAP => self::FX_SIGNAL_TRAP,  // Trace/breakpoint trap signal. Used by debuggers to catch trace and breakpoint conditions.
+		SIGQUIT => self::FX_SIGNAL_QUIT, // Quit signal. Similar to SIGINT but produces a core dump when received by the process.
+		SIGTRAP => self::FX_SIGNAL_TRAP, // Trace/breakpoint trap signal. Used by debuggers to catch trace and breakpoint conditions.
 		SIGABRT => self::FX_SIGNAL_ABORT, // Abort signal. Sent by the process itself to terminate due to a critical error condition.
 		SIGUSR1 => self::FX_SIGNAL_USER1, // User-defined signal 1.
 		SIGUSR2 => self::FX_SIGNAL_USER2, // User-defined signal 2.
 		SIGTERM => self::FX_SIGNAL_TERMINATE, // Termination signal. Typically used to request graceful termination of a process.
 		SIGCHLD => self::FX_SIGNAL_CHILD, // Child signal. Sent to a parent process when a child process terminates.
-		SIGCONT => self::FX_SIGNAL_CONTINUE,  // Continue signal. Sent to resume a process that has been stopped.
+		SIGCONT => self::FX_SIGNAL_CONTINUE, // Continue signal. Sent to resume a process that has been stopped.
 		SIGTSTP => self::FX_SIGNAL_TERMINAL_STOP, // Terminal stop signal. Sent by pressing Ctrl+Z to suspend the process.
-		SIGTTIN => self::FX_SIGNAL_BACKGROUND_READ,    // Background read signal. Sent to a process when it attempts to read from the terminal while in the background.
-		SIGTTOU => self::FX_SIGNAL_BACKGROUND_WRITE,   // Background write signal. Sent to a process when it attempts to write to the terminal while in the background.
+		SIGTTIN => self::FX_SIGNAL_BACKGROUND_READ, // Background read signal. Sent to a process when it attempts to read from the terminal while in the background.
+		SIGTTOU => self::FX_SIGNAL_BACKGROUND_WRITE, // Background write signal. Sent to a process when it attempts to write to the terminal while in the background.
 		SIGURG => self::FX_SIGNAL_URGENT, // Urgent condition signal. Indicates the arrival of out-of-band data on a socket.
 	];
 
@@ -223,7 +223,7 @@ 
 			static::setAsyncSignals(true);
 		}
 
-		foreach(static::SIGNAL_MAP as $signal => $event) {
+		foreach (static::SIGNAL_MAP as $signal => $event) {
 			$handler = pcntl_signal_get_handler($signal);
 
 			if ($handler instanceof self) {
@@ -233,7 +233,7 @@ 
 
 			$callable = is_callable($handler);
 			if ($callable) {
-				$handler = function ($sender, $param) use ($handler) {
+				$handler = function($sender, $param) use ($handler) {
 					return $handler($param->getSignal(), $param->getParameter());
 				};
 				self::$_priorHandlers[$signal][1] = $handler;
@@ -277,7 +277,7 @@ 
 			return false;
 		}
 
-		foreach(self::$_priorHandlers as $signal => $originalCallback) {
+		foreach (self::$_priorHandlers as $signal => $originalCallback) {
 			pcntl_signal($signal, $originalCallback[0]);
 			$uninstallHandler = true;
 			switch ($signal) {
@@ -325,7 +325,7 @@ 
 	{
 		if (isset(static::SIGNAL_MAP[$name])) {
 			$name = static::SIGNAL_MAP[$name];
-		} elseif(strncasecmp('pid:', $name, 4) === 0) {
+		} elseif (strncasecmp('pid:', $name, 4) === 0) {
 			if (is_numeric($pid = trim(substr($name, 4)))) {
 				return TProcessHelper::isRunning((int) $pid);
 			}
@@ -347,7 +347,7 @@ 
 	{
 		if (isset(static::SIGNAL_MAP[$name])) {
 			$name = static::SIGNAL_MAP[$name];
-		} elseif(strncasecmp('pid:', $name, 4) === 0) {
+		} elseif (strncasecmp('pid:', $name, 4) === 0) {
 			if (is_numeric($pid = trim(substr($name, 4)))) {
 				$pid = (int) $pid;
 				return isset(self::$_pidHandlers[$pid]) && self::$_pidHandlers[$pid]->getCount() > 0;
@@ -370,7 +370,7 @@ 
 	{
 		if (isset(static::SIGNAL_MAP[$name])) {
 			$name = static::SIGNAL_MAP[$name];
-		} elseif(strncasecmp('pid:', $name, 4) === 0) {
+		} elseif (strncasecmp('pid:', $name, 4) === 0) {
 			if (!is_numeric($pid = trim(substr($name, 4)))) {
 				throw new TInvalidOperationException('signalsdispatcher_bad_pid', $pid);
 			}
@@ -620,7 +620,7 @@ 
 			$callback = self::$_priorHandlers[SIGALRM][1];
 		}
 
-		foreach($alarmTime !== null ? [$alarmTime] : array_keys(static::$_alarms) as $time) {
+		foreach ($alarmTime !== null ? [$alarmTime] : array_keys(static::$_alarms) as $time) {
 			if (($key = array_search($callback, static::$_alarms[$time] ?? [], true)) !== false) {
 				unset(static::$_alarms[$time][$key]);
 				if (is_array(static::$_alarms[$time] ?? false)) {
@@ -661,7 +661,7 @@ 
 			$nextTime = null;
 			$startTime = time();
 			$signalParam->setAlarmTime($startTime);
-			foreach(static::$_alarms as $alarmTime => $alarms) {
+			foreach (static::$_alarms as $alarmTime => $alarms) {
 				if ($alarmTime <= $startTime) {
 					array_map(fn ($alarm) => $alarm($this, $signalParam), static::$_alarms[$alarmTime]);
 					unset(static::$_alarms[$alarmTime]);

framework/Util/Helpers/TProcessHelper.php

Spacing +4 added lines, -4 removed lines

@@ -161,7 +161,7 @@ 
 
 		if (TProcessHelper::isSystemWindows()) {
 			if (is_string($command)) {
-				$command = '"' . $command . '"';  //Windows, better command support
+				$command = '"' . $command . '"'; //Windows, better command support
 			}
 		}
 		return $command;
@@ -231,7 +231,7 @@ 
 			$output = shell_exec("wmic process where ProcessId={$pid} get priority");
 			preg_match('/^\s*Priority\s*\r?\n\s*(\d+)/m', $output, $matches);
 			if (isset($matches[1])) {
-				$priorityValues = [ // Map Windows Priority Numbers to Linux style Numbers
+				$priorityValues = [// Map Windows Priority Numbers to Linux style Numbers
 					TProcessWindowsPriority::Idle => static::WINDOWS_IDLE_PRIORITY,
 					TProcessWindowsPriority::BelowNormal => static::WINDOWS_BELOW_NORMAL_PRIORITY,
 					TProcessWindowsPriority::Normal => static::WINDOWS_NORMAL_PRIORITY,
@@ -263,7 +263,7 @@ 
 			$pid = getmypid();
 		}
 		if (static::isSystemWindows()) {
-			$priorityValues = [ // The priority cap to windows text priority.
+			$priorityValues = [// The priority cap to windows text priority.
 				-15 => TProcessWindowsPriorityName::Realtime,
 				-10 => TProcessWindowsPriorityName::HighPriority,
 				-5 => TProcessWindowsPriorityName::AboveNormal,
@@ -271,7 +271,7 @@ 
 				9 => TProcessWindowsPriorityName::BelowNormal,
 				PHP_INT_MAX => TProcessWindowsPriorityName::Idle,
 			];
-			foreach($priorityValues as $keyPriority => $priorityName) {
+			foreach ($priorityValues as $keyPriority => $priorityName) {
 				if ($priority <= $keyPriority) {
 					break;
 				}

framework/Util/Behaviors/TCaptureForkLog.php

Spacing +8 added lines, -8 removed lines

@@ -145,7 +145,7 @@ 
 			$logger->deleteLogs();
 			$logs = $logger->deleteProfileLogs();
 			$pid = getmypid();
-			foreach(array_keys($logs) as $key) { // Reset PROFILE_BEGIN to pid.
+			foreach (array_keys($logs) as $key) { // Reset PROFILE_BEGIN to pid.
 				$logs[$key][TLogger::LOG_LEVEL] &= ~TLogger::LOGGED;
 				$logs[$key][TLogger::LOG_PID] = $pid;
 			}
@@ -176,7 +176,7 @@ 
 		if (!$this->_parentConnections) {
 			return;
 		}
-		if($pid && !isset($this->_parentConnections[$pid])) {
+		if ($pid && !isset($this->_parentConnections[$pid])) {
 			return;
 		}
 
@@ -187,11 +187,11 @@ 
 		do {
 			$read = $connections;
 			if (stream_select($read, $write, $except, ($wait || count($childLogs)) ? 1 : 0, 0)) {
-				foreach($read as $pid => $socket) {
+				foreach ($read as $pid => $socket) {
 					$data = fread($socket, 8192);
 					do {
 						$iterate = false;
-						if($data !== false) {
+						if ($data !== false) {
 							if (array_key_exists($pid, $childLogs)) {
 								$childLogs[$pid][0] .= $data;
 							} else {
@@ -234,12 +234,12 @@ 
 					} while ($iterate);
 				}
 			}
-		} while(count($childLogs) || $wait && ($pid && isset($connections[$pid]) || $pid === null && $connections));
+		} while (count($childLogs) || $wait && ($pid && isset($connections[$pid]) || $pid === null && $connections));
 
 		if (!$completeLogs) {
 			return;
 		}
-		foreach(array_merge(...$completeLogs) as $pid => $logs) {
+		foreach (array_merge(...$completeLogs) as $pid => $logs) {
 			Prado::getLogger()->mergeLogs(unserialize($logs));
 		}
 	}
@@ -257,7 +257,7 @@ 
 			return;
 		}
 
-		if(!($logger instanceof TLogger)) {
+		if (!($logger instanceof TLogger)) {
 			$logger = Prado::getLogger();
 		}
 
@@ -294,7 +294,7 @@ 
 					$data = substr($data, $count);
 				}
 			}
-		} while($count !== false && strlen($data) > 0);
+		} while ($count !== false && strlen($data) > 0);
 
 		if ($final) {
 			stream_socket_shutdown($this->_childConnection, STREAM_SHUT_RDWR);