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
|
<?php
/* based on sapi/cli/tests/php_cli_server.inc */
define ("PHP_CLI_SERVER_HOSTNAME", "127.0.0.1");
define ("PHP_CLI_SERVER_PORT", 8000 + PHP_INT_SIZE*100 + PHP_MAJOR_VERSION*10 + PHP_MINOR_VERSION);
define ("PHP_CLI_SERVER_ADDRESS", PHP_CLI_SERVER_HOSTNAME.":".PHP_CLI_SERVER_PORT);
/* XXX incapsulate all this globals into a class when have a favourable minute */
$doc_root = __DIR__;
$router = "index.php";
$handles = array();
$ports = array();
$num_servers = 3;
function server_start_one($host, $port, $code = 'echo "Hello world";', $php_opts = array(), $no_router = FALSE)
{
global $doc_root, $router, $handles, $ports;
$php_executable = getenv('TEST_PHP_EXECUTABLE');
$descriptorspec = array(
0 => STDIN,
1 => STDOUT,
2 => STDERR,
);
$php_args = getenv('TEST_PHP_ARGS');
if (empty($php_args)) {
$ext = (substr(PHP_OS, 0, 3) == 'WIN') ? 'php_apcu.dll' : 'apcu.so';
$php_args = "-d extension_dir=$doc_root/../modules -d extension=$ext";
}
if ($php_opts) {
$php_args = "$php_args -d " . implode(' -d ', $php_opts);;
}
if (substr(PHP_OS, 0, 3) == 'WIN') {
$cmd = "{$php_executable} -n $php_args -t {$doc_root} -S $host:$port";
if (!$no_router) {
$cmd .= " {$router}";
}
$handle = proc_open(addslashes($cmd), $descriptorspec, $pipes, $doc_root, NULL, array("bypass_shell" => true, "suppress_errors" => true));
} else {
$cmd = "exec {$php_executable} -n $php_args -t {$doc_root} -S $host:$port";
if (!$no_router) {
$cmd .= " {$doc_root}/{$router}";
}
$cmd .= " 2>/dev/null";
$handle = proc_open($cmd, $descriptorspec, $pipes, $doc_root);
}
// note: even when server prints 'Listening on localhost:8964...Press Ctrl-C to quit.'
// it might not be listening yet...need to wait until fsockopen() call returns
$i = 0;
while (($i++ < 10) && !connection_test($host, $port)) {
usleep(100000);
}
return $handle;
}
function server_start($code = 'echo "Hello world";', $php_opts = array(), $no_router = FALSE)
{
global $doc_root, $router, $handles, $ports, $num_servers;
if ($code) {
file_put_contents($doc_root . '/' . $router, '<?php ' . $code . ' ?>');
}
for ($i = 0; $i < $num_servers; $i++) {
$h = server_start_one(PHP_CLI_SERVER_HOSTNAME, PHP_CLI_SERVER_PORT+$i, $code, $php_opts, $no_router);
$handles[] = $h;
}
register_shutdown_function(
function($handles) use($router) {
foreach ($handles as $handle) {
proc_terminate($handle);
}
@unlink(__DIR__ . "/{$router}");
},
$handles
);
// don't bother sleeping, server is already up
// server can take a variable amount of time to be up, so just sleeping a guessed amount of time
// does not work. this is why tests sometimes pass and sometimes fail. to get a reliable pass
// sleeping doesn't work.
}
function get_response($fp, $data_only = true)
{
$s = '';
while (!feof($fp)) {
$s .= fgets($fp);
}
if ($data_only) {
$parts = explode("\r\n\r\n", $s);
$s = $parts[1];
}
return $s;
}
function connection_test($host, $port)
{
$port = intval($port)?:80;
$fp = @fsockopen($host, $port, $errno, $errstr, 2);
if (!$fp) {
return false;
}
$send = "GET / HTTP/1.1\nHost: {$host}\r\n\r\n";
/* will not out here, just test if the connection has worked*/
if(@fwrite($fp, $send)) {
get_response($fp);
fclose($fp);
return true;
}
@fclose($fp);
return false;
}
function run_test_simple($request_uri = NULL)
{
global $num_servers;
$send = "GET /" . $request_uri ." HTTP/1.1\nHost: " . PHP_CLI_SERVER_HOSTNAME . "\r\n\r\n";
for ($i = 0; $i < $num_servers; $i++) {
run_test(PHP_CLI_SERVER_HOSTNAME, PHP_CLI_SERVER_PORT+$i, $send);
}
}
function run_test($host, $port, $send)
{
$fp = fsockopen($host, $port, $errno, $errstr, 3);
if (!$fp) {
die(sprintf("connect failed errno=%d errstr='%s'", $errno, $errstr));
}
if(fwrite($fp, $send)) {
echo get_response($fp);
}
fclose($fp);
}
|
