[catagits/Catalyst-Runtime.git] / lib / Catalyst / Engine / HTTP.pm

package Catalyst::Engine::HTTP;

use strict;
use base 'Catalyst::Engine::CGI';
use Errno 'EWOULDBLOCK';
use HTTP::Date ();
use HTTP::Status;
use NEXT;
use Socket;
use IO::Socket::INET ();
use IO::Select       ();

# For PAR
require Catalyst::Engine::HTTP::Restarter;
require Catalyst::Engine::HTTP::Restarter::Watcher;

=head1 NAME

Catalyst::Engine::HTTP - Catalyst HTTP Engine

=head1 SYNOPSIS

A script using the Catalyst::Engine::HTTP module might look like:

    #!/usr/bin/perl -w

    BEGIN {  $ENV{CATALYST_ENGINE} = 'HTTP' }

    use strict;
    use lib '/path/to/MyApp/lib';
    use MyApp;

    MyApp->run;

=head1 DESCRIPTION

This is the Catalyst engine specialized for development and testing.

=head1 METHODS

=head2 $self->finalize_headers($c)

=cut

sub finalize_headers {
    my ( $self, $c ) = @_;
    my $protocol = $c->request->protocol;
    my $status   = $c->response->status;
    my $message  = status_message($status);
    
    print "$protocol $status $message\015\012";
    
    $c->response->headers->header( Date => HTTP::Date::time2str(time) );
    $c->response->headers->header(
        Connection => $self->_keep_alive ? 'keep-alive' : 'close' );
        
    $c->response->headers->header( Status => $status );
        
    # Avoid 'print() on closed filehandle Remote' warnings when using IE
    print $c->response->headers->as_string("\015\012") if *STDOUT->opened();
    print "\015\012" if *STDOUT->opened();
}

=head2 $self->finalize_read($c)

=cut

sub finalize_read {
    my ( $self, $c ) = @_;

    # Never ever remove this, it would result in random length output
    # streams if STDIN eq STDOUT (like in the HTTP engine)
    *STDIN->blocking(1);

    return $self->NEXT::finalize_read($c);
}

=head2 $self->prepare_read($c)

=cut

sub prepare_read {
    my ( $self, $c ) = @_;

    # Set the input handle to non-blocking
    *STDIN->blocking(0);

    return $self->NEXT::prepare_read($c);
}

=head2 $self->read_chunk($c, $buffer, $length)

=cut

sub read_chunk {
    my $self = shift;
    my $c    = shift;

    # support for non-blocking IO
    my $rin = '';
    vec( $rin, *STDIN->fileno, 1 ) = 1;

  READ:
    {
        select( $rin, undef, undef, undef );
        my $rc = *STDIN->sysread(@_);
        if ( defined $rc ) {
            return $rc;
        }
        else {
            next READ if $! == EWOULDBLOCK;
            return;
        }
    }
}

=head2 $self->write($c, $buffer)

Writes the buffer to the client. Can only be called once for a request.

=cut

sub write {
	# Avoid 'print() on closed filehandle Remote' warnings when using IE
	return unless *STDOUT->opened();
	
	shift->NEXT::write( @_ );
}

=head2 run

=cut

