about summary refs log tree commit homepage
path: root/lib/PublicInbox/ParentPipe.pm
diff options
context:
space:
mode:
Diffstat (limited to 'lib/PublicInbox/ParentPipe.pm')
-rw-r--r--lib/PublicInbox/ParentPipe.pm5
1 files changed, 4 insertions, 1 deletions
diff --git a/lib/PublicInbox/ParentPipe.pm b/lib/PublicInbox/ParentPipe.pm
index 6ef51c1a..2e2abb5f 100644
--- a/lib/PublicInbox/ParentPipe.pm
+++ b/lib/PublicInbox/ParentPipe.pm
@@ -19,6 +19,9 @@ sub new ($$$) {
 }
 
 # master process died, time to call worker_quit ourselves
-sub event_step { $_[0]->{cb}->($_[0]) }
+sub event_step {
+        $_[0]->close; # PublicInbox::DS::close
+        $_[0]->{cb}->();
+}
 
 1;