mirror of
https://github.com/php/php-src.git
synced 2024-09-22 18:37:25 +00:00
252 lines
8.5 KiB
PHP
252 lines
8.5 KiB
PHP
--TEST--
|
|
Forking a child and using the same connection.
|
|
--SKIPIF--
|
|
<?php
|
|
require_once('skipif.inc');
|
|
require_once('skipifemb.inc');
|
|
require_once('skipifconnectfailure.inc');
|
|
|
|
if (!function_exists('pcntl_fork'))
|
|
die("skip Process Control Functions not available");
|
|
|
|
if (!function_exists('posix_getpid'))
|
|
die("skip POSIX functions not available");
|
|
|
|
require_once('connect.inc');
|
|
if (!$link = my_mysqli_connect($host, $user, $passwd, $db, $port, $socket))
|
|
die(sprintf("Cannot connect, [%d] %s", mysqli_connect_errno(), mysqli_connect_error()));
|
|
|
|
if (!have_innodb($link))
|
|
die(sprintf("Needs InnoDB support, [%d] %s", $link->errno, $link->error));
|
|
?>
|
|
--FILE--
|
|
<?php
|
|
require_once("table.inc");
|
|
|
|
$res = mysqli_query($link, "SELECT 'dumped by the parent' AS message");
|
|
$pid = pcntl_fork();
|
|
switch ($pid) {
|
|
case -1:
|
|
printf("[001] Cannot fork child");
|
|
break;
|
|
|
|
case 0:
|
|
/* child */
|
|
exit(0);
|
|
break;
|
|
|
|
default:
|
|
/* parent */
|
|
$status = null;
|
|
$wait_id = pcntl_waitpid($pid, $status);
|
|
if (pcntl_wifexited($status) && (0 != ($tmp = pcntl_wexitstatus($status)))) {
|
|
printf("Exit code: %s\n", (pcntl_wifexited($status)) ? pcntl_wexitstatus($status) : 'n/a');
|
|
printf("Signal: %s\n", (pcntl_wifsignaled($status)) ? pcntl_wtermsig($status) : 'n/a');
|
|
printf("Stopped: %d\n", (pcntl_wifstopped($status)) ? pcntl_wstopsig($status) : 'n/a');
|
|
}
|
|
var_dump(mysqli_fetch_assoc($res));
|
|
mysqli_free_result($res);
|
|
break;
|
|
}
|
|
|
|
if (@mysqli_query($link, "SELECT id FROM test WHERE id = 1"))
|
|
printf("[003] Expecting error and closed connection, child exit should have closed connection\n");
|
|
else if ((($errno = mysqli_errno($link)) == 0) || ('' == ($error = mysqli_error($link))))
|
|
printf("[004] Expecting error string and error code from MySQL, got errno = %s/%s, error = %s/%s\n",
|
|
gettype($errno), $errno, gettype($error), $error);
|
|
|
|
mysqli_close($link);
|
|
if (!$link = my_mysqli_connect($host, $user, $passwd, $db, $port, $socket))
|
|
printf("[005] Cannot connect to the server using host=%s, user=%s, passwd=***, dbname=%s, port=%s, socket=%s\n",
|
|
$host, $user, $db, $port, $socket);
|
|
|
|
/* non trivial tests require a message list for parent-child communication */
|
|
if (!mysqli_query($link, "DROP TABLE IF EXISTS messages"))
|
|
printf("[006] [%d] %s\n", mysqli_error($link), mysqli_errno($link));
|
|
|
|
if (!mysqli_query($link, "CREATE TABLE messages(
|
|
msg_id INT NOT NULL AUTO_INCREMENT PRIMARY KEY,
|
|
msg_time TIMESTAMP,
|
|
pid INT NOT NULL,
|
|
sender ENUM('child', 'parent') NOT NULL,
|
|
msg TEXT) ENGINE = InnoDB"))
|
|
printf("[007] [%d] %s\n", mysqli_error($link), mysqli_errno($link));
|
|
|
|
mysqli_autocommit($link, false);
|
|
if (!$res = mysqli_query($link, "SELECT id, label FROM test ORDER BY id ASC LIMIT 3", MYSQLI_USE_RESULT))
|
|
printf("[008] [%d] %s\n", mysqli_error($link), mysqli_errno($link));
|
|
|
|
$pid = pcntl_fork();
|
|
|
|
switch ($pid) {
|
|
case -1:
|
|
printf("[009] Cannot fork child");
|
|
break;
|
|
|
|
case 0:
|
|
/* child */
|
|
if (!($plink = my_mysqli_connect($host, $user, $passwd, $db, $port, $socket)) || !mysqli_autocommit($plink, true))
|
|
exit(mysqli_errno($plink));
|
|
|
|
$sql = sprintf("INSERT INTO messages(pid, sender, msg) VALUES (%d, 'child', '%%s')", posix_getpid());
|
|
if (!mysqli_query($plink, sprintf($sql, 'start')))
|
|
exit(mysqli_errno($plink));
|
|
|
|
$parent_sql = sprintf("SELECT msg_id, msg_time, msg FROM messages WHERE pid = %d AND sender = 'parent' ORDER BY msg_id DESC LIMIT 1", posix_getppid());
|
|
$msg_id = 0;
|
|
while ($row = mysqli_fetch_assoc($res)) {
|
|
/* send row to parent */
|
|
ob_start();
|
|
var_dump($row);
|
|
$tmp = ob_get_contents();
|
|
ob_end_clean();
|
|
if (!mysqli_query($plink, sprintf($sql, $tmp)))
|
|
exit(mysqli_errno($plink));
|
|
|
|
/* let the parent reply... */
|
|
$start = time();
|
|
do {
|
|
usleep(100);
|
|
if (!$pres = mysqli_query($plink, $parent_sql))
|
|
continue;
|
|
$tmp = mysqli_fetch_assoc($pres);
|
|
mysqli_free_result($pres);
|
|
if ($tmp['msg_id'] == $msg_id)
|
|
/* no new message */
|
|
continue;
|
|
if ($tmp['msg'] == 'stop')
|
|
break 2;
|
|
$msg_id = $tmp['msg_id'];
|
|
break;
|
|
} while ((time() - $start) < 5);
|
|
|
|
}
|
|
|
|
if (!mysqli_query($plink, sprintf($sql, 'stop')) || !mysqli_commit($link))
|
|
exit(mysqli_errno($plink));
|
|
exit(0);
|
|
break;
|
|
|
|
default:
|
|
/* parent */
|
|
if (!$plink = my_mysqli_connect($host, $user, $passwd, $db, $port, $socket))
|
|
printf("[010] Cannot connect to the server using host=%s, user=%s, passwd=***, dbname=%s, port=%s, socket=%s\n",
|
|
$host, $user, $db, $port, $socket);
|
|
|
|
$status = null;
|
|
$start = time();
|
|
$sql = sprintf("SELECT msg_id, msg_time, msg FROM messages WHERE pid = %d AND sender = 'child' ORDER BY msg_id DESC LIMIT 1", $pid);
|
|
$parent_sql = sprintf("INSERT INTO messages (pid, sender, msg) VALUES (%d, 'parent', '%%s')", posix_getpid());
|
|
$last_msg_id = 0;
|
|
$num_rows = 0;
|
|
do {
|
|
$wait_id = pcntl_waitpid($pid, $status, WNOHANG);
|
|
if ($pres = mysqli_query($plink, $sql)) {
|
|
$row = mysqli_fetch_assoc($pres);
|
|
if ($row['msg_id'] != $last_msg_id) {
|
|
$last_msg_id = $row['msg_id'];
|
|
switch ($row['msg']) {
|
|
case 'start':
|
|
break;
|
|
case 'stop':
|
|
break 2;
|
|
default:
|
|
/* client has started fetching rows */
|
|
$client_row = $row['msg'];
|
|
|
|
$num_rows++;
|
|
if ($num_rows > 3) {
|
|
printf("[011] Child has fetched more than three rows!\n");
|
|
var_dump($client_row);
|
|
if (!mysqli_query($plink, sprintf($parent_sql, 'stop'))) {
|
|
printf("[012] Parent cannot inform child\n", mysqli_errno($plink), mysqli_error($plink));
|
|
}
|
|
break 2;
|
|
}
|
|
|
|
if (!$parent_row = mysqli_fetch_assoc($res)) {
|
|
printf("[013] Parent cannot fetch row %d\n", $num_rows, mysqli_errno($link), mysqli_error($link));
|
|
if (!mysqli_query($plink, sprintf($parent_sql, 'stop'))) {
|
|
printf("[014] Parent cannot inform child\n", mysqli_errno($plink), mysqli_error($plink));
|
|
}
|
|
break 2;
|
|
}
|
|
|
|
ob_start();
|
|
var_dump($parent_row);
|
|
$parent_row = ob_get_contents();
|
|
ob_end_clean();
|
|
|
|
if ($parent_row != $client_row) {
|
|
printf("[015] Child indicates different results than parent.\n");
|
|
var_dump($child_row);
|
|
var_dump($parent_row);
|
|
if (!mysqli_query($plink, sprintf($parent_sql, 'stop'))) {
|
|
printf("[016] Parent cannot inform child\n", mysqli_errno($plink), mysqli_error($plink));
|
|
}
|
|
break 2;
|
|
}
|
|
|
|
if (!mysqli_query($plink, sprintf($parent_sql, 'continue'))) {
|
|
printf("[017] Parent cannot inform child to continue.\n", mysqli_errno($plink), mysqli_error($plink));
|
|
}
|
|
break;
|
|
}
|
|
}
|
|
mysqli_free_result($pres);
|
|
}
|
|
usleep(100);
|
|
} while (((time() - $start) < 5) && ($num_rows < 3));
|
|
mysqli_close($plink);
|
|
$wait_id = pcntl_waitpid($pid, $status);
|
|
if (pcntl_wifexited($status) && (0 != ($tmp = pcntl_wexitstatus($status)))) {
|
|
printf("Exit code: %s\n", (pcntl_wifexited($status)) ? pcntl_wexitstatus($status) : 'n/a');
|
|
printf("Signal: %s\n", (pcntl_wifsignaled($status)) ? pcntl_wtermsig($status) : 'n/a');
|
|
printf("Stopped: %d\n", (pcntl_wifstopped($status)) ? pcntl_wstopsig($status) : 'n/a');
|
|
}
|
|
break;
|
|
}
|
|
mysqli_free_result($res);
|
|
mysqli_close($link);
|
|
|
|
if (!$link = my_mysqli_connect($host, $user, $passwd, $db, $port, $socket))
|
|
printf("[018] Cannot connect to the server using host=%s, user=%s, passwd=***, dbname=%s, port=%s, socket=%s\n",
|
|
$host, $user, $db, $port, $socket);
|
|
|
|
if (!$res = mysqli_query($link, "SELECT sender, msg FROM messages ORDER BY msg_id ASC"))
|
|
printf("[019] [%d] %s\n", mysqli_errno($link), mysqli_error($link));
|
|
|
|
while ($row = mysqli_fetch_assoc($res))
|
|
printf("%10s %s\n", $row['sender'], substr($row['msg'], 0, 5));
|
|
mysqli_free_result($res);
|
|
|
|
print "done!";
|
|
?>
|
|
--CLEAN--
|
|
<?php
|
|
require_once("connect.inc");
|
|
if (!$link = my_mysqli_connect($host, $user, $passwd, $db, $port, $socket))
|
|
printf("[c001] [%d] %s\n", mysqli_connect_errno(), mysqli_connect_error());
|
|
|
|
if (!mysqli_query($link, "DROP TABLE IF EXISTS test"))
|
|
printf("[c002] Cannot drop table, [%d] %s\n", mysqli_errno($link), mysqli_error($link));
|
|
|
|
if (!mysqli_query($link, "DROP TABLE IF EXISTS messages"))
|
|
printf("[c003] Cannot drop table, [%d] %s\n", mysqli_errno($link), mysqli_error($link));
|
|
|
|
mysqli_close($link);
|
|
?>
|
|
--EXPECTF--
|
|
array(1) {
|
|
["message"]=>
|
|
string(20) "dumped by the parent"
|
|
}
|
|
child start
|
|
child array
|
|
parent conti
|
|
child array
|
|
parent conti
|
|
child array
|
|
parent conti
|
|
child stop
|
|
done!
|