diff options
Diffstat (limited to 'lib/PublicInbox/LeiImport.pm')
| -rw-r--r-- | lib/PublicInbox/LeiImport.pm | 20 |
1 files changed, 7 insertions, 13 deletions
diff --git a/lib/PublicInbox/LeiImport.pm b/lib/PublicInbox/LeiImport.pm index 991c84f2..9da6b7f9 100644 --- a/lib/PublicInbox/LeiImport.pm +++ b/lib/PublicInbox/LeiImport.pm @@ -58,9 +58,13 @@ sub net_merge_complete { # callback used by LeiAuth $self->wq_close(1); } -sub import_start { - my ($lei) = @_; - my $self = $lei->{imp}; +sub lei_import { # the main "lei import" method + my ($lei, @inputs) = @_; + my $sto = $lei->_lei_store(1); + $sto->write_prepare($lei); + my $self = bless {}, __PACKAGE__; + $self->{-import_kw} = $lei->{opt}->{kw} // 1; + $self->prepare_inputs($lei, \@inputs) or return; $lei->ale; # initialize for workers to read my $j = $lei->{opt}->{jobs} // scalar(@{$self->{inputs}}) || 1; if (my $net = $lei->{net}) { @@ -79,16 +83,6 @@ sub import_start { while ($op && $op->{sock}) { $op->event_step } } -sub lei_import { # the main "lei import" method - my ($lei, @inputs) = @_; - my $sto = $lei->_lei_store(1); - $sto->write_prepare($lei); - my $self = $lei->{imp} = bless {}, __PACKAGE__; - $self->{-import_kw} = $lei->{opt}->{kw} // 1; - $self->prepare_inputs($lei, \@inputs) or return; - import_start($lei); -} - no warnings 'once'; *ipc_atfork_child = \&PublicInbox::LeiInput::input_only_atfork_child; |