while (1) {
- for my $client ( $select->can_read ) {
+ for my $client ( $select->can_read(0.1) ) {
if ( $client == $daemon ) {
$client = $daemon->accept;
next if $client->response;
my $read = $client->sysread( my $buf, 4096 );
-
+
unless ( defined($read) && length($buf) ) {
-
+
$select->remove($client);
$client->close;
next;
}
- $client->read_buffer($buf);
- $client->request( $client->get_request );
+ $client->request_buffer .= $buf;
+ $client->request = $client->get_request;
}
}
next if $client->response;
next unless $client->request;
- $client->response( HTTP::Response->new );
- $class->handler( $client->request, $client->response, $client );
+ $client->response = HTTP::Response->new;
+ $client->response->protocol( $client->request->protocol );
+ $class->handler( $client->request, $client->response, $client );
}
for my $client ( $select->can_write(0) ) {
next unless $client->response;
- $client->send_response( $client->response );
+ unless ( $client->response_buffer ) {
+ $client->response_buffer = $client->response->as_string;
+ $client->response_offset = 0;
+ }
+
+ my $write = $client->syswrite( $client->response_buffer,
+ $client->response_length,
+ $client->response_offset );
- my $connection = $client->request->header('Connection');
+ $client->response_offset += $write;
+
+ unless ( defined($write) ) {
- unless ( $connection && $connection =~ /Keep-Alive/i ) {
$select->remove($client);
$client->close;
+
+ next;
}
- $client->request(undef);
- $client->response(undef);
+ if ( $client->response_offset == $client->response_length ) {
+
+ my $connection = $client->request->header('Connection');
+
+ unless ( $connection && $connection =~ /Keep-Alive/i ) {
+ $select->remove($client);
+ $client->close;
+ }
+
+ $client->response = undef;
+ $client->request = undef;
+ $client->response_buffer = undef;
+ }
}
}
}
use strict;
use base 'HTTP::Daemon::ClientConn';
-sub read_buffer {
+sub request : lvalue {
my $self = shift;
-
- if (@_) {
- ${*$self}{'httpd_rbuf'} .= shift;
- }
-
- return ${*$self}{'httpd_rbuf'};
+ ${*$self}{'request'};
}
-sub request {
+sub request_buffer : lvalue {
my $self = shift;
+ ${*$self}{'httpd_rbuf'};
+}
- if (@_) {
- ${*$self}{'request'} = shift;
- }
-
- return ${*$self}{'request'};
+sub response : lvalue {
+ my $self = shift;
+ ${*$self}{'response'};
}
-sub response {
+sub response_buffer : lvalue {
my $self = shift;
+ ${*$self}{'httpd_wbuf'};
+}
- if (@_) {
- ${*$self}{'response'} = shift;
- }
+sub response_length {
+ my $self = shift;
+ return length( $self->response_buffer );
+}
- return ${*$self}{'response'};
+sub response_offset : lvalue {
+ my $self = shift;
+ ${*$self}{'httpd_woffset'};
}
+
1;