From: Eric Wong <e@80x24.org>
To: meta@public-inbox.org
Subject: [PATCH 07/15] git: share unlinked pack checking code with gcf2
Date: Thu, 30 Nov 2023 11:41:00 +0000 [thread overview]
Message-ID: <20231130114109.2577708-8-e@80x24.org> (raw)
In-Reply-To: <20231130114109.2577708-1-e@80x24.org>
It saves some code in case we keep libgit2 around.
---
lib/PublicInbox/Gcf2.pm | 16 ++++------------
lib/PublicInbox/Git.pm | 27 ++++++++++++++-------------
2 files changed, 18 insertions(+), 25 deletions(-)
diff --git a/lib/PublicInbox/Gcf2.pm b/lib/PublicInbox/Gcf2.pm
index dcbb201d..78392990 100644
--- a/lib/PublicInbox/Gcf2.pm
+++ b/lib/PublicInbox/Gcf2.pm
@@ -9,7 +9,7 @@ use PublicInbox::Spawn qw(which run_qx); # may set PERL_INLINE_DIRECTORY
use Fcntl qw(SEEK_SET);
use Time::HiRes qw(clock_gettime CLOCK_MONOTONIC);
use IO::Handle; # autoflush
-use PublicInbox::Git;
+use PublicInbox::Git qw($ck_unlinked_packs);
use PublicInbox::Lock;
use autodie qw(close open seek truncate);
@@ -86,16 +86,6 @@ sub add_alt ($$) {
1;
}
-sub have_unlinked_files () {
- # FIXME: port gcf2-like over to git.git so we won't need to
- # deal with libgit2
- return 1 if $^O ne 'linux';
- if (my $s = PublicInbox::IO::try_cat("/proc/$$/maps")) {
- return 1 if /\.(?:idx|pack) \(deleted\)/s;
- }
- undef;
-}
-
# Usage: $^X -MPublicInbox::Gcf2 -e PublicInbox::Gcf2::loop [EXPIRE-TIMEOUT]
# (see lib/PublicInbox/Gcf2Client.pm)
sub loop (;$) {
@@ -104,6 +94,7 @@ sub loop (;$) {
my (%seen, $check_at);
STDERR->autoflush(1);
STDOUT->autoflush(1);
+ my $pid = $$;
while (<STDIN>) {
chomp;
@@ -130,7 +121,8 @@ sub loop (;$) {
$check_at //= $now + $exp;
if ($now > $check_at) {
undef $check_at;
- if (have_unlinked_files()) {
+ if (!$ck_unlinked_packs ||
+ $ck_unlinked_packs->($pid)) {
$gcf2 = new();
%seen = ();
}
diff --git a/lib/PublicInbox/Git.pm b/lib/PublicInbox/Git.pm
index 235a35cd..9c4d938e 100644
--- a/lib/PublicInbox/Git.pm
+++ b/lib/PublicInbox/Git.pm
@@ -24,7 +24,8 @@ use Carp qw(croak carp);
use PublicInbox::SHA qw(sha_all);
our %HEXLEN2SHA = (40 => 1, 64 => 256);
our %OFMT2HEXLEN = (sha1 => 40, sha256 => 64);
-our @EXPORT_OK = qw(git_unquote git_quote %HEXLEN2SHA %OFMT2HEXLEN);
+our @EXPORT_OK = qw(git_unquote git_quote %HEXLEN2SHA %OFMT2HEXLEN
+ $ck_unlinked_packs);
our $in_cleanup;
our $async_warn; # true in read-only daemons
@@ -597,27 +598,27 @@ sub manifest_entry {
$ent;
}
+our $ck_unlinked_packs = $^O eq 'linux' ? sub {
+ # FIXME: port gcf2-like over to git.git so we won't need to
+ # deal with libgit2
+ my $s = try_cat "/proc/$_[0]/maps";
+ $s =~ /\.(?:idx|pack) \(deleted\)/s ? 1 : undef;
+} : undef;
+
# returns true if there are pending cat-file processes
sub cleanup_if_unlinked {
my ($self) = @_;
- return cleanup($self, 1) if $^O ne 'linux';
+ $ck_unlinked_packs or return cleanup($self, 1);
# Linux-specific /proc/$PID/maps access
# TODO: support this inside git.git
- my $ret = 0;
+ my $nr_live = 0;
for my $obj ($self, ($self->{ck} // ())) {
my $sock = $obj->{sock} // next;
my $pid = $sock->attached_pid // next;
- open my $fh, '<', "/proc/$pid/maps" or return cleanup($self, 1);
- 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.
- /\.(?:idx|pack) \(deleted\)$/ and
- return cleanup($self, 1);
- }
- ++$ret;
+ $ck_unlinked_packs->($pid) and return cleanup($self, 1);
+ ++$nr_live;
}
- $ret;
+ $nr_live;
}
sub event_step {
next prev parent reply other threads:[~2023-11-30 11:41 UTC|newest]
Thread overview: 20+ messages / expand[flat|nested] mbox.gz Atom feed top
2023-11-30 11:40 [PATCH 00/15] various cindex fixes + speedups Eric Wong
2023-11-30 11:40 ` [PATCH 01/15] cindex: fix store_repo+repo_stored on no-op Eric Wong
2023-11-30 11:40 ` [PATCH 02/15] codesearch: allow inbox count to exceed matches Eric Wong
2023-11-30 11:40 ` [PATCH 03/15] config: reject newlines consistently in dir names Eric Wong
2023-11-30 11:40 ` [PATCH 04/15] cindex: only create {-cidx_err} field on failures Eric Wong
2023-11-30 11:40 ` [PATCH 05/15] cindex: keep batch pipe for pruning SHA-256 repos Eric Wong
2023-11-30 11:40 ` [PATCH 06/15] cindex: store extensions.objectFormat with repo data Eric Wong
2023-11-30 21:36 ` Eric Wong
2023-11-30 11:41 ` Eric Wong [this message]
2023-11-30 11:41 ` [PATCH 08/15] cindex: skip getpid guard for most OnDestroy use Eric Wong
2023-11-30 11:41 ` [PATCH 09/15] spawn: drop IO layer support from redirects Eric Wong
2023-11-30 11:41 ` [PATCH 10/15] cindex: speed up initial scan setup phase Eric Wong
2023-11-30 11:41 ` [PATCH 11/15] inbox: expire resources more aggressively Eric Wong
2023-11-30 11:41 ` [PATCH 12/15] git_async_cat: use git from "all" extindex if possible Eric Wong
2023-11-30 11:41 ` [PATCH 13/15] www_listing: support publicInbox.nameIsUrl Eric Wong
2023-12-01 1:29 ` Kyle Meyer
2023-12-01 2:01 ` [PATCH] doc: config: fix grammar for nameIsUrl Eric Wong
2023-11-30 11:41 ` [PATCH 14/15] inbox: shrink data structures for publicinbox.*.hide Eric Wong
2023-11-30 11:41 ` [PATCH 15/15] codesearch: use retry_reopen for WWW Eric Wong
2023-11-30 21:40 ` [PATCH v2] " Eric Wong
Reply instructions:
You may reply publicly to this message via plain-text email
using any one of the following methods:
* Save the following mbox file, import it into your mail client,
and reply-to-all from there: mbox
Avoid top-posting and favor interleaved quoting:
https://en.wikipedia.org/wiki/Posting_style#Interleaved_style
List information: https://public-inbox.org/README
* Reply using the --to, --cc, and --in-reply-to
switches of git-send-email(1):
git send-email \
--in-reply-to=20231130114109.2577708-8-e@80x24.org \
--to=e@80x24.org \
--cc=meta@public-inbox.org \
/path/to/YOUR_REPLY
https://kernel.org/pub/software/scm/git/docs/git-send-email.html
* If your mail client supports setting the In-Reply-To header
via mailto: links, try the mailto: link
Be sure your reply has a Subject: header at the top and a blank line
before the message body.
This is a public inbox, see mirroring instructions
for how to clone and mirror all data and code used for this inbox;
as well as URLs for read-only IMAP folder(s) and NNTP newsgroup(s).