From: Eric Wong Date: Thu, 24 Aug 2023 12:30:20 +0000 (+0000) Subject: drop unused CidxRecvIbx.pm X-Git-Url: http://git.ipfire.org/cgi-bin/gitweb.cgi?a=commitdiff_plain;h=7b02fcbfad74932c6341baf428cb68784859801f;p=thirdparty%2Fpublic-inbox.git drop unused CidxRecvIbx.pm This is no longer needed since xap_helper performs its functionality while having an optional C++ implementation which is being significantly faster. --- diff --git a/MANIFEST b/MANIFEST index 4bccc8493..918ec2e1f 100644 --- a/MANIFEST +++ b/MANIFEST @@ -163,7 +163,6 @@ lib/PublicInbox/AutoReap.pm lib/PublicInbox/Cgit.pm lib/PublicInbox/CidxComm.pm lib/PublicInbox/CidxLogP.pm -lib/PublicInbox/CidxRecvIbx.pm lib/PublicInbox/CidxXapHelperAux.pm lib/PublicInbox/CmdIPC4.pm lib/PublicInbox/CodeSearch.pm diff --git a/lib/PublicInbox/CidxRecvIbx.pm b/lib/PublicInbox/CidxRecvIbx.pm deleted file mode 100644 index 6add8e54e..000000000 --- a/lib/PublicInbox/CidxRecvIbx.pm +++ /dev/null @@ -1,46 +0,0 @@ -# Copyright (C) all contributors -# License: AGPL-3.0+ -# -# dumps all per-inbox info for -cindex --associate -# integrated into the event loop for signalfd SIGINT handling -package PublicInbox::CidxRecvIbx; -use v5.12; -use parent qw(PublicInbox::DS); -use PublicInbox::Syscall qw(EPOLLIN EPOLLEXCLUSIVE); -use Socket qw(MSG_EOR); -use PublicInbox::CidxDumpIbx; - -sub new { - my ($cls, $cidx, $qry_str) = @_; - my ($op_p, $r_ibx, $sort_w) = delete @$cidx{0..2}; - $op_p // die 'BUG: no $op_p'; - $r_ibx // die 'BUG: no $r_ibx'; - $sort_w // die 'BUG: no $sort_w'; - my $self = bless {}, $cls; - $self->SUPER::new($r_ibx, EPOLLIN|EPOLLEXCLUSIVE); - $self->{cidx} = $cidx; - $self->{sort_w} = $sort_w; - $self->{op_p} = $op_p; # PublicInbox::CidxDumpIbx uses this - $self->{qry_str} = $qry_str; - # writes to this pipe are never longer than POSIX PIPE_BUF, - # so rely on POSIX atomicity guarantees - $sort_w->autoflush(1); - $self; -} - -sub event_step { - my ($self) = @_; - recv($self->{sock}, my $ibx_id, 25, 0) // die "recv: $!"; - return $self->close if $ibx_id eq '' || $self->{cidx}->do_quit; - PublicInbox::CidxDumpIbx::start($self, $ibx_id); -} - -sub close { - my ($self) = @_; - $self->{cidx}->do_quit or - send($self->{op_p}, - "recv_ibx_done $self->{cidx}->{shard}", MSG_EOR); - $self->SUPER::close; # PublicInbox::DS::close -} - -1;