http: async getline supports push_back_read

Sometimes we need to read something to ensure it's a successful
response.

1 files changed, 17 insertions, 1 deletions

diff --git a/lib/PublicInbox/HTTPD/Async.pm b/lib/PublicInbox/HTTPD/Async.pm
index ceba738e..8f3a6a09 100644
--- a/lib/PublicInbox/HTTPD/Async.pm
+++ b/lib/PublicInbox/HTTPD/Async.pm
@@ -26,7 +26,23 @@ sub event_read { $_[0]->{cb}->() }
 sub event_hup { $_[0]->{cb}->() }
 sub event_err { $_[0]->{cb}->() }
 sub sysread { shift->{sock}->sysread(@_) }
-sub getline { $_[0]->{sock}->getline };
+
+sub getline {
+        my ($self) = @_;
+        die 'getline called without $/ ref' unless ref $/;
+        while (1) {
+                my $ret = $self->read(8192); # Danga::Socket::read
+                return $$ret if defined $ret;
+
+                return unless $!{EAGAIN} || $!{EINTR};
+
+                # in case of spurious wakeup, hopefully we never hit this
+                my $vin = '';
+                vec($vin, $self->{fd}, 1) = 1;
+                my $n;
+                do { $n = select($vin, undef, undef, undef) } until $n;
+        }
+}
 
 sub close {
         my $self = shift;