import: implement barrier operation for v1 repos

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

diff --git a/lib/PublicInbox/WatchMaildir.pm b/lib/PublicInbox/WatchMaildir.pm
index 3da6b276ffa13b5e5e1e3d39e81d81ba43607b11..c72d93962481f2a34384573e2d43ecd709eeeb90 100644 (file)
--- a/lib/PublicInbox/WatchMaildir.pm
+++ b/lib/PublicInbox/WatchMaildir.pm
@@ -91,7 +91,7 @@ sub _done_for_now {
        my ($self) = @_;
        my $importers = $self->{importers};
        foreach my $im (values %$importers) {
-               $im->done if $im->{nchg};
+               $im->barrier;
        }
 
        my $opendirs = $self->{opendirs};