# A very very simple HTTP server that initializes a CGI environment
sub run {
    my ( $self, $class, $port, $host, $options ) = @_;

    $options ||= {};

    if ($options->{background}) {
        my $child = fork;
        die "Can't fork: $!" unless defined($child);
        exit if $child;
    }

    my $restart = 0;
    local $SIG{CHLD} = 'IGNORE';

    my $allowed = $options->{allowed} || { '127.0.0.1' => '255.255.255.255' };
    my $addr = $host ? inet_aton($host) : INADDR_ANY;
    if ( $addr eq INADDR_ANY ) {
        require Sys::Hostname;
        $host = lc Sys::Hostname::hostname();
    }
    else {
        $host = gethostbyaddr( $addr, AF_INET ) || inet_ntoa($addr);
    }

    # Handle requests

    # Setup socket
    my $daemon = IO::Socket::INET->new(
        Listen    => SOMAXCONN,
        LocalAddr => inet_ntoa($addr),
        LocalPort => $port,
        Proto     => 'tcp',
        ReuseAddr => 1,
        Type      => SOCK_STREAM,
      )
      or die "Couldn't create daemon: $!";

    my $url = "http://$host";
    $url .= ":$port" unless $port == 80;

    print "You can connect to your server at $url\n";

    if ($options->{background}) {
        open STDIN,  "+</dev/null" or die $!;
        open STDOUT, ">&STDIN"     or die $!;
        open STDERR, ">&STDIN"     or die $!;
        if ( $^O !~ /MSWin32/ ) {
             require POSIX;
             POSIX::setsid()
                 or die "Can't start a new session: $!";
        }
    }

    if (my $pidfile = $options->{pidfile}) {
        if (! open PIDFILE, "> $pidfile") {
            warn("Cannot open: $pidfile: $!");
        }
        print PIDFILE "$$\n";
        close PIDFILE;
    }

    $self->_keep_alive( $options->{keepalive} || 0 );

    my $pid    = undef;
    while ( accept( Remote, $daemon ) )
    {    # TODO: get while ( my $remote = $daemon->accept ) to work

        select Remote;

        # Request data

        Remote->blocking(1);

        next
          unless my ( $method, $uri, $protocol ) =
          $self->_parse_request_line( \*Remote );

        unless ( uc($method) eq 'RESTART' ) {

            # Fork
            if ( $options->{fork} ) { next if $pid = fork }

            $self->_handler( $class, $port, $method, $uri, $protocol );

            $daemon->close if defined $pid;

        }
        else {
            my $sockdata = $self->_socket_data( \*Remote );
            my $ipaddr   = _inet_addr( $sockdata->{peeraddr} );
            my $ready    = 0;
            foreach my $ip ( keys %$allowed ) {
                my $mask = $allowed->{$ip};
                $ready = ( $ipaddr & _inet_addr($mask) ) == _inet_addr($ip);
                last if $ready;
            }
            if ($ready) {
                $restart = 1;
                last;
            }
        }

        exit if defined $pid;
    }
    continue {
        close Remote;
    }
    $daemon->close;

    if ($restart) {
        $SIG{CHLD} = 'DEFAULT';
        wait;

        ### if the standalone server was invoked with perl -I .. we will loose
        ### those include dirs upon re-exec. So add them to PERL5LIB, so they
        ### are available again for the exec'ed process --kane
        use Config;
        $ENV{PERL5LIB} .= join $Config{path_sep}, @INC; 
        
        exec $^X . ' "' . $0 . '" ' . join( ' ', @{ $options->{argv} } );
    }

    exit;
}

sub _handler {
    my ( $self, $class, $port, $method, $uri, $protocol ) = @_;

    # Ignore broken pipes as an HTTP server should
    local $SIG{PIPE} = sub { close Remote };

    local *STDIN  = \*Remote;
    local *STDOUT = \*Remote;

    # We better be careful and just use 1.0
    $protocol = '1.0';

    my $sockdata    = $self->_socket_data( \*Remote );
    my %copy_of_env = %ENV;

    my $sel = IO::Select->new;
    $sel->add( \*STDIN );

    while (1) {
        my ( $path, $query_string ) = split /\?/, $uri, 2;

        # Initialize CGI environment
        local %ENV = (
            PATH_INFO    => $path         || '',
            QUERY_STRING => $query_string || '',
            REMOTE_ADDR     => $sockdata->{peeraddr},
            REMOTE_HOST     => $sockdata->{peername},
            REQUEST_METHOD  => $method || '',
            SERVER_NAME     => $sockdata->{localname},
            SERVER_PORT     => $port,
            SERVER_PROTOCOL => "HTTP/$protocol",
            %copy_of_env,
        );

        # Parse headers
        if ( $protocol >= 1 ) {
            while (1) {
                my $line = $self->_get_line( \*STDIN );
                last if $line eq '';
                next
                  unless my ( $name, $value ) =
                  $line =~ m/\A(\w(?:-?\w+)*):\s(.+)\z/;

                $name = uc $name;
                $name = 'COOKIE' if $name eq 'COOKIES';
                $name =~ tr/-/_/;
                $name = 'HTTP_' . $name
                  unless $name =~ m/\A(?:CONTENT_(?:LENGTH|TYPE)|COOKIE)\z/;
                if ( exists $ENV{$name} ) {
                    $ENV{$name} .= ", $value";
                }
                else {
                    $ENV{$name} = $value;
                }
            }
        }

        # Pass flow control to Catalyst
        $class->handle_request;

        my $connection = lc $ENV{HTTP_CONNECTION};
        last
          unless $self->_keep_alive()
          && index( $connection, 'keep-alive' ) > -1
          && index( $connection, 'te' ) == -1          # opera stuff
          && $sel->can_read(5);

        last
          unless ( $method, $uri, $protocol ) =
          $self->_parse_request_line( \*STDIN );
    }

    close Remote;
}

