X-Git-Url: http://www.git.stargrave.org/?a=blobdiff_plain;f=lib%2FPublicInbox%2FNNTPdeflate.pm;h=02af935f0dfc3be4dcea4f884b5eb83bf559b198;hb=0d38f65c490466837ae091afa7a7b6f59d04ce7c;hp=c143488f14bd9010bb174bd7736194719f3f302e;hpb=d327141cee62b2efec2c859a237023d7ff9e71a5;p=public-inbox.git diff --git a/lib/PublicInbox/NNTPdeflate.pm b/lib/PublicInbox/NNTPdeflate.pm index c143488f..02af935f 100644 --- a/lib/PublicInbox/NNTPdeflate.pm +++ b/lib/PublicInbox/NNTPdeflate.pm @@ -1,4 +1,4 @@ -# Copyright (C) 2019 all contributors +# Copyright (C) 2019-2020 all contributors # License: AGPL-3.0+ # RFC 8054 NNTP COMPRESS DEFLATE implementation @@ -16,11 +16,9 @@ # efficient in terms of server memory usage. package PublicInbox::NNTPdeflate; use strict; -use warnings; use 5.010_001; -use base qw(PublicInbox::NNTP); +use parent qw(PublicInbox::NNTP); use Compress::Raw::Zlib; -use Hash::Util qw(unlock_hash); # dependency of fields for perl 5.10+, anyways my %IN_OPT = ( -Bufsize => PublicInbox::NNTP::LINE_MAX, @@ -53,7 +51,6 @@ sub enable { $self->res('403 Unable to activate compression'); return; } - unlock_hash(%$self); $self->res('206 Compression active'); bless $self, $class; $self->{zin} = $in; @@ -62,7 +59,6 @@ sub enable { # overrides PublicInbox::NNTP::compressed sub compressed { 1 } -# $_[1] may be a reference or not sub do_read ($$$$) { my ($self, $rbuf, $len, $off) = @_; @@ -72,6 +68,16 @@ sub do_read ($$$$) { $doff = length($dbuf); my $r = PublicInbox::DS::do_read($self, \$dbuf, $len, $doff) or return; + # Workaround inflate bug appending to OOK scalars: + # + # We only have $off if the client is pipelining, and pipelining + # is where our substr() OOK optimization in event_step makes sense. + if ($off) { + my $copy = $$rbuf; + undef $$rbuf; + $$rbuf = $copy; + } + # assert(length($$rbuf) == $off) as far as NNTP.pm is concerned # -ConsumeInput is true, so $dbuf is automatically emptied my $err = $zin->inflate($dbuf, $rbuf);