use PublicInbox::Smsg;
our $MIN_PARTIAL_LEN = 14; # for 'XXXXXXXXXX.fsf' msgids gnus generates
use B qw(cstring);
-use PublicInbox::Leak;
# TODO: user-configurable
our @EXT_URL = map { ascii_html($_) } (
$ctx->{again} = \@try_ibxish;
sub {
$ctx->{-wcb} = $_[0]; # HTTP server write callback
- push @{$ctx->{-leak}}, noleak;
partial_enter $ctx;
}
}
lc 'publicinbox.nameIsUrl'} ? ($ctx->{env}) : ();
ext_msg_ALL($ctx) // sub {
$ctx->{-wcb} = $_[0]; # HTTP server write callback
- push @{$ctx->{-leak}}, noleak;
if ($ctx->{env}->{'pi-httpd.app'}) {
require PublicInbox::ConfigIter;
use PublicInbox::Eml;
use PublicInbox::GitAsyncCat;
use Carp qw(carp);
-use PublicInbox::Leak;
our @EXPORT_OK = qw(gzf_maybe);
# Compress::Raw::Zlib uses MAX_MEM_LEVEL (9) while zlib DEF_MEM_LEVEL is 8;
$http->{forward} = $self;
sub {
my ($wcb) = @_; # -httpd provided write callback
- push @{$self->{-leak}}, noleak;
$self->{wcb_args} = [ $code, $res_hdr, $wcb ];
$self->can('async_next')->($http); # start stepping
};
use PublicInbox::Syscall qw(EPOLLIN);
use PublicInbox::InputStream;
use Carp qw(carp confess);
-use PublicInbox::Leak;
# n.b.: we get EAGAIN with public-inbox-httpd, and EINTR on other PSGI servers
use Errno qw(EAGAIN EINTR);
# PublicInbox::HTTP, the chunked_wcb or identity_wcb callback),
# but other HTTP servers are supported:
$env->{'qspawn.wcb'} = $_[0];
- push @{$env->{'pi-httpd.leak'}}, noleak;
start($self, $limiter, \&_yield_start);
}
}
use PublicInbox::Qspawn;
use PublicInbox::ViewVCS;
use PublicInbox::WwwStatic qw(r);
-use PublicInbox::Leak;
# Not using standard mime types since the compressed tarballs are
# special or do not match my /etc/mime.types. Choose what gitweb
@{$ctx->{-try}} = @try;
sub {
$ctx->{env}->{'qspawn.wcb'} = $_[0];
- push @{$ctx->{-leak}}, noleak;
PublicInbox::ViewVCS::do_check_async($ctx, \&ver_check, @try);
}
}
use Time::Local qw(timegm);
use PublicInbox::Smsg qw(subject_normalized);
use PublicInbox::ContentHash qw(content_hash);
-use PublicInbox::Leak;
use constant COLS => 72;
use constant INDENT => ' ';
use constant TCHILD => '` ';
$mid, "</a>>\n\n";
sub {
$ctx->attach($_[0]->([200, delete $ctx->{-res_hdr}]));
- push @{$ctx->{-leak}}, noleak;
$md->begin_mail_diff;
};
}
use parent qw(PublicInbox::GzipFilter);
use PublicInbox::Hval qw(psgi_base_url);
use PublicInbox::Eml;
-use PublicInbox::Leak;
sub referer_match ($) {
my ($ctx) = @_;
if ($ctx->{smsg} = $ctx->{ibx}->smsg_by_mid($ctx->{mid})) {
return sub { # public-inbox-httpd-only
$ctx->{wcb} = $_[0];
- push @{$ctx->{-leak}}, noleak;
scan_attach($ctx);
} if $ctx->{env}->{'pi-httpd.app'};
# generic PSGI:
use URI::Escape qw(uri_escape_utf8);
use autodie qw(fcntl open);
use PublicInbox::Git qw(git_exe);
-use PublicInbox::Leak;
my @EACH_REF = (git_exe, qw(for-each-ref --sort=-creatordate),
"--format=%(HEAD)%00".join('%00', map { "%($_)" }
sub summary ($$) {
my ($ctx, $wcb) = @_;
- push @{$ctx->{-leak}}, noleak;
$ctx->{-wcb} = $wcb; # PublicInbox::HTTP::{Identity,Chunked}
my $tip = $ctx->{qp}->{h}; # same as cgit
if (defined $tip && $tip eq '') {
use PublicInbox::WwwStream;
use URI::Escape qw(uri_escape_utf8);
use PublicInbox::MID qw(mid_escape);
-use PublicInbox::Leak;
sub ibx_entry {
my ($ctx, $ibx, $ce) = @_;
\&list_match_i, $re, $ctx);
sub {
$ctx->{-wcb} = $_[0]; # HTTP server callback
- push @{$ctx->{-leak}}, noleak;
$ctx->{env}->{'pi-httpd.app'} ?
$iter->event_step : $iter->each_section;
}