Return to server.inc CVS log

Up to [ELWIX - Embedded LightWeight unIX -] / embedaddon / php / ext / standard / tests / http

Annotation of embedaddon/php/ext/standard/tests/http/server.inc, revision 1.1

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: ?>