lei: require Socket::MsgHdr or Inline::C, drop oneshot

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

diff --git a/lib/PublicInbox/LeiStore.pm b/lib/PublicInbox/LeiStore.pm
index a7a0ebef097d41f68f1adfe0b0de4b656d1b702b..af5edbc24732817eb3b2dcfd51b4d9da2dacc17d 100644 (file)
--- a/lib/PublicInbox/LeiStore.pm
+++ b/lib/PublicInbox/LeiStore.pm
@@ -431,20 +431,15 @@ sub write_prepare {
                my $d = $lei->store_path;
                $self->ipc_lock_init("$d/ipc.lock");
                substr($d, -length('/lei/store'), 10, '');
-               my $err_pipe;
-               unless ($lei->{oneshot}) {
-                       pipe(my ($r, $w)) or die "pipe: $!";
-                       $err_pipe = [ $r, $w ];
-               }
+               pipe(my ($r, $w)) or die "pipe: $!";
+               my $err_pipe = [ $r, $w ];
                # Mail we import into lei are private, so headers filtered out
                # by -mda for public mail are not appropriate
                local @PublicInbox::MDA::BAD_HEADERS = ();
                $self->ipc_worker_spawn("lei/store $d", $lei->oldset,
                                        { lei => $lei, err_pipe => $err_pipe });
-               if ($err_pipe) {
-                       require PublicInbox::LeiStoreErr;
-                       PublicInbox::LeiStoreErr->new($err_pipe->[0], $lei);
-               }
+               require PublicInbox::LeiStoreErr;
+               PublicInbox::LeiStoreErr->new($err_pipe->[0], $lei);
        }
        $lei->{sto} = $self;
 }