Annotation of embedaddon/php/ext/mysqli/tests/mysqli_poll_kill.phpt, revision 1.1.1.1
1.1 misho 1: --TEST--
2: int mysqli_poll() and kill
3: --SKIPIF--
4: <?php
5: require_once('skipif.inc');
6: require_once('skipifemb.inc');
7: require_once('connect.inc');
8: require_once('skipifconnectfailure.inc');
9:
10: if (!$IS_MYSQLND)
11: die("skip mysqlnd only feature, compile PHP using --with-mysqli=mysqlnd");
12: ?>
13: --FILE--
14: <?php
15: require_once('connect.inc');
16:
17: function get_connection() {
18: global $host, $user, $passwd, $db, $port, $socket;
19:
20: if (!$link = my_mysqli_connect($host, $user, $passwd, $db, $port, $socket))
21: printf("[001] [%d] %s\n", mysqli_connect_errno(), mysqli_connect_error());
22: return $link;
23: }
24:
25: // Killing connection - 1
26:
27: $link = get_connection();
28: if (true !== ($tmp = mysqli_query($link, "SELECT 1 AS 'processed before killed'", MYSQLI_ASYNC | MYSQLI_USE_RESULT)))
29: printf("[002] Expecting boolean/true got %s/%s\n", gettype($tmp), var_export($tmp, true));
30:
31: // Sleep 0.1s - the asynchronous query should have been processed after the wait period
32: usleep(100000);
33: $thread_id = mysqli_thread_id($link);
34: mysqli_kill(get_connection(), $thread_id);
35:
36: $links = array($link);
37: $errors = array($link);
38: $reject = array($link);
39:
40: // Yes, 1 - the asynchronous query should have been processed
41: if (1 !== ($tmp = (mysqli_poll($links, $errors, $reject, 0, 10000))))
42: printf("[003] Expecting int/1 got %s/%s\n", gettype($tmp), var_export($tmp, true));
43:
44: if (!is_array($links) || empty($links))
45: printf("[004] Expecting non-empty array got %s/%s\n", gettype($links), var_export($links, true));
46: else
47: foreach ($links as $link) {
48: if (is_object($res = mysqli_reap_async_query($link))) {
49: // Yes, you can fetch a result - the query has been processed
50: var_dump(mysqli_fetch_assoc($res));
51: mysqli_free_result($res);
52: } else if ($link->errno > 0) {
53: printf("[005] Error: %d\n", $link->errno);
54: }
55: }
56:
57: // No error!
58: if (!is_array($errors) || !empty($errors))
59: printf("[006] Expecting non-empty array got %s/%s\n", gettype($errors), var_export($errors, true));
60:
61: if (!is_array($reject) || !empty($reject))
62: printf("[007] Expecting empty array got %s/%s\n", gettype($reject), var_export($reject, true));
63:
64: // Lets pass a dead connection
65: $links = array($link);
66: $errors = array($link);
67: $reject = array($link);
68: if (0 !== ($tmp = mysqli_poll($links, $errors, $reject, 1)))
69: printf("[008] There should be no connection ready! Returned %s/%s, expecting int/0.\n",
70: gettype($tmp), var_export($tmp, true));
71:
72: if (!empty($errors))
73: printf("[009] There should be no errors but one rejected connection\n");
74:
75: foreach ($reject as $mysqli)
76: if (mysqli_thread_id($mysqli) != $thread_id) {
77: printf("[010] Rejected thread %d should have rejected thread %d\n",
78: mysqli_thread_id($mysqli), $thread_id);
79: }
80:
81: // Killing connection - 2
82:
83: $link = get_connection();
84: if (true !== ($tmp = mysqli_query($link, "SELECT 1", MYSQLI_ASYNC | MYSQLI_USE_RESULT)))
85: printf("[011] Expecting boolean/true got %s/%s\n", gettype($tmp), var_export($tmp, true));
86:
87: usleep(100000);
88: $thread_id = mysqli_thread_id($link);
89: mysqli_kill(get_connection(), $thread_id);
90:
91: // Yes, 1 - fetch OK packet of kill!
92: $processed = 0;
93: do {
94: $links = array($link, $link);
95: $errors = array($link, $link);
96: $reject = array($link, $link);
97: $ready = mysqli_poll($links, $errors, $reject, 1);
98:
99: if (!empty($errors)) {
100: foreach ($errors as $mysqli) {
101: printf("[012] Error on thread %d: %s/%s\n",
102: mysqli_thread_id($mysqli),
103: mysqli_errno($mysqli),
104: mysqli_error($mysqli));
105: }
106: break;
107: }
108:
109: if (!empty($reject)) {
110: foreach ($reject as $mysqli) {
111: printf("[013] Rejecting thread %d: %s/%s\n",
112: mysqli_thread_id($mysqli),
113: mysqli_errno($mysqli),
114: mysqli_error($mysqli));
115: }
116: $processed += count($reject);
117: }
118:
119: foreach ($links as $mysqli) {
120: if (is_object($res = mysqli_reap_async_query($mysqli))) {
121: printf("Fetching from thread %d...\n", mysqli_thread_id($mysqli));
122: var_dump(mysqli_fetch_assoc($res));
123: } else if (mysqli_errno($mysqli) > 0) {
124: printf("[014] %d/%s\n", mysqli_errno($mysqli), mysqli_error($mysqli));
125: }
126: $processed++;
127: }
128:
129: } while ($processed < 2);
130:
131:
132: // Killing connection - 3
133:
134: $link = get_connection();
135: $thread_id = mysqli_thread_id($link);
136: mysqli_kill(get_connection(), $thread_id);
137: // Sleep 0.1s to ensure the KILL gets recognized
138: usleep(100000);
139: if (false !== ($tmp = mysqli_query($link, "SELECT 1 AS 'processed before killed'", MYSQLI_ASYNC | MYSQLI_USE_RESULT)))
140: printf("[015] Expecting boolean/false got %s/%s\n", gettype($tmp), var_export($tmp, true));
141:
142: $links = array($link);
143: $errors = array($link);
144: $reject = array($link);
145:
146: if (0 !== ($tmp = (mysqli_poll($links, $errors, $reject, 0, 10000))))
147: printf("[016] Expecting int/0 got %s/%s\n", gettype($tmp), var_export($tmp, true));
148:
149: if (!is_array($links) || empty($links))
150: printf("[017] Expecting non-empty array got %s/%s\n", gettype($links), var_export($links, true));
151: else
152: foreach ($links as $link) {
153: if (is_object($res = mysqli_reap_async_query($link))) {
154: // No, you cannot fetch the result
155: var_dump(mysqli_fetch_assoc($res));
156: mysqli_free_result($res);
157: } else if ($link->errno > 0) {
158: // But you are supposed to handle the error the way its shown here!
159: printf("[018] Error: %d/%s\n", $link->errno, $link->error);
160: }
161: }
162:
163: // None of these will indicate an error, check errno on the list of returned connections!
164: if (!is_array($errors) || !empty($errors))
165: printf("[019] Expecting non-empty array got %s/%s\n", gettype($errors), var_export($errors, true));
166:
167: if (!is_array($reject) || !empty($reject))
168: printf("[020] Expecting empty array got %s/%s\n", gettype($reject), var_export($reject, true));
169:
170:
171: mysqli_close($link);
172: print "done!";
173: ?>
174: --XFAIL--
175: To be fixed later. Minor issue about fetching error message from killed line
176: --EXPECTF--
177: array(1) {
178: [%u|b%"processed before killed"]=>
179: %unicode|string%(1) "1"
180: }
181: Fetching from thread %d...
182: array(1) {
183: [1]=>
184: %unicode|string%(1) "1"
185: }
186:
187: Warning: mysqli_reap_async_query(): Premature end of data (mysqlnd_wireprotocol.c:%d) in %s on line %d
188:
189: Warning: mysqli_reap_async_query(): RSET_HEADER %s
190:
191: Warning: mysqli_reap_async_query(): Error reading result set's header in %s on line %d
192:
193: Warning: Error while sending QUERY packet. %s
194:
195: Warning: mysqli_reap_async_query(): %s
196:
197: Warning: mysqli_reap_async_query(): Error reading result set's header in %s on line %d
198: [018] Error: %d/%s
199: done!
FreeBSD-CVSweb <freebsd-cvsweb@FreeBSD.org>
![[BACK]](/icons/cvsweb/back.gif){kind=icon}
Return to mysqli_poll_kill.phpt CVS log ![[TXT]](/icons/cvsweb/text.gif){kind=icon}
![[DIR]](/icons/cvsweb/dir.gif){kind=icon}
Up to [ELWIX - Embedded LightWeight unIX -] / embedaddon / php / ext / mysqli / tests