daemons: revamp periodic cleanup task

[public-inbox.git] / lib / PublicInbox / Git.pm

diff --git a/lib/PublicInbox/Git.pm b/lib/PublicInbox/Git.pm
index 5ef1db2f8c5da5fd94bf70e57255173f0ba16e3c..3c577ab317b29339271f468f3538345ed14690ca 100644 (file)
--- a/lib/PublicInbox/Git.pm
+++ b/lib/PublicInbox/Git.pm
@@ -12,7 +12,7 @@ use v5.10.1;
 use parent qw(Exporter);
 use POSIX ();
 use IO::Handle; # ->autoflush
-use Errno qw(EINTR EAGAIN);
+use Errno qw(EINTR EAGAIN ENOENT);
 use File::Glob qw(bsd_glob GLOB_NOSORT);
 use File::Spec ();
 use Time::HiRes qw(stat);
@@ -400,7 +400,7 @@ sub cleanup {
        delete $self->{inflight_c};
        _destroy($self, qw(cat_rbuf in out pid));
        _destroy($self, qw(chk_rbuf in_c out_c pid_c err_c));
-       !!($self->{pid} || $self->{pid_c});
+       defined($self->{pid}) || defined($self->{pid_c});
 }
 
 
@@ -523,6 +523,27 @@ sub manifest_entry {
        $ent;
 }
 
+# returns true if there are pending cat-file processes
+sub cleanup_if_unlinked {
+       my ($self) = @_;
+       return cleanup($self) if $^O ne 'linux';
+       # Linux-specific /proc/$PID/maps access
+       # TODO: support this inside git.git
+       my $ret = 0;
+       for my $fld (qw(pid pid_c)) {
+               my $pid = $self->{$fld} // next;
+               open my $fh, '<', "/proc/$pid/maps" or return cleanup($self);
+               while (<$fh>) {
+                       # n.b. we do not restart for unlinked multi-pack-index
+                       # since it's not too huge, and the startup cost may
+                       # be higher.
+                       return cleanup($self) if /\.(?:idx|pack) \(deleted\)$/;
+               }
+               ++$ret;
+       }
+       $ret;
+}
+
 1;
 __END__
 =pod