![[BACK]](/icons/cvsweb/back.gif){kind=icon}
Return to mysqli_fork.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|
Return to mysqli_fork.phpt CVS log | Up to [ELWIX - Embedded LightWeight unIX -] / embedaddon / php / ext / mysqli / tests |
1.1 misho 1: --TEST--
2: Forking a child and using the same connection.
3: --SKIPIF--
4: <?php
5: require_once('skipif.inc');
6: require_once('skipifemb.inc');
7: require_once('skipifconnectfailure.inc');
8:
9: if (!function_exists('pcntl_fork'))
10: die("skip Process Control Functions not available");
11:
12: if (!function_exists('posix_getpid'))
13: die("skip POSIX functions not available");
14:
15: require_once('connect.inc');
16: if (!$link = my_mysqli_connect($host, $user, $passwd, $db, $port, $socket))
17: die(sprintf("Cannot connect, [%d] %s", mysqli_connect_errno(), mysqli_connect_error()));
18:
19: if (!have_innodb($link))
20: die(sprintf("Needs InnoDB support, [%d] %s", $link->errno, $link->error));
21: ?>
22: --FILE--
23: <?php
24: require_once("table.inc");
25:
26: $res = mysqli_query($link, "SELECT 'dumped by the parent' AS message");
27: $pid = pcntl_fork();
28: switch ($pid) {
29: case -1:
30: printf("[001] Cannot fork child");
31: break;
32:
33: case 0:
34: /* child */
35: exit(0);
36: break;
37:
38: default:
39: /* parent */
40: $status = null;
41: $wait_id = pcntl_waitpid($pid, $status);
42: if (pcntl_wifexited($status) && (0 != ($tmp = pcntl_wexitstatus($status)))) {
43: printf("Exit code: %s\n", (pcntl_wifexited($status)) ? pcntl_wexitstatus($status) : 'n/a');
44: printf("Signal: %s\n", (pcntl_wifsignaled($status)) ? pcntl_wtermsig($status) : 'n/a');
45: printf("Stopped: %d\n", (pcntl_wifstopped($status)) ? pcntl_wstopsig($status) : 'n/a');
46: }
47: var_dump(mysqli_fetch_assoc($res));
48: mysqli_free_result($res);
49: break;
50: }
51:
52: if (@mysqli_query($link, "SELECT id FROM test WHERE id = 1"))
53: printf("[003] Expecting error and closed connection, child exit should have closed connection\n");
54: else if ((($errno = mysqli_errno($link)) == 0) || ('' == ($error = mysqli_error($link))))
55: printf("[004] Expecting error string and error code from MySQL, got errno = %s/%s, error = %s/%s\n",
56: gettype($errno), $errno, gettype($error), $error);
57:
58: mysqli_close($link);
59: if (!$link = my_mysqli_connect($host, $user, $passwd, $db, $port, $socket))
60: printf("[005] Cannot connect to the server using host=%s, user=%s, passwd=***, dbname=%s, port=%s, socket=%s\n",
61: $host, $user, $db, $port, $socket);
62:
63: /* non trivial tests require a message list for parent-child communication */
64: if (!mysqli_query($link, "DROP TABLE IF EXISTS messages"))
65: printf("[006] [%d] %s\n", mysqli_error($link), mysqli_errno($link));
66:
67: if (!mysqli_query($link, "CREATE TABLE messages(
68: msg_id INT NOT NULL AUTO_INCREMENT PRIMARY KEY,
69: msg_time TIMESTAMP,
70: pid INT NOT NULL,
71: sender ENUM('child', 'parent') NOT NULL,
72: msg TEXT) ENGINE = InnoDB"))
73: printf("[007] [%d] %s\n", mysqli_error($link), mysqli_errno($link));
74:
75: mysqli_autocommit($link, false);
76: if (!$res = mysqli_query($link, "SELECT id, label FROM test ORDER BY id ASC LIMIT 3", MYSQLI_USE_RESULT))
77: printf("[008] [%d] %s\n", mysqli_error($link), mysqli_errno($link));
78:
79: $pid = pcntl_fork();
80:
81: switch ($pid) {
82: case -1:
83: printf("[009] Cannot fork child");
84: break;
85:
86: case 0:
87: /* child */
88: if (!($plink = my_mysqli_connect($host, $user, $passwd, $db, $port, $socket)) || !mysqli_autocommit($plink, true))
89: exit(mysqli_errno($plink));
90:
91: $sql = sprintf("INSERT INTO messages(pid, sender, msg) VALUES (%d, 'child', '%%s')", posix_getpid());
92: if (!mysqli_query($plink, sprintf($sql, 'start')))
93: exit(mysqli_errno($plink));
94:
95: $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());
96: $msg_id = 0;
97: while ($row = mysqli_fetch_assoc($res)) {
98: /* send row to parent */
99: ob_start();
100: var_dump($row);
101: $tmp = ob_get_contents();
102: ob_end_clean();
103: if (!mysqli_query($plink, sprintf($sql, $tmp)))
104: exit(mysqli_errno($plink));
105:
106: /* let the parent reply... */
107: $start = time();
108: do {
109: usleep(100);
110: if (!$pres = mysqli_query($plink, $parent_sql))
111: continue;
112: $tmp = mysqli_fetch_assoc($pres);
113: mysqli_free_result($pres);
114: if ($tmp['msg_id'] == $msg_id)
115: /* no new message */
116: continue;
117: if ($tmp['msg'] == 'stop')
118: break 2;
119: $msg_id = $tmp['msg_id'];
120: break;
121: } while ((time() - $start) < 5);
122:
123: }
124:
125: if (!mysqli_query($plink, sprintf($sql, 'stop')) || !mysqli_commit($link))
126: exit(mysqli_errno($plink));
127: exit(0);
128: break;
129:
130: default:
131: /* parent */
132: if (!$plink = my_mysqli_connect($host, $user, $passwd, $db, $port, $socket))
133: printf("[010] Cannot connect to the server using host=%s, user=%s, passwd=***, dbname=%s, port=%s, socket=%s\n",
134: $host, $user, $db, $port, $socket);
135:
136: $status = null;
137: $start = time();
138: $sql = sprintf("SELECT msg_id, msg_time, msg FROM messages WHERE pid = %d AND sender = 'child' ORDER BY msg_id DESC LIMIT 1", $pid);
139: $parent_sql = sprintf("INSERT INTO messages (pid, sender, msg) VALUES (%d, 'parent', '%%s')", posix_getpid());
140: $last_msg_id = 0;
141: $num_rows = 0;
142: do {
143: $wait_id = pcntl_waitpid($pid, $status, WNOHANG);
144: if ($pres = mysqli_query($plink, $sql)) {
145: $row = mysqli_fetch_assoc($pres);
146: if ($row['msg_id'] != $last_msg_id) {
147: $last_msg_id = $row['msg_id'];
148: switch ($row['msg']) {
149: case 'start':
150: break;
151: case 'stop':
152: break 2;
153: default:
154: /* client has started fetching rows */
155: $client_row = $row['msg'];
156:
157: $num_rows++;
158: if ($num_rows > 3) {
159: printf("[011] Child has fetched more than three rows!\n");
160: var_dump($client_row);
161: if (!mysqli_query($plink, sprintf($parent_sql, 'stop'))) {
162: printf("[012] Parent cannot inform child\n", mysqli_errno($plink), mysqli_error($plink));
163: }
164: break 2;
165: }
166:
167: if (!$parent_row = mysqli_fetch_assoc($res)) {
168: printf("[013] Parent cannot fetch row %d\n", $num_rows, mysqli_errno($link), mysqli_error($link));
169: if (!mysqli_query($plink, sprintf($parent_sql, 'stop'))) {
170: printf("[014] Parent cannot inform child\n", mysqli_errno($plink), mysqli_error($plink));
171: }
172: break 2;
173: }
174:
175: ob_start();
176: var_dump($parent_row);
177: $parent_row = ob_get_contents();
178: ob_end_clean();
179:
180: if ($parent_row != $client_row) {
181: printf("[015] Child indicates different results than parent.\n");
182: var_dump($child_row);
183: var_dump($parent_row);
184: if (!mysqli_query($plink, sprintf($parent_sql, 'stop'))) {
185: printf("[016] Parent cannot inform child\n", mysqli_errno($plink), mysqli_error($plink));
186: }
187: break 2;
188: }
189:
190: if (!mysqli_query($plink, sprintf($parent_sql, 'continue'))) {
191: printf("[017] Parent cannot inform child to continue.\n", mysqli_errno($plink), mysqli_error($plink));
192: }
193: break;
194: }
195: }
196: mysqli_free_result($pres);
197: }
198: usleep(100);
199: } while (((time() - $start) < 5) && ($num_rows < 3));
200: mysqli_close($plink);
201: $wait_id = pcntl_waitpid($pid, $status);
202: if (pcntl_wifexited($status) && (0 != ($tmp = pcntl_wexitstatus($status)))) {
203: printf("Exit code: %s\n", (pcntl_wifexited($status)) ? pcntl_wexitstatus($status) : 'n/a');
204: printf("Signal: %s\n", (pcntl_wifsignaled($status)) ? pcntl_wtermsig($status) : 'n/a');
205: printf("Stopped: %d\n", (pcntl_wifstopped($status)) ? pcntl_wstopsig($status) : 'n/a');
206: }
207: break;
208: }
209: mysqli_free_result($res);
210: mysqli_close($link);
211:
212: if (!$link = my_mysqli_connect($host, $user, $passwd, $db, $port, $socket))
213: printf("[018] Cannot connect to the server using host=%s, user=%s, passwd=***, dbname=%s, port=%s, socket=%s\n",
214: $host, $user, $db, $port, $socket);
215:
216: if (!$res = mysqli_query($link, "SELECT sender, msg FROM messages ORDER BY msg_id ASC"))
217: printf("[019] [%d] %s\n", mysqli_errno($link), mysqli_error($link));
218:
219: while ($row = mysqli_fetch_assoc($res))
220: printf("%10s %s\n", $row['sender'], substr($row['msg'], 0, 5));
221: mysqli_free_result($res);
222:
223: print "done!";
224: ?>
225: --CLEAN--
226: <?php
227: require_once("connect.inc");
228: if (!$link = my_mysqli_connect($host, $user, $passwd, $db, $port, $socket))
229: printf("[c001] [%d] %s\n", mysqli_connect_errno(), mysqli_connect_error());
230:
231: if (!mysqli_query($link, "DROP TABLE IF EXISTS test"))
232: printf("[c002] Cannot drop table, [%d] %s\n", mysqli_errno($link), mysqli_error($link));
233:
234: if (!mysqli_query($link, "DROP TABLE IF EXISTS messages"))
235: printf("[c003] Cannot drop table, [%d] %s\n", mysqli_errno($link), mysqli_error($link));
236:
237: mysqli_close($link);
238: ?>
239: --EXPECTF--
240: array(1) {
241: ["message"]=>
242: string(20) "dumped by the parent"
243: }
244: child start
245: child array
246: parent conti
247: child array
248: parent conti
249: child array
250: parent conti
251: child stop
252: done!