wrote exec thingie, but it doesn't work

diff --git a/misc.php b/misc.php
index e604e61..35ed78d 100644 (file)
--- a/misc.php
+++ b/misc.php
@@ -18,6 +18,93 @@
 #  along with wfpl; if not, write to the Free Software Foundation, Inc., 51
 #  Franklin Street, Fifth Floor, Boston, MA  02110-1301  USA
 
+# returns an array containing just the elements of $pipes that are readable (without blocking)
+# timeout 0 means don't wait, timeout NULL means wait indefinitely
+function readable_sockets($pipes, $timeout = 0){
+       $read = array_values($pipes);
+       $ret = stream_select($read, $write = NULL, $exceptions = NULL, $timeout);
+       if($ret === false) {
+               return false;
+       }
+       if($ret) {
+               return $read;
+       } else {
+               return array();
+       }
+}
+
+
+# Parameters:
+#     command
+#     stdin
+# Returns: (as array)
+#     exit code
+#     stdout
+#     stderr
+function exec_pipe($command, $stdin) {
+       $descriptorspec = 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 pipe that the child will write to
+       );
+
+       $process = proc_open($command, $descriptorspec, $pipes);
+
+       if (is_resource($process)) {
+               fwrite($pipes[0], $stdin);
+               fclose($pipes[0]);
+
+               $stdout_open = true;
+               $stderr_open = true;
+               while($stdout_open || $stderr_open) {
+                       $pipes_to_check = array();
+                       if($stdout_open) {
+                               $pipes_to_check[] = $pipes[1];
+                       }
+                       if($stderr_open) {
+                               $pipes_to_check[] = $pipes[2];
+                       }
+                       $readables = readable_sockets($pipes_to_check);
+                       if($readables === false) {
+                               die('select failed');
+                       }
+                       foreach($readables as $pipe) {
+                               $ret = fread($pipe, 4096);
+                               if($ret === false) {
+                                       die('fread (in exec_pipe) failed');
+                               }
+                               if($pipe = $pipes[1]) {
+                                       if($ret == '') {
+                                               fclose($pipes[1]);
+                                               $stdout_open = false;
+                                       } else {
+                                               $stdout .= $ret;
+                                       }
+                               }
+                               if($pipe = $pipes[2]) {
+                                       if($ret == '') {
+                                               fclose($pipes[2]);
+                                               $stderr_open = false;
+                                       } else {
+                                               $stderr .= $ret;
+                                       }
+                               }
+                       }
+               }
+
+               // It is important that you close any pipes before calling
+               // proc_close in order to avoid a deadlock
+               $return_value = proc_close($process);
+
+               return array($return_value, $stdout, $stderr);
+       }
+}
+
+
+
+
+
+
 function unix_newlines($str) {
        $str = str_replace("\r\n", "\n", $str);
        return str_replace("\r", "\n", $str);