proc_open print stderr

[sakismat]

please help
how can I get stderr from processes ($proc[$i]) in my screen
without waiting the other processes to end

#!/usr/bin/php
<?php
 
$con = mysql_connect("localhost", "user");
if (!$con)
{
die('Could not connect: ' . mysql_error());
}
mysql_select_db("database");
 
$stores = mysql_num_rows(mysql_query ("select * from stores"));
 
$query1 = mysql_query ("select sid, sip, sport, sname from stores");
 
$reads = array();
$storess = array();
while ( $store = mysql_fetch_assoc($query1))
{
$storess[$store['sid']] = $store;
 
$ip = $store['sip'];
$port = $store['sport '];
 
$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
);
 
$proc[$i] = proc_open('mysqldump -u user -pPASS -h '.$ip.' -P '.
$port.' ... file.sql', $descriptorspec, $pipes);
 
//get stderr
$reads[$store['sid']] = $pipes[2];
 
}//end while
 
echo "Dumping ...". "\n";
 
 
/*
echo "ALL STDERR"
*/
 
 
 
 
echo "--OK--". "\n";
?>
 

I tried this:

while ( stream_select($select_reads, $null, $null, 0) !== false )
{
 
 
echo "stream is \n";
var_dump($select_reads);
foreach ($select_reads as $read) {
$sid = array_search($read, $reads);
 
echo $storess[$sid]['sname'] . " SAID:\n";
var_dump(fread($read, 1024));
}
 
// stream_select modifies the contents of $select_reads
// in a loop we should replace it with the original
$select_reads = $reads;
sleep(1);
}//end while
 

[Erwin Moller]

sa******@gmail.com schreef:

please help
how can I get stderr from processes ($proc[$i]) in my screen
without waiting the other processes to end

Hi,

I cannot help you with your STDERR, but I spotted something that could
potentially slow down your script a lot.

[code]
#!/usr/bin/php
<?php

$con = mysql_connect("localhost", "user");
if (!$con)
{
die('Could not connect: ' . mysql_error());
}
mysql_select_db("database");

$stores = mysql_num_rows(mysql_query ("select * from stores"));

Just a small suggestion:
The above line is a waste of CPU cycles (and bandwidth is mySQL is on
another fysical server).
You actually ask mysql to return the full content of the table stores,
only to find out how many there are.
This won't matter a lot when table stores is small, but it is a bad
approach, I think.
MySQL must:
1) Find out what * translates to (all your columnnames).
2) Send the full content of that table to PHP.

Much better is to use the SQL build-in command COUNT() for this:
$SQL = "SELECT COUNT(*) AS numrowsstore FROM stores;";
or
$SQL = "SELECT COUNT(storeid) AS numrowsstore FROM stores;";
(assuming storeid exists)

Just a suggestion. :-)

I hope somebody else can help you with the STDERR.

Regards,
Erwin Moller

[Captain Paralytic]

On 8 May, 12:06, Erwin Moller
<Since_humans_read_this_I_am_spammed_too_m...@spam yourself.comwrote:

[e-mail] schreef:

please help
how can I get stderr from processes ($proc[$i]) in my screen
without waiting the other processes to end

Hi,

I cannot help you with your STDERR, but I spotted something that could
potentially slow down your script a lot.

[code]
#!/usr/bin/php
<?php

$con = mysql_connect("localhost", "user");
if (!$con)
{
die('Could not connect: ' . mysql_error());
}
mysql_select_db("database");

$stores = mysql_num_rows(mysql_query ("select * from stores"));

Just a small suggestion:
The above line is a waste of CPU cycles (and bandwidth is mySQL is on
another fysical server).
You actually ask mysql to return the full content of the table stores,
only to find out how many there are.
This won't matter a lot when table stores is small, but it is a bad
approach, I think.
MySQL must:
1) Find out what * translates to (all your columnnames).
2) Send the full content of that table to PHP.

Much better is to use the SQL build-in command COUNT() for this:
$SQL = "SELECT COUNT(*) AS numrowsstore FROM stores;";
or
$SQL = "SELECT COUNT(storeid) AS numrowsstore FROM stores;";
(assuming storeid exists)

Just a suggestion. :-)

I hope somebody else can help you with the STDERR.

Regards,
Erwin Moller

What is more to the point, is that the value $stores is never used
again.

[Erwin Moller]

Captain Paralytic schreef:

On 8 May, 12:06, Erwin Moller
<Since_humans_read_this_I_am_spammed_too_m...@spam yourself.comwrote:

>[e-mail] schreef:

>>please help
how can I get stderr from processes ($proc[$i]) in my screen
without waiting the other processes to end

Hi,

I cannot help you with your STDERR, but I spotted something that could
potentially slow down your script a lot.

>>[code]
#!/usr/bin/php
<?php
$con = mysql_connect("localhost", "user");
if (!$con)
{
die('Could not connect: ' . mysql_error());
}
mysql_select_db("database");
$stores = mysql_num_rows(mysql_query ("select * from stores"));

