X-Git-Url: http://www.git.stargrave.org/?a=blobdiff_plain;f=lib%2FPublicInbox%2FV2Writable.pm;h=bdde76bbbf54702007d5f27a8c0e05777d67d06c;hb=fa53ccda7a0e4e975276ed421e7226393adb7ee8;hp=a305842e311c7e1772d7856f0bd6efd2c842619f;hpb=d88d35ed7ad85d9b90c8e2e805f0d872df9e32fa;p=public-inbox.git diff --git a/lib/PublicInbox/V2Writable.pm b/lib/PublicInbox/V2Writable.pm index a305842e..bdde76bb 100644 --- a/lib/PublicInbox/V2Writable.pm +++ b/lib/PublicInbox/V2Writable.pm @@ -26,10 +26,13 @@ sub nproc () { sub new { my ($class, $v2ibx, $creat) = @_; my $dir = $v2ibx->{mainrepo} or die "no mainrepo in inbox\n"; + my $lock_path = "$dir/inbox.lock"; unless (-d $dir) { if ($creat) { require File::Path; File::Path::mkpath($dir); + open my $fh, '>>', $lock_path or + die "failed to open $lock_path: $!\n"; } else { die "$dir does not exist\n"; } @@ -57,6 +60,7 @@ sub new { xap_ro => undef, partitions => $nparts, transact_bytes => 0, + lock_path => "$dir/inbox.lock", # limit each repo to 1GB or so rotate_bytes => int((1024 * 1024 * 1024) / $PACKING_FACTOR), }; @@ -395,7 +399,7 @@ sub import_init { my $im = PublicInbox::Import->new($git, undef, undef, $self->{-inbox}); $im->{bytes_added} = int($packed_bytes / $PACKING_FACTOR); $im->{want_object_info} = 1; - $im->{ssoma_lock} = 0; + $im->{lock_path} = $self->{lock_path}; $im->{path_type} = 'v2'; $self->{im} = $im; }