1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
|
--TEST--
int mysqli_poll() simple
--EXTENSIONS--
mysqli
--SKIPIF--
<?php
require_once 'skipifconnectfailure.inc';
?>
--FILE--
<?php
require_once 'connect.inc';
function get_connection() {
global $host, $user, $passwd, $db, $port, $socket;
if (!$link = my_mysqli_connect($host, $user, $passwd, $db, $port, $socket))
printf("[001] [%d] %s\n", mysqli_connect_errno(), mysqli_connect_error());
return $link;
}
if (!$link = get_connection())
printf("[001] [%d] %s\n", mysqli_connect_errno(), mysqli_connect_error());
$read = $error = $reject = array($link);
if (0 !== ($tmp = (mysqli_poll($read, $error, $reject, 0, 1))))
printf("[009] Expecting int/0 got %s/%s\n", gettype($tmp), var_export($tmp, true));
$read = $error = $reject = array($link);
try {
mysqli_poll($read, $error, $reject, -1, 1);
} catch (\ValueError $e) {
echo $e->getMessage() . \PHP_EOL;
}
try {
mysqli_poll($read, $error, $reject, 0, -1);
} catch (\ValueError $e) {
echo $e->getMessage() . \PHP_EOL;
}
$link->close();
$read[0] = get_connection();
try {
mysqli_poll($read, $error, $reject, 0, 1);
} catch (\Error $e) {
echo $e->getMessage() . \PHP_EOL;
}
function poll_async($offset, $link, $links, $errors, $reject, $exp_ready, $use_oo_syntax) {
if ($exp_ready !== ($tmp = mysqli_poll($links, $errors, $reject, 0, 1000)))
printf("[%03d + 1] There should be %d links ready to read from, %d ready\n",
$exp_ready, $tmp);
foreach ($links as $mysqli) {
if ($use_oo_syntax) {
$res = $mysqli->reap_async_query();
} else {
$res = mysqli_reap_async_query($mysqli);
}
if (is_object($res)) {
printf("[%03d + 2] Can fetch resultset although no query has been run!\n", $offset);
} else if (mysqli_errno($mysqli) > 0) {
printf("[%03d + 3] Error indicated through links array: %d/%s",
$offset, mysqli_errno($mysqli), mysqli_error($mysqli));
} else {
printf("[%03d + 4] Cannot fetch and no error set - non resultset query (no SELECT)!\n", $offset);
}
}
foreach ($errors as $mysqli)
printf("[%03d + 5] Error on %d: %d/%s\n",
$offset, mysqli_thread_id($mysqli), mysqli_errno($mysqli), mysqli_error($mysqli));
foreach ($reject as $mysqli)
printf("[%03d + 6] Rejecting thread %d: %d/%s\n",
$offset, mysqli_thread_id($mysqli), mysqli_errno($mysqli), mysqli_error($mysqli));
}
// Connections on which no query has been sent - 1
$link = get_connection();
$links = array($link);
$errors = array($link);
$reject = array($link);
poll_async(12, $link, $links, $errors, $reject, 0, false);
mysqli_close($link);
$link = get_connection();
$links = array($link);
$errors = array($link);
$reject = array($link);
poll_async(13, $link, $links, $errors, $reject, 0, true);
mysqli_close($link);
// Connections on which no query has been sent - 2
// Difference: pass $links twice
$link = get_connection();
$links = array($link, $link);
$errors = array($link, $link);
$reject = array();
poll_async(14, $link, $links, $errors, $reject, 0, false);
// Connections on which no query has been sent - 3
// Difference: pass two connections
$link = get_connection();
$links = array($link, get_connection());
$errors = array($link, $link);
$reject = array();
poll_async(15, $link, $links, $errors, $reject, 0, false);
// Reference mess...
$link = get_connection();
$links = array($link);
$errors = array($link);
$ref_errors =& $errors;
$reject = array();
poll_async(16, $link, $links, $ref_errors, $reject, 0, false);
print "done!";
?>
--EXPECTF--
mysqli_poll(): Argument #4 ($seconds) must be greater than or equal to 0
mysqli_poll(): Argument #5 ($microseconds) must be greater than or equal to 0
mysqli object is already closed
[012 + 6] Rejecting thread %d: 0/
[013 + 6] Rejecting thread %d: 0/
[014 + 6] Rejecting thread %d: 0/
[014 + 6] Rejecting thread %d: 0/
[015 + 6] Rejecting thread %d: 0/
[015 + 6] Rejecting thread %d: 0/
[016 + 6] Rejecting thread %d: 0/
done!
|
