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
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
|
--TEST--
int mysqli_poll() and kill
--SKIPIF--
<?php
require_once('skipif.inc');
require_once('skipifemb.inc');
require_once('connect.inc');
require_once('skipifconnectfailure.inc');
if (!$IS_MYSQLND)
die("skip mysqlnd only feature, compile PHP using --with-mysqli=mysqlnd");
?>
--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;
}
// Killing connection - 1
$link = get_connection();
if (true !== ($tmp = mysqli_query($link, "SELECT 1 AS 'processed before killed'", MYSQLI_ASYNC | MYSQLI_USE_RESULT)))
printf("[002] Expecting boolean/true got %s/%s\n", gettype($tmp), var_export($tmp, true));
// Sleep 0.1s - the asynchronous query should have been processed after the wait period
usleep(100000);
$thread_id = mysqli_thread_id($link);
mysqli_kill(get_connection(), $thread_id);
$links = array($link);
$errors = array($link);
$reject = array($link);
// Yes, 1 - the asynchronous query should have been processed
if (1 !== ($tmp = (mysqli_poll($links, $errors, $reject, 0, 10000))))
printf("[003] Expecting int/1 got %s/%s\n", gettype($tmp), var_export($tmp, true));
if (!is_array($links) || empty($links))
printf("[004] Expecting non-empty array got %s/%s\n", gettype($links), var_export($links, true));
else
foreach ($links as $link) {
if (is_object($res = mysqli_reap_async_query($link))) {
// Yes, you can fetch a result - the query has been processed
var_dump(mysqli_fetch_assoc($res));
mysqli_free_result($res);
} else if ($link->errno > 0) {
printf("[005] Error: %d\n", $link->errno);
}
}
// No error!
if (!is_array($errors) || !empty($errors))
printf("[006] Expecting non-empty array got %s/%s\n", gettype($errors), var_export($errors, true));
if (!is_array($reject) || !empty($reject))
printf("[007] Expecting empty array got %s/%s\n", gettype($reject), var_export($reject, true));
// Lets pass a dead connection
$links = array($link);
$errors = array($link);
$reject = array($link);
if (0 !== ($tmp = mysqli_poll($links, $errors, $reject, 1)))
printf("[008] There should be no connection ready! Returned %s/%s, expecting int/0.\n",
gettype($tmp), var_export($tmp, true));
if (!empty($errors))
printf("[009] There should be no errors but one rejected connection\n");
foreach ($reject as $mysqli)
if (mysqli_thread_id($mysqli) != $thread_id) {
printf("[010] Rejected thread %d should have rejected thread %d\n",
mysqli_thread_id($mysqli), $thread_id);
}
// Killing connection - 2
$link = get_connection();
if (true !== ($tmp = mysqli_query($link, "SELECT 1", MYSQLI_ASYNC | MYSQLI_USE_RESULT)))
printf("[011] Expecting boolean/true got %s/%s\n", gettype($tmp), var_export($tmp, true));
usleep(100000);
$thread_id = mysqli_thread_id($link);
mysqli_kill(get_connection(), $thread_id);
// Yes, 1 - fetch OK packet of kill!
$processed = 0;
$begin = microtime(true);
do {
$links = array($link, $link);
$errors = array($link, $link);
$reject = array($link, $link);
$ready = mysqli_poll($links, $errors, $reject, 1);
if (!empty($errors)) {
foreach ($errors as $mysqli) {
printf("[012] Error on thread %d: %s/%s\n",
mysqli_thread_id($mysqli),
mysqli_errno($mysqli),
mysqli_error($mysqli));
}
break;
}
if (FALSE === $ready) {
printf("[013] MySQLi indicates some error\n");
break;
}
if (!empty($reject)) {
foreach ($reject as $mysqli) {
printf("[014] Rejecting thread %d: %s/%s\n",
mysqli_thread_id($mysqli),
mysqli_errno($mysqli),
mysqli_error($mysqli));
}
$processed += count($reject);
}
foreach ($links as $mysqli) {
if (is_object($res = mysqli_reap_async_query($mysqli))) {
printf("Fetching from thread %d...\n", mysqli_thread_id($mysqli));
var_dump(mysqli_fetch_assoc($res));
} else if (mysqli_errno($mysqli) > 0) {
printf("[015] %d/%s\n", mysqli_errno($mysqli), mysqli_error($mysqli));
}
$processed++;
}
if ((microtime(true) - $begin) > 5) {
printf("[016] Pulling the emergency break after 5s, something is wrong...\n");
break;
}
} while ($processed < 2);
// Killing connection - 3
$link = get_connection();
$thread_id = mysqli_thread_id($link);
mysqli_kill(get_connection(), $thread_id);
// Sleep 0.1s to ensure the KILL gets recognized
usleep(100000);
if (false !== ($tmp = mysqli_query($link, "SELECT 1 AS 'processed before killed'", MYSQLI_ASYNC | MYSQLI_USE_RESULT)))
printf("[017] Expecting boolean/false got %s/%s\n", gettype($tmp), var_export($tmp, true));
$links = array($link);
$errors = array($link);
$reject = array($link);
if (0 !== ($tmp = (mysqli_poll($links, $errors, $reject, 0, 10000))))
printf("[018] Expecting int/0 got %s/%s\n", gettype($tmp), var_export($tmp, true));
if (!is_array($links) || empty($links))
printf("[019] Expecting non-empty array got %s/%s\n", gettype($links), var_export($links, true));
else
foreach ($links as $link) {
if (is_object($res = mysqli_reap_async_query($link))) {
// No, you cannot fetch the result
var_dump(mysqli_fetch_assoc($res));
mysqli_free_result($res);
} else if ($link->errno > 0) {
// But you are supposed to handle the error the way its shown here!
printf("[020] Error: %d/%s\n", $link->errno, $link->error);
}
}
// None of these will indicate an error, check errno on the list of returned connections!
if (!is_array($errors) || !empty($errors))
printf("[021] Expecting non-empty array got %s/%s\n", gettype($errors), var_export($errors, true));
if (!is_array($reject) || !empty($reject))
printf("[021] Expecting empty array got %s/%s\n", gettype($reject), var_export($reject, true));
mysqli_close($link);
print "done!";
?>
--XFAIL--
To be fixed later. Minor issue about fetching error message from killed line
--EXPECTF--
array(1) {
[%u|b%"processed before killed"]=>
%unicode|string%(1) "1"
}
Fetching from thread %d...
array(1) {
[1]=>
%unicode|string%(1) "1"
}
Warning: mysqli_reap_async_query(): Premature end of data (mysqlnd_wireprotocol.c:%d) in %s on line %d
Warning: mysqli_reap_async_query(): RSET_HEADER %s
Warning: mysqli_reap_async_query(): Error reading result set's header in %s on line %d
Warning: Error while sending QUERY packet. %s
Warning: mysqli_reap_async_query(): %s
Warning: mysqli_reap_async_query(): Error reading result set's header in %s on line %d
[018] Error: %d/%s
done!
|
