about summary refs log tree commit homepage
path: root/lib/PublicInbox/LeiToMail.pm
diff options
context:
space:
mode:
Diffstat (limited to 'lib/PublicInbox/LeiToMail.pm')
-rw-r--r--lib/PublicInbox/LeiToMail.pm10
1 files changed, 3 insertions, 7 deletions
diff --git a/lib/PublicInbox/LeiToMail.pm b/lib/PublicInbox/LeiToMail.pm
index 6f386b10..7e821646 100644
--- a/lib/PublicInbox/LeiToMail.pm
+++ b/lib/PublicInbox/LeiToMail.pm
@@ -11,7 +11,6 @@ use PublicInbox::Lock;
 use PublicInbox::ProcessPipe;
 use PublicInbox::Spawn qw(which spawn popen_rd);
 use PublicInbox::LeiDedupe;
-use PublicInbox::Git;
 use PublicInbox::GitAsyncCat;
 use PublicInbox::PktOp qw(pkt_do);
 use Symbol qw(gensym);
@@ -642,18 +641,15 @@ sub poke_dst {
 }
 
 sub write_mail { # via ->wq_io_do
-        my ($self, $git_dir, $smsg) = @_;
-        my $git = $self->{"$$\0$git_dir"} //= PublicInbox::Git->new($git_dir);
-        git_async_cat($git, $smsg->{blob}, \&git_to_mail,
+        my ($self, $smsg) = @_;
+        git_async_cat($self->{lei}->{ale}->git, $smsg->{blob}, \&git_to_mail,
                                 [$self->{wcb}, $smsg]);
 }
 
 sub wq_atexit_child {
         my ($self) = @_;
         delete $self->{wcb};
-        for my $git (delete @$self{grep(/\A$$\0/, keys %$self)}) {
-                $git->async_wait_all;
-        }
+        $self->{lei}->{ale}->git->async_wait_all;
         $SIG{__WARN__} = 'DEFAULT';
 }