Just a small suggestion:
The above line is a waste of CPU cycles (and bandwidth is mySQL is on
another fysical server).
You actually ask mysql to return the full content of the table stores,
only to find out how many there are.
This won't matter a lot when table stores is small, but it is a bad
approach, I think.
MySQL must:
1) Find out what * translates to (all your columnnames).
2) Send the full content of that table to PHP.

Much better is to use the SQL build-in command COUNT() for this:
$SQL = "SELECT COUNT(*) AS numrowsstore FROM stores;";
or
$SQL = "SELECT COUNT(storeid) AS numrowsstore FROM stores;";
(assuming storeid exists)

Just a suggestion. :-)

I hope somebody else can help you with the STDERR.

Regards,
Erwin Moller

What is more to the point, is that the value $stores is never used
again.

LOL, yes. Good point.
That makes it an even better waste of CPU. ;-)

Regards,
Erwin Moller

[Jerry Stuckle]

sa******@gmail.com wrote:

please help
how can I get stderr from processes ($proc[$i]) in my screen
without waiting the other processes to end

#!/usr/bin/php
<?php

    $con = mysql_connect("localhost", "user");
    if (!$con)
      {
         die('Could not connect: ' . mysql_error());
     }
     mysql_select_db("database");

     $stores = mysql_num_rows(mysql_query ("select * from stores"));

    $query1 = mysql_query ("select sid, sip, sport, sname from stores");

    $reads = array();
    $storess = array();
    while ( $store = mysql_fetch_assoc($query1))
    {
        $storess[$store['sid']] = $store;

        $ip = $store['sip'];
        $port = $store['sport '];

        $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
        );

        $proc[$i] = proc_open('mysqldump -u user -pPASS -h '.$ip.' -P '.
$port.' ... file.sql', $descriptorspec, $pipes);

                //get stderr
        $reads[$store['sid']] = $pipes[2];

    }//end while

    echo "Dumping ...". "\n";


    /*
        echo "ALL STDERR"
        */




    echo "--OK--". "\n";
?>
 

I tried this:

while ( stream_select($select_reads, $null, $null, 0) !== false )
    {


        echo "stream is \n";
        var_dump($select_reads);
        foreach ($select_reads as $read) {
            $sid = array_search($read, $reads);

            echo $storess[$sid]['sname'] . " SAID:\n";
            var_dump(fread($read, 1024));
        }

        // stream_select modifies the contents of $select_reads
                // in a loop we should replace it with the original
           $select_reads = $reads;
           sleep(1);
    }//end while
 

You read from your stderr pipe. In this case you could use:

echo stream_get_contents($descriptorspec[2]);

But you have an error in your proc_open call. You cannot use the
redirection symbols '<' or '>' (or the pipe symbol '|'). These are
handled by the command processor, which does not get executed when you
call proc_open.

--
==================
Remove the "x" from my email address
Jerry Stuckle
JDS Computer Training Corp.
js*******@attglobal.net
==================

[sakismat]

On May 8, 2:07 pm, [e-mail] wrote:

please help
how can I get stderr from processes ($proc[$i]) in my screen
without waiting the other processes to end

#!/usr/bin/php
<?php

        $con = mysql_connect("localhost", "user");
        if (!$con)
        {
                die('Could not connect: ' . mysql_error());
        }
        mysql_select_db("database");

        $stores = mysql_num_rows(mysql_query ("select * from stores"));

        $query1 = mysql_query ("select sid, sip, sport, sname from stores");

        $reads = array();
        $storess = array();
        while ( $store = mysql_fetch_assoc($query1))
        {
                $storess[$store['sid']] = $store;

                $ip = $store['sip'];
                $port = $store['sport '];

                $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
                );

                $proc[$i] = proc_open('mysqldump -u user -pPASS -h '.$ip.' -P '.
$port.' ... file.sql', $descriptorspec, $pipes);

                //get stderr
                $reads[$store['sid']] = $pipes[2];

        }//end while

        echo "Dumping ...". "\n";

        /*
        echo "ALL STDERR"
        */

        echo "--OK--". "\n";
?>
 

I tried this:

while ( stream_select($select_reads, $null, $null, 0) !== false )
        {

                echo "stream is \n";
                var_dump($select_reads);
                foreach ($select_reads as $read) {
                        $sid = array_search($read, $reads);

                        echo $storess[$sid]['sname'] . " SAID:\n";
                        var_dump(fread($read, 1024));
                }

                // stream_select modifies the contents of $select_reads
                // in a loop we should replace it with the original
                $select_reads = $reads;
                sleep(1);
        }//end while
 

there is an other solution:
sending stderr to file

$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("file", "/tmp/error-output.txt",
"a") // stderr is a file to write to
);
 

but the problem is: who to add to the file the "sname" to know from
which store came the stderr ?
thank you