www_stream: description header links to top $INBOX_URL

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

diff --git a/lib/PublicInbox/LeiNoteEvent.pm b/lib/PublicInbox/LeiNoteEvent.pm
index bf15cd26feeb039528157892bb4571255aa5e9ee..6a40ba3967b816d6310905d751520ded7915e180 100644 (file)
--- a/lib/PublicInbox/LeiNoteEvent.pm
+++ b/lib/PublicInbox/LeiNoteEvent.pm
@@ -14,8 +14,8 @@ sub flush_lei ($) {
        my ($lei) = @_;
        if (my $lne = delete $lei->{cfg}->{-lei_note_event}) {
                $lne->wq_close(1, undef, $lei); # runs _lei_wq_eof;
-       } else { # lms_clear_src calls only:
-               my $wait = $lei->{sto}->ipc_do('done');
+       } elsif ($lei->{sto}) { # lms_clear_src calls only:
+               $lei->sto_done_request;
        }
 }
 
@@ -74,7 +74,7 @@ sub lei_note_event {
        my $err = $lms->arg2folder($lei, [ $folder ]);
        return if $err->{fail};
        undef $lms;
-       my $state = $cfg->get_1("watch.$folder", 'state') // 'pause';
+       my $state = $cfg->get_1("watch.$folder", 'state') // 'tag-rw';
        return if $state eq 'pause';
        $lei->ale; # prepare
        $sto->write_prepare($lei);
@@ -117,7 +117,7 @@ sub lne_done_wait {
 sub _lei_wq_eof { # EOF callback for main lei daemon
        my ($lei) = @_;
        my $lne = delete $lei->{lne} or return $lei->fail;
-       my $wait = $lei->{sto}->ipc_do('done');
+       $lei->sto_done_request;
        $lne->wq_wait_old(\&lne_done_wait, $lei);
 }