TheAnachronism/docspell
1
0
Fork 0
mirror of https://github.com/TheAnachronism/docspell.git synced 2025-04-04 18:39:33 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix cache clearing

Browse Source 
It must be cancelled when obtaining a pipeline.
This commit is contained in:
Eike Kettner 2021-01-07 23:29:47 +01:00
parent a87500bf78
commit 716252721c
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
modules/analysis/src/main/scala/docspell/analysis/nlp/PipelineCache.scala
View File

@ -136,12 +136,12 @@ object PipelineCache {
private[this] val log = Logger.log4s[F](logger)
def withCache: Resource[F, Unit] =
Resource.make(counter.update(_ + 1))(_ =>
Resource.make(counter.update(_ + 1) *> cancelClear)(_ =>
counter.updateAndGet(_ - 1).flatMap(n => scheduleClearPipeline(n))
)
def scheduleClearPipeline(cnt: Long): F[Unit] =
if (cnt > 0) cancelClear
if (cnt > 0) ().pure[F]
else cancelClear *> clearAllLater.flatMap(fiber => cleaningFiber.set(fiber.some))
private def cancelClear: F[Unit] =