diff options
author | Eric Wong <e@80x24.org> | 2021-03-31 07:45:51 +0000 |
---|---|---|
committer | Eric Wong <e@80x24.org> | 2021-03-31 22:27:19 +0000 |
commit | 8fa51e510fbe629a05c2da82482053f77ece7de5 (patch) | |
tree | c25e83a48644e0665595a80343b352c083f84159 /lib/PublicInbox/LeiInput.pm | |
parent | b9dfb42d9f504c36693377f6beea98e954e7c5a9 (diff) | |
download | public-inbox-8fa51e510fbe629a05c2da82482053f77ece7de5.tar.gz |
No point in sending a command for every input when a single one will do. We'll also trigger LeiStore->done sooner in the worker rather than later.
Diffstat (limited to 'lib/PublicInbox/LeiInput.pm')
-rw-r--r-- | lib/PublicInbox/LeiInput.pm | 9 |
1 files changed, 9 insertions, 0 deletions
diff --git a/lib/PublicInbox/LeiInput.pm b/lib/PublicInbox/LeiInput.pm index 505b73ff..40d71f9e 100644 --- a/lib/PublicInbox/LeiInput.pm +++ b/lib/PublicInbox/LeiInput.pm @@ -5,6 +5,7 @@ package PublicInbox::LeiInput; use strict; use v5.10.1; +use PublicInbox::DS; sub check_input_format ($;$) { my ($lei, $files) = @_; @@ -165,6 +166,14 @@ $input is `eml', not --in-format=$in_fmt $self->{inputs} = $inputs; } +sub process_inputs { + my ($self) = @_; + for my $input (@{$self->{inputs}}) { + $self->input_path_url($input); + } + my $wait = $self->{lei}->{sto}->ipc_do('done') if $self->{lei}->{sto}; +} + sub input_only_atfork_child { my ($self) = @_; my $lei = $self->{lei}; |