sub _keep_alive {
    my ( $self, $keepalive ) = @_;

    my $r = $self->{_keepalive} || 0;
    $self->{_keepalive} = $keepalive if defined $keepalive;

    return $r;

}

sub _parse_request_line {
    my ( $self, $handle ) = @_;

    # Parse request line
    my $line = $self->_get_line($handle);
    return ()
      unless my ( $method, $uri, $protocol ) =
      $line =~ m/\A(\w+)\s+(\S+)(?:\s+HTTP\/(\d+(?:\.\d+)?))?\z/;
    return ( $method, $uri, $protocol );
}

sub _socket_data {
    my ( $self, $handle ) = @_;

    my $remote_sockaddr       = getpeername($handle);
    my ( undef, $iaddr )      = $remote_sockaddr 
        ? sockaddr_in($remote_sockaddr) 
        : (undef, undef);
        
    my $local_sockaddr        = getsockname($handle);
    my ( undef, $localiaddr ) = sockaddr_in($local_sockaddr);

    # This mess is necessary to keep IE from crashing the server
    my $data = {
        peername  => $iaddr 
            ? ( gethostbyaddr( $iaddr, AF_INET ) || 'localhost' )
            : 'localhost',
        peeraddr  => $iaddr 
            ? ( inet_ntoa($iaddr) || '127.0.0.1' )
            : '127.0.0.1',
        localname => gethostbyaddr( $localiaddr, AF_INET ) || 'localhost',
        localaddr => inet_ntoa($localiaddr) || '127.0.0.1',
    };

    return $data;
}

sub _get_line {
    my ( $self, $handle ) = @_;

    my $line = '';

    while ( sysread( $handle, my $byte, 1 ) ) {
        last if $byte eq "\012";    # eol
        $line .= $byte;
    }

    1 while $line =~ s/\s\z//;

    return $line;
}

sub _inet_addr { unpack "N*", inet_aton( $_[0] ) }

=head1 SEE ALSO

L<Catalyst>, L<Catalyst::Engine>.

=head1 AUTHORS

Sebastian Riedel, <sri@cpan.org>

Dan Kubb, <dan.kubb-cpan@onautopilot.com>

Sascha Kiefer, <esskar@cpan.org>

=head1 THANKS

Many parts are ripped out of C<HTTP::Server::Simple> by Jesse Vincent.

=head1 COPYRIGHT

This program is free software, you can redistribute it and/or modify it under
the same terms as Perl itself.

=cut

1;
Commit	Line	Data
ca61af20	1	package Catalyst::Engine::HTTP;
45374ac6	2
45374ac6	3	use strict;
fbcc39ad	4	use base 'Catalyst::Engine::CGI';
fbcc39ad	5	use Errno 'EWOULDBLOCK';
055ff026	6	use HTTP::Date ();
fbcc39ad	7	use HTTP::Status;
	8	use NEXT;
	9	use Socket;
