From ae546078c5696ac73ad9f48c2c90163febb4a246 Mon Sep 17 00:00:00 2001 From: Eric Wong Date: Sat, 22 Aug 2020 06:06:25 +0000 Subject: searchidx: index THREADID in Xapian This is the `tid' column from over.sqlite3; and will be used for IMAP and JMAP search (among other things). --- lib/PublicInbox/SearchIdxShard.pm | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) (limited to 'lib/PublicInbox/SearchIdxShard.pm') diff --git a/lib/PublicInbox/SearchIdxShard.pm b/lib/PublicInbox/SearchIdxShard.pm index c0f8be89..f23d23d0 100644 --- a/lib/PublicInbox/SearchIdxShard.pm +++ b/lib/PublicInbox/SearchIdxShard.pm @@ -68,8 +68,8 @@ sub shard_worker_loop ($$$$$) { } else { chomp $line; # n.b. $mid may contain spaces(!) - my ($to_read, $bytes, $num, $blob, $ds, $ts, $mid) = - split(/ /, $line, 7); + my ($to_read, $bytes, $num, $blob, $ds, $ts, $tid, $mid) + = split(/ /, $line, 8); $self->begin_txn_lazy; my $n = read($r, my $msg, $to_read) or die "read: $!\n"; $n == $to_read or die "short read: $n != $to_read\n"; @@ -79,6 +79,7 @@ sub shard_worker_loop ($$$$$) { num => $num + 0, blob => $blob, mid => $mid, + tid => $tid, ds => $ds, ts => $ts, }, 'PublicInbox::Smsg'; @@ -93,7 +94,7 @@ sub index_raw { if (my $w = $self->{w}) { # mid must be last, it can contain spaces (but not LF) print $w join(' ', @$smsg{qw(raw_bytes bytes - num blob ds ts mid)}), + num blob ds ts tid mid)}), "\n", $$msgref or die "failed to write shard $!\n"; } else { if ($eml) { -- cgit v1.2.3-24-ge0c7