]> Sergey Matveev's repositories - public-inbox.git/blobdiff - lib/PublicInbox/ExtSearchIdx.pm
rename {pi_config} fields to {pi_cfg}
[public-inbox.git] / lib / PublicInbox / ExtSearchIdx.pm
index 819c7903e108b1c6c1b64d31b1e075fa1f5ac1d4..c82d163349a755094193fb5916c617aae76fa0e1 100644 (file)
@@ -125,17 +125,16 @@ sub do_xpost ($$) {
        if (my $new_smsg = $req->{new_smsg}) { # 'm' on cross-posted message
                my $xnum = $req->{xnum};
                $self->{oidx}->add_xref3($docid, $xnum, $oid, $eidx_key);
-               $idx->shard_add_eidx_info($docid, $oid, $xibx, $eml);
+               $idx->shard_add_eidx_info($docid, $eidx_key, $eml);
                check_batch_limit($req);
        } else { # 'd'
                my $rm_eidx_info;
                my $nr = $self->{oidx}->remove_xref3($docid, $oid, $eidx_key,
                                                        \$rm_eidx_info);
                if ($nr == 0) {
-                       $idx->shard_remove($oid, $docid);
+                       $idx->shard_remove($docid);
                } elsif ($rm_eidx_info) {
-                       $idx->shard_remove_eidx_info($docid, $oid, $eidx_key,
-                                                       $eml);
+                       $idx->shard_remove_eidx_info($docid, $eidx_key, $eml);
                }
        }
 }
@@ -333,13 +332,11 @@ DELETE FROM xref3 WHERE docid = ? AND ibx_id = ?
        if (@$remain) {
                for my $oid (@oid) {
                        warn "I: unref #$docid $eidx_key $oid\n";
-                       $idx->shard_remove_eidx_info($docid, $oid, $eidx_key);
+                       $idx->shard_remove_eidx_info($docid, $eidx_key);
                }
        } else {
-               for my $oid (@oid) {
-                       warn "I: remove #$docid $eidx_key $oid\n";
-                       $idx->shard_remove($oid, $docid);
-               }
+               warn "I: remove #$docid $eidx_key @oid\n";
+               $idx->shard_remove($docid);
        }
 }