Expected Test Failure Report for ext/mysqli/tests/mysqli_poll_kill.phpt ('int mysqli_poll() and kill')
Script
1:
<?php
2: require_once('connect.inc');
3:
4: function get_connection() {
5: global $host, $user, $passwd, $db, $port, $socket;
6:
7: if (!$link = my_mysqli_connect($host, $user, $passwd, $db, $port, $socket))
8: printf("[001] [%d] %s\n", mysqli_connect_errno(), mysqli_connect_error());
9: return $link;
10: }
11:
12: // Killing connection - 1
13:
14: $link = get_connection();
15: if (true !== ($tmp = mysqli_query($link, "SELECT 1 AS 'processed before killed'", MYSQLI_ASYNC | MYSQLI_USE_RESULT)))
16: printf("[002] Expecting boolean/true got %s/%s\n", gettype($tmp), var_export($tmp, true));
17:
18: // Sleep 0.1s - the asynchronous query should have been processed after the wait period
19: usleep(100000);
20: $thread_id = mysqli_thread_id($link);
21: mysqli_kill(get_connection(), $thread_id);
22:
23: $links = array($link);
24: $errors = array($link);
25: $reject = array($link);
26:
27: // Yes, 1 - the asynchronous query should have been processed
28: if (1 !== ($tmp = (mysqli_poll($links, $errors, $reject, 0, 10000))))
29: printf("[003] Expecting int/1 got %s/%s\n", gettype($tmp), var_export($tmp, true));
30:
31: if (!is_array($links) || empty($links))
32: printf("[004] Expecting non-empty array got %s/%s\n", gettype($links), var_export($links, true));
33: else
34: foreach ($links as $link) {
35: if (is_object($res = mysqli_reap_async_query($link))) {
36: // Yes, you can fetch a result - the query has been processed
37: var_dump(mysqli_fetch_assoc($res));
38: mysqli_free_result($res);
39: } else if ($link->errno > 0) {
40: printf("[005] Error: %d\n", $link->errno);
41: }
42: }
43:
44: // No error!
45: if (!is_array($errors) || !empty($errors))
46: printf("[006] Expecting non-empty array got %s/%s\n", gettype($errors), var_export($errors, true));
47:
48: if (!is_array($reject) || !empty($reject))
49: printf("[007] Expecting empty array got %s/%s\n", gettype($reject), var_export($reject, true));
50:
51: // Lets pass a dead connection
52: $links = array($link);
53: $errors = array($link);
54: $reject = array($link);
55: if (0 !== ($tmp = mysqli_poll($links, $errors, $reject, 1)))
56: printf("[008] There should be no connection ready! Returned %s/%s, expecting int/0.\n",
57: gettype($tmp), var_export($tmp, true));
58:
59: if (!empty($errors))
60: printf("[009] There should be no errors but one rejected connection\n");
61:
62: foreach ($reject as $mysqli)
63: if (mysqli_thread_id($mysqli) != $thread_id) {
64: printf("[010] Rejected thread %d should have rejected thread %d\n",
65: mysqli_thread_id($mysqli), $thread_id);
66: }
67:
68: // Killing connection - 2
69:
70: $link = get_connection();
71: if (true !== ($tmp = mysqli_query($link, "SELECT 1", MYSQLI_ASYNC | MYSQLI_USE_RESULT)))
72: printf("[011] Expecting boolean/true got %s/%s\n", gettype($tmp), var_export($tmp, true));
73:
74: usleep(100000);
75: $thread_id = mysqli_thread_id($link);
76: mysqli_kill(get_connection(), $thread_id);
77:
78: // Yes, 1 - fetch OK packet of kill!
79: $processed = 0;
80: $begin = microtime(true);
81: do {
82: $links = array($link, $link);
83: $errors = array($link, $link);
84: $reject = array($link, $link);
85: $ready = mysqli_poll($links, $errors, $reject, 1);
86:
87: if (!empty($errors)) {
88: foreach ($errors as $mysqli) {
89: printf("[012] Error on thread %d: %s/%s\n",
90: mysqli_thread_id($mysqli),
91: mysqli_errno($mysqli),
92: mysqli_error($mysqli));
93: }
94: break;
95: }
96:
97: if (FALSE === $ready) {
98: printf("[013] MySQLi indicates some error\n");
99: break;
100: }
101:
102: if (!empty($reject)) {
103: foreach ($reject as $mysqli) {
104: printf("[014] Rejecting thread %d: %s/%s\n",
105: mysqli_thread_id($mysqli),
106: mysqli_errno($mysqli),
107: mysqli_error($mysqli));
108: }
109: $processed += count($reject);
110: }
111:
112: foreach ($links as $mysqli) {
113: if (is_object($res = mysqli_reap_async_query($mysqli))) {
114: printf("Fetching from thread %d...\n", mysqli_thread_id($mysqli));
115: var_dump(mysqli_fetch_assoc($res));
116: } else if (mysqli_errno($mysqli) > 0) {
117: printf("[015] %d/%s\n", mysqli_errno($mysqli), mysqli_error($mysqli));
118: }
119: $processed++;
120: }
121:
122: if ((microtime(true) - $begin) > 5) {
123: printf("[016] Pulling the emergency break after 5s, something is wrong...\n");
124: break;
125: }
126:
127: } while ($processed < 2);
128:
129:
130: // Killing connection - 3
131:
132: $link = get_connection();
133: $thread_id = mysqli_thread_id($link);
134: mysqli_kill(get_connection(), $thread_id);
135: // Sleep 0.1s to ensure the KILL gets recognized
136: usleep(100000);
137: if (false !== ($tmp = mysqli_query($link, "SELECT 1 AS 'processed before killed'", MYSQLI_ASYNC | MYSQLI_USE_RESULT)))
138: printf("[017] Expecting boolean/false got %s/%s\n", gettype($tmp), var_export($tmp, true));
139:
140: $links = array($link);
141: $errors = array($link);
142: $reject = array($link);
143:
144: if (0 !== ($tmp = (mysqli_poll($links, $errors, $reject, 0, 10000))))
145: printf("[018] Expecting int/0 got %s/%s\n", gettype($tmp), var_export($tmp, true));
146:
147: if (!is_array($links) || empty($links))
148: printf("[019] Expecting non-empty array got %s/%s\n", gettype($links), var_export($links, true));
149: else
150: foreach ($links as $link) {
151: if (is_object($res = mysqli_reap_async_query($link))) {
152: // No, you cannot fetch the result
153: var_dump(mysqli_fetch_assoc($res));
154: mysqli_free_result($res);
155: } else if ($link->errno > 0) {
156: // But you are supposed to handle the error the way its shown here!
157: printf("[020] Error: %d/%s\n", $link->errno, $link->error);
158: }
159: }
160:
161: // None of these will indicate an error, check errno on the list of returned connections!
162: if (!is_array($errors) || !empty($errors))
163: printf("[021] Expecting non-empty array got %s/%s\n", gettype($errors), var_export($errors, true));
164:
165: if (!is_array($reject) || !empty($reject))
166: printf("[021] Expecting empty array got %s/%s\n", gettype($reject), var_export($reject, true));
167:
168:
169: mysqli_close($link);
170: print "done!";
171: ?>
172:
Expected
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!
Output
array(1) {
["processed before killed"]=>
string(1) "1"
}
Fetching from thread 61159...
array(1) {
[1]=>
string(1) "1"
}
Warning: mysqli_reap_async_query(): Premature end of data (mysqlnd_wireprotocol.c:1079) in /var/php_gcov/PHP_5_6/ext/mysqli/tests/mysqli_poll_kill.php on line 113
Warning: mysqli_reap_async_query(): RSET_HEADER packet 4 bytes shorter than expected in /var/php_gcov/PHP_5_6/ext/mysqli/tests/mysqli_poll_kill.php on line 113
Warning: mysqli_reap_async_query(): Error reading result set's header in /var/php_gcov/PHP_5_6/ext/mysqli/tests/mysqli_poll_kill.php on line 113
Warning: Error while sending QUERY packet. PID=27824 in /var/php_gcov/PHP_5_6/ext/mysqli/tests/mysqli_poll_kill.php on line 137
Warning: mysqli_poll(): All arrays passed are clear in /var/php_gcov/PHP_5_6/ext/mysqli/tests/mysqli_poll_kill.php on line 144
[018] Expecting int/0 got boolean/false
[019] Expecting non-empty array got array/array (
)
[021] Expecting non-empty array got array/array (
0 =>
mysqli::__set_state(array(
'affected_rows' => NULL,
'client_info' => NULL,
'client_version' => NULL,
'connect_errno' => NULL,
'connect_error' => NULL,
'errno' => NULL,
'error' => NULL,
'error_list' => NULL,
'field_count' => NULL,
'host_info' => NULL,
'info' => NULL,
'insert_id' => NULL,
'server_info' => NULL,
'server_version' => NULL,
'stat' => NULL,
'sqlstate' => NULL,
'protocol_version' => NULL,
'thread_id' => NULL,
'warning_count' => NULL,
)),
)
[021] Expecting empty array got array/array (
0 =>
mysqli::__set_state(array(
'affected_rows' => NULL,
'client_info' => NULL,
'client_version' => NULL,
'connect_errno' => NULL,
'connect_error' => NULL,
'errno' => NULL,
'error' => NULL,
'error_list' => NULL,
'field_count' => NULL,
'host_info' => NULL,
'info' => NULL,
'insert_id' => NULL,
'server_info' => NULL,
'server_version' => NULL,
'stat' => NULL,
'sqlstate' => NULL,
'protocol_version' => NULL,
'thread_id' => NULL,
'warning_count' => NULL,
)),
)
done!
Diff
019+ Warning: mysqli_poll(): All arrays passed are clear in /var/php_gcov/PHP_5_6/ext/mysqli/tests/mysqli_poll_kill.php on line 144
020+ [018] Expecting int/0 got boolean/false
021+ [019] Expecting non-empty array got array/array (
022+ )
023+ [021] Expecting non-empty array got array/array (
019- Warning: mysqli_reap_async_query(): %s
020-
021- Warning: mysqli_reap_async_query(): Error reading result set's header in %s on line %d
022- [018] Error: %d/%s
023- done!
024+ 0 =>
025+ mysqli::__set_state(array(
026+ 'affected_rows' => NULL,
027+ 'client_info' => NULL,
028+ 'client_version' => NULL,
029+ 'connect_errno' => NULL,
030+ 'connect_error' => NULL,
031+ 'errno' => NULL,
032+ 'error' => NULL,
033+ 'error_list' => NULL,
034+ 'field_count' => NULL,
035+ 'host_info' => NULL,
036+ 'info' => NULL,
037+ 'insert_id' => NULL,
038+ 'server_info' => NULL,
039+ 'server_version' => NULL,
040+ 'stat' => NULL,
041+ 'sqlstate' => NULL,
042+ 'protocol_version' => NULL,
043+ 'thread_id' => NULL,
044+ 'warning_count' => NULL,
045+ )),
046+ )
047+ [021] Expecting empty array got array/array (
048+ 0 =>
049+ mysqli::__set_state(array(
050+ 'affected_rows' => NULL,
051+ 'client_info' => NULL,
052+ 'client_version' => NULL,
053+ 'connect_errno' => NULL,
054+ 'connect_error' => NULL,
055+ 'errno' => NULL,
056+ 'error' => NULL,
057+ 'error_list' => NULL,
058+ 'field_count' => NULL,
059+ 'host_info' => NULL,
060+ 'info' => NULL,
061+ 'insert_id' => NULL,
062+ 'server_info' => NULL,
063+ 'server_version' => NULL,
064+ 'stat' => NULL,
065+ 'sqlstate' => NULL,
066+ 'protocol_version' => NULL,
067+ 'thread_id' => NULL,
068+ 'warning_count' => NULL,
069+ )),
070+ )
071+ done!
Generated at Sat, 24 Jan 2015 14:29:14 +0000 (5 days ago)
|
