lei: use standard warn() in more places

[public-inbox.git] / lib / PublicInbox / LeiRemote.pm

diff --git a/lib/PublicInbox/LeiRemote.pm b/lib/PublicInbox/LeiRemote.pm
index 8d4ffed0c03b9bc6f75bc64a784f34165b71c107..7782aa9dbfa132bef82301130a3450fd5d6a8b30 100644 (file)
--- a/lib/PublicInbox/LeiRemote.pm
+++ b/lib/PublicInbox/LeiRemote.pm
@@ -28,7 +28,7 @@ sub _each_mboxrd_eml { # callback for MboxReader->mboxrd
        my $xoids = $lei->{ale}->xoids_for($eml, 1);
        my $smsg = bless {}, 'PublicInbox::Smsg';
        if ($lei->{sto} && !$xoids) { # memoize locally
-               my $res = $lei->{sto}->ipc_do('add_eml', $eml);
+               my $res = $lei->{sto}->wq_do('add_eml', $eml);
                $smsg = $res if ref($res) eq ref($smsg);
        }
        $smsg->{blob} //= $xoids ? (keys(%$xoids))[0]
@@ -56,7 +56,7 @@ sub mset {
        my $err = waitpid($pid, 0) == $pid ? undef
                                        : "BUG: waitpid($cmd): $!";
        @$reap = (); # cancel OnDestroy
-       my $wait = $self->{lei}->{sto}->ipc_do('done');
+       my $wait = $self->{lei}->{sto}->wq_do('done');
        die $err if $err;
        $self; # we are the mset (and $ibx, and $self)
 }
@@ -75,7 +75,7 @@ sub smsg_eml {
        if (my $bref = $self->{lei}->ale->git->cat_file($smsg->{blob})) {
                return PublicInbox::Eml->new($bref);
        }
-       $self->{lei}->err("E: $self->{uri} $smsg->{blob} gone <$smsg->{mid}>");
+       warn("E: $self->{uri} $smsg->{blob} gone <$smsg->{mid}>\n");
        undef;
 }