Return to server.inc CVS log | Up to [ELWIX - Embedded LightWeight unIX -] / embedaddon / php / ext / standard / tests / http |
1.1 misho 1: <?php 2: 3: function http_server_skipif($socket_string) { 4: 5: if (!function_exists('pcntl_fork')) die('skip pcntl_fork() not available'); 6: if (!function_exists('posix_kill')) die('skip posix_kill() not available'); 7: if (!stream_socket_server($socket_string)) die('skip stream_socket_server() failed'); 8: } 9: 10: /* Minimal HTTP server with predefined responses. 11: * 12: * $socket_string is the socket to create and listen on (e.g. tcp://127.0.0.1:1234) 13: * $files is an array of files containing N responses for N expected requests. Server dies after N requests. 14: * $output is a stream on which everything sent by clients is written to 15: */ 16: function http_server($socket_string, array $files, &$output = null) { 17: 18: pcntl_alarm(60); 19: 20: $server = stream_socket_server($socket_string, $errno, $errstr); 21: if (!$server) { 22: return false; 23: } 24: 25: if ($output === null) { 26: $output = tmpfile(); 27: if ($output === false) { 28: return false; 29: } 30: } 31: 32: $pid = pcntl_fork(); 33: if ($pid == -1) { 34: die('could not fork'); 35: } else if ($pid) { 36: return $pid; 37: } 38: 39: foreach($files as $file) { 40: 41: $sock = stream_socket_accept($server); 42: if (!$sock) { 43: exit(1); 44: } 45: 46: // read headers 47: 48: $content_length = 0; 49: 50: stream_set_blocking($sock, 0); 51: while (!feof($sock)) { 52: 53: list($r, $w, $e) = array(array($sock), null, null); 54: if (!stream_select($r, $w, $e, 1)) continue; 55: 56: $line = stream_get_line($sock, 8192, "\r\n"); 57: if ($line === b'') { 58: fwrite($output, b"\r\n"); 59: break; 60: } else if ($line !== false) { 61: fwrite($output, b"$line\r\n"); 62: 63: if (preg_match(b'#^Content-Length\s*:\s*([[:digit:]]+)\s*$#i', $line, $matches)) { 64: $content_length = (int) $matches[1]; 65: } 66: } 67: } 68: stream_set_blocking($sock, 1); 69: 70: // read content 71: 72: if ($content_length > 0) { 73: stream_copy_to_stream($sock, $output, $content_length); 74: } 75: 76: // send response 77: 78: $fd = fopen($file, 'rb'); 79: stream_copy_to_stream($fd, $sock); 80: 81: fclose($sock); 82: } 83: 84: exit(0); 85: } 86: 87: function http_server_kill($pid) { 88: posix_kill($pid, SIGTERM); 89: pcntl_waitpid($pid, $status); 90: } 91: 92: ?>