about summary refs log tree commit homepage
path: root/lib
diff options
context:
space:
mode:
authorEric Wong <e@80x24.org>2017-01-11 04:12:27 +0000
committerEric Wong <e@80x24.org>2019-01-22 03:40:13 +0000
commit21235aaf76ff3b5d7f400b65c8aa793f6b6a002c (patch)
treed23c7b30018987dbd2c558d85d5bbc4e92732915 /lib
parentb490ce09b370d9398d5332ca1dc6260a7ec0aa6c (diff)
downloadpublic-inbox-21235aaf76ff3b5d7f400b65c8aa793f6b6a002c.tar.gz
Diffstat (limited to 'lib')
-rw-r--r--lib/PublicInbox/HTTPD/Async.pm1
-rw-r--r--lib/PublicInbox/Qspawn.pm4
2 files changed, 2 insertions, 3 deletions
diff --git a/lib/PublicInbox/HTTPD/Async.pm b/lib/PublicInbox/HTTPD/Async.pm
index a8488b6b..a9a9573b 100644
--- a/lib/PublicInbox/HTTPD/Async.pm
+++ b/lib/PublicInbox/HTTPD/Async.pm
@@ -23,6 +23,7 @@ sub new {
         $self;
 }
 
+# fires after pending writes are complete:
 sub restart_read_cb ($) {
         my ($self) = @_;
         sub { $self->watch_read(1) }
diff --git a/lib/PublicInbox/Qspawn.pm b/lib/PublicInbox/Qspawn.pm
index 3247cd07..96fbf38d 100644
--- a/lib/PublicInbox/Qspawn.pm
+++ b/lib/PublicInbox/Qspawn.pm
@@ -86,8 +86,6 @@ sub psgi_return {
                 $fh->close if $fh; # async-only
         };
 
-        # Danga::Socket users, we queue up the read_enable callback to
-        # fire after pending writes are complete:
         my $buf = '';
         my $rd_hdr = sub {
                 my $r = sysread($rpipe, $buf, 1024, length($buf));
@@ -102,7 +100,7 @@ sub psgi_return {
                 my $filter = delete $env->{'qspawn.filter'};
                 if (scalar(@$r) == 3) { # error
                         if ($async) {
-                                $async->close; # calls rpipe->close
+                                $async->close; # calls rpipe->close and $end
                         } else {
                                 $rpipe->close;
                                 $end->();