From 97a3b1b79eda65b494e9c01bc99afb4df33a32d5 Mon Sep 17 00:00:00 2001 From: Eric Wong Date: Wed, 13 Jan 2021 19:06:21 -1200 Subject: lei q: reinstate smsg dedupe Now that dedupe is serialization and fork-safe, we can wire it back up in our query results paths. --- lib/PublicInbox/LeiQuery.pm | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) (limited to 'lib/PublicInbox/LeiQuery.pm') diff --git a/lib/PublicInbox/LeiQuery.pm b/lib/PublicInbox/LeiQuery.pm index 1a3e1193..69d2f9a6 100644 --- a/lib/PublicInbox/LeiQuery.pm +++ b/lib/PublicInbox/LeiQuery.pm @@ -26,14 +26,13 @@ sub lei_q { my $sto = $self->_lei_store(1); my $cfg = $self->_lei_cfg(1); my $opt = $self->{opt}; - require PublicInbox::LeiDedupe; - my $dd = PublicInbox::LeiDedupe->new($self); # --local is enabled by default # src: LeiXSearch || LeiSearch || Inbox my @srcs; require PublicInbox::LeiXSearch; require PublicInbox::LeiOverview; + require PublicInbox::LeiDedupe; my $lxs = PublicInbox::LeiXSearch->new; # --external is enabled by default, but allow --no-external @@ -49,8 +48,8 @@ sub lei_q { unshift(@srcs, $sto->search) if $opt->{'local'}; # no forking workers after this - require PublicInbox::LeiOverview; $self->{ovv} = PublicInbox::LeiOverview->new($self); + $self->{dd} = PublicInbox::LeiDedupe->new($self); my %mset_opt = map { $_ => $opt->{$_} } qw(thread limit offset); $mset_opt{asc} = $opt->{'reverse'} ? 1 : 0; $mset_opt{qstr} = join(' ', map {; -- cgit v1.2.3-24-ge0c7