X-Git-Url: http://www.git.stargrave.org/?a=blobdiff_plain;f=lib%2FPublicInbox%2FNNTPdeflate.pm;h=352d4842834816a0df1523575aa4a6ea7f3326b3;hb=1c3e60b66e01df89afdf74990a849a5a7386f9c7;hp=c143488f14bd9010bb174bd7736194719f3f302e;hpb=d327141cee62b2efec2c859a237023d7ff9e71a5;p=public-inbox.git
diff --git a/lib/PublicInbox/NNTPdeflate.pm b/lib/PublicInbox/NNTPdeflate.pm
index c143488f..352d4842 100644
--- a/lib/PublicInbox/NNTPdeflate.pm
+++ b/lib/PublicInbox/NNTPdeflate.pm
@@ -1,4 +1,4 @@
-# Copyright (C) 2019 all contributors
+# Copyright (C) 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,
@@ -50,11 +48,10 @@ sub enable {
my ($in, $err) = Compress::Raw::Zlib::Inflate->new(%IN_OPT);
if ($err != Z_OK) {
$self->err("Inflate->new failed: $err");
- $self->res('403 Unable to activate compression');
+ $self->write(\"403 Unable to activate compression\r\n");
return;
}
- unlock_hash(%$self);
- $self->res('206 Compression active');
+ $self->write(\"206 Compression active\r\n");
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);