diff options
author | Eric Wong <e@80x24.org> | 2022-12-23 11:05:15 +0000 |
---|---|---|
committer | Eric Wong <e@80x24.org> | 2022-12-23 12:44:26 +0000 |
commit | 1556c660030b7ebb4006f522026e638285e94f46 (patch) | |
tree | 3b501d743270a9192ebd6d249b6e6c97849557db /lib/PublicInbox/HTTPD | |
parent | 372d6e03debe13cab1ed00a3a59e834566c7a709 (diff) | |
download | public-inbox-1556c660030b7ebb4006f522026e638285e94f46.tar.gz |
Use more unique names within the project to minimize confusion since these packages interact quite a bit and using identical names leads to needless confusion.
Diffstat (limited to 'lib/PublicInbox/HTTPD')
-rw-r--r-- | lib/PublicInbox/HTTPD/Async.pm | 16 |
1 files changed, 9 insertions, 7 deletions
diff --git a/lib/PublicInbox/HTTPD/Async.pm b/lib/PublicInbox/HTTPD/Async.pm index 75b3bd50..e03daafa 100644 --- a/lib/PublicInbox/HTTPD/Async.pm +++ b/lib/PublicInbox/HTTPD/Async.pm @@ -37,7 +37,7 @@ sub new { arg => $arg, # arg for $cb end_obj => $end_obj, # like END{}, can ->event_step }, $class; - my $pp = tied *$io; + my $pp = tied *$io; # ProcessPipe $pp->{fh}->blocking(0) // die "$io->blocking(0): $!"; $self->SUPER::new($io, EPOLLIN); } @@ -54,7 +54,7 @@ sub event_step { # and 65536 is the default Linux pipe size my $r = sysread($sock, my $buf, 65536); if ($r) { - $self->{fh}->write($buf); # may call $http->close + $self->{ofh}->write($buf); # may call $http->close # let other clients get some work done, too return if $http->{sock}; # !closed @@ -63,7 +63,7 @@ sub event_step { return; # EPOLLIN means we'll be notified } - # Done! Error handling will happen in $self->{fh}->close + # Done! Error handling will happen in $self->{ofh}->close # called by end_obj->event_step handler delete $http->{forward}; $self->close; # queues end_obj->event_step to be called @@ -71,9 +71,11 @@ sub event_step { } # once this is called, all data we read is passed to the -# to the PublicInbox::HTTP instance ($http) via $fh->write +# to the PublicInbox::HTTP instance ($http) via $ofh->write +# $ofh is typically PublicInbox::HTTP::{Chunked,Identity}, but +# may be PublicInbox::GzipFilter or $PublicInbox::Qspawn::qx_fh sub async_pass { - my ($self, $http, $fh, $bref) = @_; + my ($self, $http, $ofh, $bref) = @_; # In case the client HTTP connection ($http) dies, it # will automatically close this ($self) object. $http->{forward} = $self; @@ -82,10 +84,10 @@ sub async_pass { # This is typically PublicInbox:HTTP::{chunked,identity}_wcb, # but may be PublicInbox::GzipFilter::write. PSGI requires # *_wcb methods respond to ->write (and ->close), not ->print - $fh->write($$bref); + $ofh->write($$bref); $self->{http} = $http; - $self->{fh} = $fh; + $self->{ofh} = $ofh; } # may be called as $forward->close in PublicInbox::HTTP or EOF (event_step) |