lib/PublicInbox/MiscSearch.pm | 35 ----------------------------------- lib/PublicInbox/SearchIdxShard.pm | 10 ---------- diff --git a/lib/PublicInbox/MiscSearch.pm b/lib/PublicInbox/MiscSearch.pm index 6b575b0da083246bbc2c0e0fe7a9104a1af2bed4..c6d2a062a66865e8774aee9c8bee9ddf248c8db5 100644 --- a/lib/PublicInbox/MiscSearch.pm +++ b/lib/PublicInbox/MiscSearch.pm @@ -81,41 +81,6 @@ $opt->{relevance} = 1 unless exists $opt->{relevance}; retry_reopen($self, \&misc_enquire_once, $qr, $opt); } -sub ibx_matches_once { # retry_reopen callback - my ($self, $qr, $by_newsgroup) = @_; - # double in case no newsgroups are configured: - my $limit = scalar(keys %$by_newsgroup) * 2; - my $opt = { limit => $limit, offset => 0, relevance => -1 }; - my $ret = {}; # newsgroup => $ibx of matches - while (1) { - my $mset = misc_enquire_once($self, $qr, $opt); - for my $mi ($mset->items) { - my ($eidx_key) = xap_terms('Q', $mi->get_document); - if (defined($eidx_key)) { - if (my $ibx = $by_newsgroup->{$eidx_key}) { - $ret->{$eidx_key} = $ibx; - } - } else { - warn <get_docid} has no `Q' (eidx_key) term -EOF - } - } - my $nr = $mset->size; - return $ret if $nr < $limit; - $opt->{offset} += $nr; - } -} - -# returns a newsgroup => PublicInbox::Inbox mapping -sub newsgroup_matches { - my ($self, $qs, $pi_cfg) = @_; - my $qp = $self->{qp} //= mi_qp_new($self); - $qs .= ' type:inbox'; - my $qr = $qp->parse_query($qs, $PublicInbox::Search::QP_FLAGS); - retry_reopen($self, \&ibx_matches_once, $qr, $pi_cfg->{-by_newsgroup}); -} - sub ibx_data_once { my ($self, $ibx) = @_; my $xdb = $self->{xdb}; diff --git a/lib/PublicInbox/SearchIdxShard.pm b/lib/PublicInbox/SearchIdxShard.pm index 8635f5858a8ac37b14c6707b412ce69a6d828d08..000abd9413b5ba5159f2d540f8344805564c6ad9 100644 --- a/lib/PublicInbox/SearchIdxShard.pm +++ b/lib/PublicInbox/SearchIdxShard.pm @@ -75,14 +75,4 @@ $self->ipc_do('idx_close'); $self->ipc_worker_stop; } -sub shard_over_check { - my ($self, $over) = @_; - if ($self->{-ipc_req} && $over->{dbh}) { - # can't send DB handles over IPC, and use read-only to avoid - # create_tables lock conflict: - $over = PublicInbox::Over->new($over->{dbh}->sqlite_db_filename) - } - $self->ipc_do('over_check', $over); -} - 1;