Unnamed

/**here is classes to run pipe :*/$pipe = new Pipe();# or $pipe = new PipeIO();$cmd='ps';$args = array();$result = $pipe->run($cmd, $args, $stdin='');if($result == false)	echo "error : " . $pipe->get_error();else	echo "result = $result\n";// an other example : will execute a php script and return the result.$pipe = new Pipe();$cmd='php.exe';$args = array('-q');$script = '<?php phpinfo(); ?>';$result = $pipe->run($cmd, $args, $script);if($result == false)	echo "error : " . $pipe->get_error();else	echo "result = $result\n";class PipeIO{	protected $descriptor_spec;	protected $cmd;	protected $args;	protected $pipes;	protected $stdin_data;	protected $stdout_data;	protected $stderr_data;	protected $terminated;	public function __construct(){		$this->descriptor_spec = array(			0 => array("pipe", "r"),  // stdin is a pipe that the child will read from			1 => array("pipe", "w"),  // stdout is a pipe that the child will write to			2 => array("pipe", "w")   // stderr is a file to write to		);		$this->proc_id = null;	}	public function __destruct(){		$this->terminate();	}	public function terminate(){				if($this->proc_id != null){			proc_close($this->proc_id);			$this->proc_id = null;		}	}	public function run($cmd, $args, $stdin_data=null){		$this->cmd = $cmd;		$this->args = $args;		$this->stdin_data = $stdin_data;		$this->stderr_data = '';		$this->stdout_data = '';		$this->terminated = false;		$this->pipes = null;		$cmd = $this->cmd . ' ' . join(' ', $this->args);		$this->proc_id = proc_open($cmd, $this->descriptor_spec, $this->pipes);		# if (is_resource($this->proc_id)) {		if ($this->proc_id !== false) {			echo "running pipe\n";			$ids[0] = Gtk::io_add_watch($this->pipes[1],Gtk::IO_HUP, array($this, 'io_hup'));			$ids[1] = Gtk::io_add_watch($this->pipes[1],Gtk::IO_IN,  array($this, 'stdout'));			# $ids[2] = Gtk::io_add_watch($this->pipes[2],Gtk::IO_IN,  array($this, 'stderr'));			if($this->stdin_data != null){				fwrite($this->pipes[0], $this->stdin_data);				fflush($this->pipes[0]);			}			fclose($this->pipes[0]);			# will terminate when io_hup() is called.			Gtk::main();			fclose($this->pipes[1]);			fclose($this->pipes[2]);			$this->terminate();			return $this->stdout_data;		} else{			trigger_error("PipeIO::run() : proc_open error");			return false;		}	}		function io_hup($pipe){		$this->terminated = true;		# this pipe exec is done ;		Gtk::main_quit();		return false;	}		function stdout($pipe){		while($data =  fgets($pipe)){			# echo $data;			$this->stdout_data .= $data;		}		if(feof($pipe)){			return false;		}		return $this->terminated;	}		function stderr($pipe){		while($data=  fgets($pipe)){			echo $data;			$this->stderr_data .= $data;		}		if(feof($pipe)){			return false;		}		return $this->terminated;	}}