6c7a1d2f	10	use IO::Socket::INET ();
b5ecfcf0	11	use IO::Select ();
45374ac6	12
71fd2e0f	13	# For PAR
	14	require Catalyst::Engine::HTTP::Restarter;
	15	require Catalyst::Engine::HTTP::Restarter::Watcher;
	16
45374ac6	17	=head1 NAME
45374ac6	18
ca61af20	19	Catalyst::Engine::HTTP - Catalyst HTTP Engine
45374ac6	20
	21	=head1 SYNOPSIS
	22
ca61af20	23	A script using the Catalyst::Engine::HTTP module might look like:
45374ac6	24
	25	#!/usr/bin/perl -w
	26
ca61af20	27	BEGIN { $ENV{CATALYST_ENGINE} = 'HTTP' }
45374ac6	28
	29	use strict;
	30	use lib '/path/to/MyApp/lib';
	31	use MyApp;
	32
	33	MyApp->run;
	34
	35	=head1 DESCRIPTION
	36
	37	This is the Catalyst engine specialized for development and testing.
	38
fbcc39ad	39	=head1 METHODS
fbcc39ad	40
b5ecfcf0	41	=head2 $self->finalize_headers($c)
fbcc39ad	42
	43	=cut
	44
	45	sub finalize_headers {
	46	my ( $self, $c ) = @_;
	47	my $protocol = $c->request->protocol;
	48	my $status = $c->response->status;
	49	my $message = status_message($status);
055ff026	50
fbcc39ad	51	print "$protocol $status $message\015\012";
055ff026	52
055ff026	53	$c->response->headers->header( Date => HTTP::Date::time2str(time) );
6c7a1d2f	54	$c->response->headers->header(
6c7a1d2f	55	Connection => $self->_keep_alive ? 'keep-alive' : 'close' );
00c99324	56
055ff026	57	$c->response->headers->header( Status => $status );
00c99324	58
	59	# Avoid 'print() on closed filehandle Remote' warnings when using IE
	60	print $c->response->headers->as_string("\015\012") if *STDOUT->opened();
	61	print "\015\012" if *STDOUT->opened();
fbcc39ad	62	}
fbcc39ad	63
b5ecfcf0	64	=head2 $self->finalize_read($c)
fbcc39ad	65
	66	=cut
	67
	68	sub finalize_read {
	69	my ( $self, $c ) = @_;
	70
	71	# Never ever remove this, it would result in random length output
	72	# streams if STDIN eq STDOUT (like in the HTTP engine)
4f5ebacd	73	*STDIN->blocking(1);
fbcc39ad	74
	75	return $self->NEXT::finalize_read($c);
	76	}
	77
b5ecfcf0	78	=head2 $self->prepare_read($c)
fbcc39ad	79
	80	=cut
	81
	82	sub prepare_read {
	83	my ( $self, $c ) = @_;
	84
	85	# Set the input handle to non-blocking
4f5ebacd	86	*STDIN->blocking(0);
fbcc39ad	87
	88	return $self->NEXT::prepare_read($c);
	89	}
	90
b5ecfcf0	91	=head2 $self->read_chunk($c, $buffer, $length)
fbcc39ad	92
	93	=cut
	94
	95	sub read_chunk {
	96	my $self = shift;
	97	my $c = shift;
	98
	99	# support for non-blocking IO
4f5ebacd	100	my $rin = '';
4f5ebacd	101	vec( $rin, *STDIN->fileno, 1 ) = 1;
fbcc39ad	102
	103	READ:
	104	{
	105	select( $rin, undef, undef, undef );
4f5ebacd	106	my $rc = *STDIN->sysread(@_);
fbcc39ad	107	if ( defined $rc ) {
	108	return $rc;
	109	}
	110	else {
	111	next READ if $! == EWOULDBLOCK;
	112	return;
	113	}
	114	}
	115	}
	116
