diff options
| -rw-r--r-- | lib/MaildirIndexer/Store.rakumod | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/lib/MaildirIndexer/Store.rakumod b/lib/MaildirIndexer/Store.rakumod index 8efb731..27ec915 100644 --- a/lib/MaildirIndexer/Store.rakumod +++ b/lib/MaildirIndexer/Store.rakumod @@ -60,8 +60,10 @@ method del-file(IO:D $file --> Nil) { method mailbox-for-email(MaildirIndexer::Email:D $email --> Str) { my Str $result; MaildirIndexer::LogTimelineSchema::Store::Find.log: { - for @!indices -> $index { - with $index.mailbox-for-email($email) { $result = $_; last }; + $!lock.protect: { + for @!indices -> $index { + with $index.mailbox-for-email($email) { $result = $_; last }; + } } } return $result; |