($num - 1) * $nshard + $num % $nshard + 1;
}
-sub msg_keywords {
+sub _msg_kw { # retry_reopen callback
my ($self, $num) = @_; # num_or_mitem
my $xdb = $self->xdb; # set {nshard};
my $docid = ref($num) ? $num->get_docid : num2docid($self, $num);
wantarray ? sort(keys(%$kw)) : $kw;
}
-# returns undef if blob is unknown
-sub oid_keywords {
- my ($self, $oidhex) = @_;
- my @num = $self->over->blob_exists($oidhex) or return;
+sub msg_keywords {
+ my ($self, $num) = @_; # num_or_mitem
+ $self->retry_reopen(\&_msg_kw, $num);
+}
+
+sub _oid_kw { # retry_reopen callback
+ my ($self, $nums) = @_;
my $xdb = $self->xdb; # set {nshard};
my %kw;
- for my $num (@num) { # there should only be one...
+ for my $num (@$nums) { # there should only be one...
my $doc = $xdb->get_document(num2docid($self, $num));
my $x = xap_terms('K', $doc);
%kw = (%kw, %$x);
\%kw;
}
-# lookup keywords+labels for external messages
-sub xsmsg_vmd {
+# returns undef if blob is unknown
+sub oid_keywords {
+ my ($self, $oidhex) = @_;
+ my @num = $self->over->blob_exists($oidhex) or return;
+ $self->retry_reopen(\&_oid_kw, \@num);
+}
+
+sub _xsmsg_vmd { # retry_reopen
my ($self, $smsg, $want_label) = @_;
- return if $smsg->{kw};
my $xdb = $self->xdb; # set {nshard};
my (%kw, %L, $doc, $x);
$kw{flagged} = 1 if delete($smsg->{lei_q_tt_flagged});
$smsg->{L} = [ sort keys %L ] if scalar(keys(%L));
}
+# lookup keywords+labels for external messages
+sub xsmsg_vmd {
+ my ($self, $smsg, $want_label) = @_;
+ return if $smsg->{kw}; # already set by LeiXSearch->mitem_kw
+ $self->retry_reopen(\&_xsmsg_vmd, $smsg, $want_label);
+}
+
# when a message has no Message-IDs at all, this is needed for
# unsent Draft messages, at least
sub content_key ($) {
# called by PublicInbox::Search::xdb (usually via ->mset)
sub xdb_shards_flat { @{$_[0]->{shards_flat} // []} }
-sub mitem_kw ($$;$) {
- my ($smsg, $mitem, $flagged) = @_;
- my $kw = xap_terms('K', my $doc = $mitem->get_document);
+sub _mitem_kw { # retry_reopen callback
+ my ($srch, $smsg, $mitem, $flagged) = @_;
+ my $doc = $mitem->get_document;
+ my $kw = xap_terms('K', $doc);
$kw->{flagged} = 1 if $flagged;
+ my $L = xap_terms('L', $doc);
# we keep the empty {kw} array here to prevent expensive work in
# ->xsmsg_vmd, _unbless_smsg will clobber it iff it's empty
$smsg->{kw} = [ sort keys %$kw ];
- my $L = xap_terms('L', $doc);
$smsg->{L} = [ sort keys %$L ] if scalar(keys %$L);
}
+sub mitem_kw ($$$;$) {
+ my ($srch, $smsg, $mitem, $flagged) = @_;
+ $srch->retry_reopen(\&_mitem_kw, $smsg, $mitem, $flagged);
+}
+
# like over->get_art
sub smsg_for {
my ($self, $mitem) = @_;
my $smsg = $ibx->over->get_art($num);
return if $smsg->{bytes} == 0; # external message
if ($ibx->can('msg_keywords')) {
- mitem_kw($smsg, $mitem);
+ mitem_kw($self, $smsg, $mitem);
}
$smsg;
}
my $mitem = delete $n2item{$n};
next if $smsg->{bytes} == 0;
if ($mitem && $can_kw) {
- mitem_kw($smsg, $mitem, $fl);
+ mitem_kw($srch, $smsg, $mitem,
+ $fl);
} elsif ($mitem && $fl) {
# call ->xsmsg_vmd, later
$smsg->{lei_q_tt_flagged} = 1;
my $mitem = $items[$i++];
my $smsg = $over->get_art($n) or next;
next if $smsg->{bytes} == 0;
- mitem_kw($smsg, $mitem, $fl) if $can_kw;
+ mitem_kw($srch, $smsg, $mitem, $fl) if $can_kw;
$each_smsg->($smsg, $mitem);
}
}
our @EXPORT_OK = qw(retry_reopen int_val get_pct xap_terms);
use List::Util qw(max);
use POSIX qw(strftime);
+use Carp ();
# values for searching, changing the numeric value breaks
# compatibility with old indices (so don't change them it)
# Exception: The revision being read has been discarded -
# you should call Xapian::Database::reopen()
if (ref($@) =~ /\bDatabaseModifiedError\b/) {
- warn "reopen try #$i on $@\n";
+ warn "# reopen try #$i on $@\n";
reopen($self);
} else {
# let caller decide how to spew, because ExtMsg queries
# get wonky and trigger:
# "something terrible happened at .../Xapian/Enquire.pm"
- die;
+ Carp::croak($@);
}
}
- die "Too many Xapian database modifications in progress\n";
+ Carp::croak("Too many Xapian database modifications in progress\n");
}
sub _do_enquire {