00c99324	117	=head2 $self->write($c, $buffer)
	118
	119	Writes the buffer to the client. Can only be called once for a request.
	120
	121	=cut
	122
	123	sub write {
	124	# Avoid 'print() on closed filehandle Remote' warnings when using IE
	125	return unless *STDOUT->opened();
	126
	127	shift->NEXT::write( @_ );
	128	}
	129
b5ecfcf0	130	=head2 run
fbcc39ad	131
	132	=cut
	133
	134	# A very very simple HTTP server that initializes a CGI environment
	135	sub run {
37553dc8	136	my ( $self, $class, $port, $host, $options ) = @_;
fbcc39ad	137
4eeca0f2	138	$options \|\|= {};
1cf1c56a	139
e1576f62	140	if ($options->{background}) {
	141	my $child = fork;
	142	die "Can't fork: $!" unless defined($child);
	143	exit if $child;
	144	}
	145
57a87bb3	146	my $restart = 0;
31b426c0	147	local $SIG{CHLD} = 'IGNORE';
fbcc39ad	148
1cf1c56a	149	my $allowed = $options->{allowed} \|\| { '127.0.0.1' => '255.255.255.255' };
6c7a1d2f	150	my $addr = $host ? inet_aton($host) : INADDR_ANY;
6c7a1d2f	151	if ( $addr eq INADDR_ANY ) {
fbcc39ad	152	require Sys::Hostname;
6c7a1d2f	153	$host = lc Sys::Hostname::hostname();
fbcc39ad	154	}
fbcc39ad	155	else {
6c7a1d2f	156	$host = gethostbyaddr( $addr, AF_INET ) \|\| inet_ntoa($addr);
fbcc39ad	157	}
6c7a1d2f	158
	159	# Handle requests
	160
	161	# Setup socket
	162	my $daemon = IO::Socket::INET->new(
	163	Listen => SOMAXCONN,
	164	LocalAddr => inet_ntoa($addr),
	165	LocalPort => $port,
	166	Proto => 'tcp',
	167	ReuseAddr => 1,
	168	Type => SOCK_STREAM,
	169	)
	170	or die "Couldn't create daemon: $!";
	171
	172	my $url = "http://$host";
	173	$url .= ":$port" unless $port == 80;
	174
fbcc39ad	175	print "You can connect to your server at $url\n";
fbcc39ad	176
e1576f62	177	if ($options->{background}) {
	178	open STDIN, "+</dev/null" or die $!;
	179	open STDOUT, ">&STDIN" or die $!;
	180	open STDERR, ">&STDIN" or die $!;
	181	if ( $^O !~ /MSWin32/ ) {
	182	require POSIX;
	183	POSIX::setsid()
	184	or die "Can't start a new session: $!";
	185	}
	186	}
	187
	188	if (my $pidfile = $options->{pidfile}) {
	189	if (! open PIDFILE, "> $pidfile") {
	190	warn("Cannot open: $pidfile: $!");
	191	}
	192	print PIDFILE "$$\n";
	193	close PIDFILE;
	194	}
	195
6c7a1d2f	196	$self->_keep_alive( $options->{keepalive} \|\| 0 );
6c7a1d2f	197
57a87bb3	198	my $pid = undef;
6c7a1d2f	199	while ( accept( Remote, $daemon ) )
6c7a1d2f	200	{ # TODO: get while ( my $remote = $daemon->accept ) to work
fbcc39ad	201
57a87bb3	202	select Remote;
fbcc39ad	203
fbcc39ad	204	# Request data
fbcc39ad	205
57a87bb3	206	Remote->blocking(1);
fbcc39ad	207
fbcc39ad	208	next
fbcc39ad	209	unless my ( $method, $uri, $protocol ) =
6c7a1d2f	210	$self->_parse_request_line( \*Remote );
fbcc39ad	211
57a87bb3	212	unless ( uc($method) eq 'RESTART' ) {
	213
	214	# Fork
	215	if ( $options->{fork} ) { next if $pid = fork }
	216
6c7a1d2f	217	$self->_handler( $class, $port, $method, $uri, $protocol );
	218
	219	$daemon->close if defined $pid;
fbcc39ad	220
1cf1c56a	221	}
1cf1c56a	222	else {
6c7a1d2f	223	my $sockdata = $self->_socket_data( \*Remote );
	224	my $ipaddr = _inet_addr( $sockdata->{peeraddr} );
	225	my $ready = 0;
c82ed742	226	foreach my $ip ( keys %$allowed ) {
c82ed742	227	my $mask = $allowed->{$ip};
1cf1c56a	228	$ready = ( $ipaddr & _inet_addr($mask) ) == _inet_addr($ip);
c82ed742	229	last if $ready;
1cf1c56a	230	}
1cf1c56a	231	if ($ready) {
57a87bb3	232	$restart = 1;
1cf1c56a	233	last;
	234	}
	235	}
57a87bb3	236
fbcc39ad	237	exit if defined $pid;
	238	}
	239	continue {
	240	close Remote;
	241	}
6c7a1d2f	242	$daemon->close;
37553dc8	243
57a87bb3	244	if ($restart) {
60c38e3e	245	$SIG{CHLD} = 'DEFAULT';
6844bc1c	246	wait;
e37e3977	247
	248	### if the standalone server was invoked with perl -I .. we will loose
	249	### those include dirs upon re-exec. So add them to PERL5LIB, so they
	250	### are available again for the exec'ed process --kane
	251	use Config;
	252	$ENV{PERL5LIB} .= join $Config{path_sep}, @INC;
	253
1cf1c56a	254	exec $^X . ' "' . $0 . '" ' . join( ' ', @{ $options->{argv} } );
60c38e3e	255	}
57a87bb3	256
57a87bb3	257	exit;
fbcc39ad	258	}
fbcc39ad	259
6c7a1d2f	260	sub _handler {
	261	my ( $self, $class, $port, $method, $uri, $protocol ) = @_;
	262
	263	# Ignore broken pipes as an HTTP server should
	264	local $SIG{PIPE} = sub { close Remote };
	265
	266	local STDIN = \Remote;
	267	local STDOUT = \Remote;
	268
	269	# We better be careful and just use 1.0
	270	$protocol = '1.0';
	271
	272	my $sockdata = $self->_socket_data( \*Remote );
	273	my %copy_of_env = %ENV;
	274
	275	my $sel = IO::Select->new;
	276	$sel->add( \*STDIN );
	277
	278	while (1) {
	279	my ( $path, $query_string ) = split /\?/, $uri, 2;
	280
	281	# Initialize CGI environment
	282	local %ENV = (
b5ecfcf0	283	PATH_INFO => $path \|\| '',
b5ecfcf0	284	QUERY_STRING => $query_string \|\| '',
6c7a1d2f	285	REMOTE_ADDR => $sockdata->{peeraddr},
	286	REMOTE_HOST => $sockdata->{peername},
	287	REQUEST_METHOD => $method \|\| '',
	288	SERVER_NAME => $sockdata->{localname},
	289	SERVER_PORT => $port,
	290	SERVER_PROTOCOL => "HTTP/$protocol",
	291	%copy_of_env,
	292	);
	293
	294	# Parse headers
	295	if ( $protocol >= 1 ) {
	296	while (1) {
	297	my $line = $self->_get_line( \*STDIN );
	298	last if $line eq '';
	299	next
	300	unless my ( $name, $value ) =
	301	$line =~ m/\A(\w(?:-?\w+)*):\s(.+)\z/;
	302
	303	$name = uc $name;
	304	$name = 'COOKIE' if $name eq 'COOKIES';
	305	$name =~ tr/-/_/;
	306	$name = 'HTTP_' . $name
	307	unless $name =~ m/\A(?:CONTENT_(?:LENGTH\|TYPE)\|COOKIE)\z/;
	308	if ( exists $ENV{$name} ) {
ace55b07	309	$ENV{$name} .= ", $value";
6c7a1d2f	310	}
	311	else {
	312	$ENV{$name} = $value;
	313	}
	314	}
	315	}
	316
	317	# Pass flow control to Catalyst
	318	$class->handle_request;
	319
	320	my $connection = lc $ENV{HTTP_CONNECTION};
	321	last
	322	unless $self->_keep_alive()
	323	&& index( $connection, 'keep-alive' ) > -1
	324	&& index( $connection, 'te' ) == -1 # opera stuff
	325	&& $sel->can_read(5);
	326
	327	last
	328	unless ( $method, $uri, $protocol ) =
	329	$self->_parse_request_line( \*STDIN );
	330	}
	331
	332	close Remote;
	333	}
	334
	335	sub _keep_alive {
	336	my ( $self, $keepalive ) = @_;
	337
	338	my $r = $self->{_keepalive} \|\| 0;
	339	$self->{_keepalive} = $keepalive if defined $keepalive;
	340
	341	return $r;
	342
	343	}
	344
	345	sub _parse_request_line {
	346	my ( $self, $handle ) = @_;
	347
	348	# Parse request line
	349	my $line = $self->_get_line($handle);
	350	return ()
	351	unless my ( $method, $uri, $protocol ) =
	352	$line =~ m/\A(\w+)\s+(\S+)(?:\s+HTTP\/(\d+(?:\.\d+)?))?\z/;
	353	return ( $method, $uri, $protocol );
	354	}
	355
	356	sub _socket_data {
	357	my ( $self, $handle ) = @_;
	358
8b9d0298	359	my $remote_sockaddr = getpeername($handle);
3150d774	360	my ( undef, $iaddr ) = $remote_sockaddr
	361	? sockaddr_in($remote_sockaddr)
	362	: (undef, undef);
	363
8b9d0298	364	my $local_sockaddr = getsockname($handle);
6c7a1d2f	365	my ( undef, $localiaddr ) = sockaddr_in($local_sockaddr);
6c7a1d2f	366
8b9d0298	367	# This mess is necessary to keep IE from crashing the server
6c7a1d2f	368	my $data = {
8b9d0298	369	peername => $iaddr
	370	? ( gethostbyaddr( $iaddr, AF_INET ) \|\| 'localhost' )
	371	: 'localhost',
	372	peeraddr => $iaddr
	373	? ( inet_ntoa($iaddr) \|\| '127.0.0.1' )
	374	: '127.0.0.1',
	375	localname => gethostbyaddr( $localiaddr, AF_INET ) \|\| 'localhost',
	376	localaddr => inet_ntoa($localiaddr) \|\| '127.0.0.1',
6c7a1d2f	377	};
	378
	379	return $data;
	380	}
	381
