lib/PublicInbox/SearchIdxPart.pm | 2 +- lib/PublicInbox/V2Writable.pm | 2 +- diff --git a/lib/PublicInbox/SearchIdxPart.pm b/lib/PublicInbox/SearchIdxPart.pm index c166078331a6f59d690182369d56a01a25657648..d8c8c8bb00e49a9a9a5b7177b0bab9d5f841452e 100644 --- a/lib/PublicInbox/SearchIdxPart.pm +++ b/lib/PublicInbox/SearchIdxPart.pm @@ -95,7 +95,7 @@ close $_[0]->{w} or die "failed to close write pipe: $!\n"; } # called by V2Writable: -sub barrier { +sub remote_barrier { my $w = $_[0]->{w}; print $w "barrier\n" or die "failed to print: $!"; $w->flush or die "failed to flush: $!"; diff --git a/lib/PublicInbox/V2Writable.pm b/lib/PublicInbox/V2Writable.pm index 5c104d8ec27df12fa93528834f3d396e401e0691..261f9d91a0c7e7849eb21d22b6d48c6ffaf5b4ed 100644 --- a/lib/PublicInbox/V2Writable.pm +++ b/lib/PublicInbox/V2Writable.pm @@ -280,7 +280,7 @@ # Now deal with Xapian $skel->barrier_init(scalar(@$parts)); # each partition needs to issue a barrier command to skel: - $_->barrier foreach @$parts; + $_->remote_barrier foreach @$parts; $skel->barrier_wait; # wait for each Xapian partition