about summary refs log tree commit homepage
path: root/lib/PublicInbox/Qspawn.pm
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/PublicInbox/Qspawn.pm
parentb490ce09b370d9398d5332ca1dc6260a7ec0aa6c (diff)
downloadpublic-inbox-21235aaf76ff3b5d7f400b65c8aa793f6b6a002c.tar.gz
Diffstat (limited to 'lib/PublicInbox/Qspawn.pm')
-rw-r--r--lib/PublicInbox/Qspawn.pm4
1 files changed, 1 insertions, 3 deletions
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->();