Merge pull request #3 from /pull/2

Pull/2
PhpGt · Mar 19, 2019 · 6c055f5 · 6c055f5
2 parents ad65791 + e8c2067
commit 6c055f5
Show file tree

Hide file tree

Showing 2 changed files with 199 additions and 261 deletions.
diff --git a/src/Pool.php b/src/Pool.php
@@ -1,109 +1,109 @@
-<?php
-namespace Gt\Daemon;
-
-use \Exception;
-
-class Pool {
-	protected $processList;
-
-	public function __construct() {
-		$this->processList = [];
-	}
-
-	public function add(string $name, Process $process) {
-		$this->processList[$name] = $process;
-	}
-
-	/** Starts the execution of all proccesses */
-	public function exec() {
-		foreach($this->processList as $name=>$process ){
-			$process->run();
-		}
-	}
-
-    	public function numRunning():int {
-		$num = 0 ;
-		foreach($this->processList as $name=>$process){
-			$num += ($process->isAlive() ? 1 : 0);
-		}
-
-		return $num;
-	}
-
-	/** Returns ouptput for all the proccesses in the $processList */
-	public function read():string {
-		$output = "" ;
-
-		foreach($this->processList as $name=>$process){
-			$out = $process->getOutput();
-
-			if(!empty($out)){
-				$output .= "OUTPUT for [$name] : " . PHP_EOL . $out . PHP_EOL .PHP_EOL;
-			}
-		}
-
-		return $output ;
-	}
-
-	/** Returns errors for all the proccesses in the $processList */
-	public function readError():string {
-		$output = "" ;
-
-		foreach($this->processList as $name=>$process){
-			$out = $process->getErrorOutput();
-
-			if(!empty($out)){
-				$output .= "ERROR for [$name] : " . PHP_EOL . $out . PHP_EOL .PHP_EOL;
-			}
-		}
-
-		return $output ;
-	}
-
-	public function readErrorOf(string $processName):string {
-		if(!array_key_exists($processName, $this->processList)
-		|| !is_resource($this->processList[$processName])) {
-			throw new \Exception("No process named $processName found .");
-		}
-
-		return $this->processList[$processName]->getErrorOuput();
-	}
-
-	public function readOutputOf(string $processName):string {
-		if(!array_key_exists($processName, $this->processList)
-		|| !is_resource($this->processList[$processName])) {
-			throw new \Exception("No process named $processName found .");
-		}
-
-		return $this->processList[$processName]->getErrorOuput();
-	}
-
-	/** Executes only the proccess having $processName as a name */
-	public function executeOne(string $processName) {
-		if(!array_key_exists( $processName ,$this->processList)
-		|| !is_resource($this->processList[$processName])) {
-			throw new \Exception("No process named $processName found .");
-		}
-
-		$this->processList[$processName]->run();
-	}
-
-	/**
-	* Stops all the processes and returns an array mapping each proccess name with it's return code
-	* This method should only be called if you want to stop the execution of all the processes
-	*
-	* example :
-	*      $return_codes = $pool->closeAll() ;
-	*      echo $return_codes['process1'] ; //assuming that the pool contained a process having 'process1' for name
-	*      //this will return the return code of 'process1'
-	*/
-	public function closeAll():array {
-		$codes = [] ;
-
-		foreach($this->processList as $name=>$process){
-			$codes[$name] = $process->close();
-		}
-
-		return $codes;
-	}
-}
+<?php
+namespace Gt\Daemon;
+
+use \Exception;
+
+class Pool {
+	protected $processList;
+
+	public function __construct() {
+		$this->processList = [];
+	}
+
+	public function add(string $name, Process $process) {
+		$this->processList[$name] = $process;
+	}
+
+	/** Starts the execution of all proccesses */
+	public function exec() {
+		foreach($this->processList as $name=>$process ){
+			$process->run();
+		}
+	}
+
+    	public function numRunning():int {
+		$num = 0 ;
+		foreach($this->processList as $name=>$process){
+			$num += ($process->isAlive() ? 1 : 0);
+		}
+
+		return $num;
+	}
+
+	/** Returns ouptput for all the proccesses in the $processList */
+	public function read():string {
+		$output = "" ;
+
+		foreach($this->processList as $name=>$process){
+			$out = $process->getOutput();
+
+			if(!empty($out)){
+				$output .= "OUTPUT for [$name] : " . PHP_EOL . $out . PHP_EOL .PHP_EOL;
+			}
+		}
+
+		return $output ;
+	}
+
+	/** Returns errors for all the proccesses in the $processList */
+	public function readError():string {
+		$output = "" ;
+
+		foreach($this->processList as $name=>$process){
+			$out = $process->getErrorOutput();
+
+			if(!empty($out)){
+				$output .= "ERROR for [$name] : " . PHP_EOL . $out . PHP_EOL .PHP_EOL;
+			}
+		}
+
+		return $output ;
+	}
+
+	public function readErrorOf(string $processName):string {
+		if(!array_key_exists($processName, $this->processList)
+		|| !is_resource($this->processList[$processName])) {
+			throw new \Exception("No process named $processName found .");
+		}
+
+		return $this->processList[$processName]->getErrorOuput();
+	}
+
+	public function readOutputOf(string $processName):string {
+		if(!array_key_exists($processName, $this->processList)
+		|| !is_resource($this->processList[$processName])) {
+			throw new Exception("No process named $processName found .");
+		}
+
+		return $this->processList[$processName]->getErrorOuput();
+	}
+
+	/** Executes only the proccess having $processName as a name */
+	public function executeOne(string $processName) {
+		if(!array_key_exists( $processName ,$this->processList)
+		|| !is_resource($this->processList[$processName])) {
+			throw new Exception("No process named $processName found .");
+		}
+
+		$this->processList[$processName]->run();
+	}
+
+	/**
+	* Stops all the processes and returns an array mapping each proccess name with it's return code
+	* This method should only be called if you want to stop the execution of all the processes
+	*
+	* example :
+	*      $return_codes = $pool->closeAll() ;
+	*      echo $return_codes['process1'] ; //assuming that the pool contained a process having 'process1' for name
+	*      //this will return the return code of 'process1'
+	*/
+	public function closeAll():array {
+		$codes = [] ;
+
+		foreach($this->processList as $name=>$process){
+			$codes[$name] = $process->close();
+		}
+
+		return $codes;
+	}
+}