Changeset 13805

Timestamp:

06/13/08 13:54:04 (5 years ago)

Author:

nothingmuch

Message:

r82914@syeeda (orig r13794): tokuhirom | 2008-06-13 07:17:36 +0400
oops. i forgot to commit :-(
r82915@syeeda (orig r13795): tokuhirom | 2008-06-13 07:17:55 +0400
please test in deep.

Location:

lang/perl/HTTP-Engine/branches/lazy_request

Files:

• Makefile.PL (modified) (1 diff)
• lib/HTTP/Engine/Interface/POE.pm (modified) (1 diff)

lang/perl/HTTP-Engine/branches/lazy_request/Makefile.PL

@@ -74 +74 @@
     Apache::TestMM::filter_args();
     Apache::TestMM::generate_script('t/TEST');
-    tests('t/*.t t/modperl/basic.t');
+    tests('t/*.t t/*/*.t t/*/*/*.t t/*/*/*/*.t t/modperl/basic.t');
+} else {
+    tests('t/*.t t/*/*.t t/*/*/*.t t/*/*/*/*.t');
 }
 

lang/perl/HTTP-Engine/branches/lazy_request/lib/HTTP/Engine/Interface/POE.pm

@@ -35 +35 @@
         ClientFilter => 'POE::Filter::HTTPD',
         ( $self->alias ? ( Alias => $self->alias ) : () ),
-        ClientInput  => sub {
-            my ( $kernel, $heap, $request ) = @_[ KERNEL, HEAP, ARG0 ];
+        ClientInput  => _client_input($self),
+    );
+}
 
-            # Filter::HTTPD sometimes generates HTTP::Response objects.
-            # They indicate (and contain the response for) errors that occur
-            # while parsing the client's HTTP request.  It's easiest to send
-            # the responses as they are and finish up.
-            if ( $request->isa('HTTP::Response') ) {
-                $heap->{client}->put($request);
-                $kernel->yield('shutdown');
-                return;
-            }
+sub _client_input {
+    my $self = shift;
 
-            # follow is normal workflow.
-            my $ascgi = HTTP::Request::AsCGI->new($request)->setup;
-            do {
-                $self->handle_request();
-            };
-            $ascgi->restore;
+    sub {
+        my ( $kernel, $heap, $request ) = @_[ KERNEL, HEAP, ARG0 ];
 
-            $heap->{client}->put($ascgi->response);
+        # Filter::HTTPD sometimes generates HTTP::Response objects.
+        # They indicate (and contain the response for) errors that occur
+        # while parsing the client's HTTP request.  It's easiest to send
+        # the responses as they are and finish up.
+        if ( $request->isa('HTTP::Response') ) {
+            $heap->{client}->put($request);
             $kernel->yield('shutdown');
-        },
-    );
+            return;
+        }
+
+        # follow is normal workflow.
+        my $ascgi = HTTP::Request::AsCGI->new($request)->setup;
+        do {
+            $self->handle_request();
+        };
+        $ascgi->restore;
+
+        $heap->{client}->put($ascgi->response);
+        $kernel->yield('shutdown');
+    }
 }