fbcc39ad	382	sub _get_line {
	383	my ( $self, $handle ) = @_;
	384
	385	my $line = '';
	386
	387	while ( sysread( $handle, my $byte, 1 ) ) {
	388	last if $byte eq "\012"; # eol
	389	$line .= $byte;
	390	}
	391
	392	1 while $line =~ s/\s\z//;
	393
	394	return $line;
	395	}
	396
1cf1c56a	397	sub _inet_addr { unpack "N*", inet_aton( $_[0] ) }
1cf1c56a	398
45374ac6	399	=head1 SEE ALSO
45374ac6	400
fbcc39ad	401	L<Catalyst>, L<Catalyst::Engine>.
	402
	403	=head1 AUTHORS
	404
	405	Sebastian Riedel, <sri@cpan.org>
	406
	407	Dan Kubb, <dan.kubb-cpan@onautopilot.com>
45374ac6	408
6c7a1d2f	409	Sascha Kiefer, <esskar@cpan.org>
6c7a1d2f	410
fbcc39ad	411	=head1 THANKS
45374ac6	412
fbcc39ad	413	Many parts are ripped out of C<HTTP::Server::Simple> by Jesse Vincent.
45374ac6	414
	415	=head1 COPYRIGHT
	416
	417	This program is free software, you can redistribute it and/or modify it under
	418	the same terms as Perl itself.
	419
	420	=cut
	421
45374ac6	422	1;