diff options
Diffstat (limited to 'lib/PublicInbox/Gcf2Client.pm')
| -rw-r--r-- | lib/PublicInbox/Gcf2Client.pm | 7 |
1 files changed, 3 insertions, 4 deletions
diff --git a/lib/PublicInbox/Gcf2Client.pm b/lib/PublicInbox/Gcf2Client.pm index f63a0335..5220c474 100644 --- a/lib/PublicInbox/Gcf2Client.pm +++ b/lib/PublicInbox/Gcf2Client.pm @@ -10,7 +10,7 @@ use PublicInbox::Gcf2; # fails if Inline::C or libgit2-dev isn't available use PublicInbox::Spawn qw(spawn); use Socket qw(AF_UNIX SOCK_STREAM); use PublicInbox::Syscall qw(EPOLLIN); -use PublicInbox::ProcessIO; +use PublicInbox::IO; use autodie qw(socketpair); # fields: @@ -32,11 +32,10 @@ sub new { $opt->{0} = $opt->{1} = $s2; my $cmd = [$^X, $^W ? ('-w') : (), qw[-MPublicInbox::Gcf2 -e PublicInbox::Gcf2::loop]]; - my $pid = spawn($cmd, $env, $opt); - my $sock = PublicInbox::ProcessIO->maybe_new($pid, $s1); + PublicInbox::IO::attach_pid($s1, spawn($cmd, $env, $opt)); $self->{inflight} = []; $self->{epwatch} = \undef; # for Git->cleanup - $self->SUPER::new($sock, EPOLLIN); + $self->SUPER::new($s1, EPOLLIN); } sub gcf2_async ($$$;$) { |