enso-org/enso
1
1
Fork 0
mirror of https://github.com/enso-org/enso.git synced 2024-11-23 08:08:34 +03:00
Code Issues Projects Releases Wiki Activity

Update cache invalidation commands (#8634)

Browse Source
This commit is contained in:
Dmitry Bushev 2023-12-26 12:39:17 +00:00 committed by GitHub
parent 07d58f2c02
commit 2d628263ff
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 5 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
engine/runtime-instrument-common/src/main/scala/org/enso/interpreter/instrument/job/EnsureCompiledJob.scala
View File

@ -322,19 +322,20 @@ final class EnsureCompiledJob(
*
* @param changeset the [[Changeset]] object capturing the previous
* version of IR
* @param ir the IR of compiled module
* @return the list of cache invalidation commands
*/
private def buildCacheInvalidationCommands(
changeset: Changeset[_],
oldIRs: Seq[IR]
ir: IR
): Seq[CacheInvalidation] = {
val invalidateExpressionsCommand =
CacheInvalidation.Command.InvalidateKeys(
changeset.invalidated
)
val oldUUIDs = oldIRs.flatMap(_.location()).flatMap(_.id()).distinct
val moduleIds = ir.preorder().flatMap(_.location()).flatMap(_.id()).toSet
val invalidateStaleCommand =
CacheInvalidation.Command.InvalidateStale(oldUUIDs)
CacheInvalidation.Command.InvalidateStale(moduleIds)
Seq(
CacheInvalidation(
CacheInvalidation.StackSelector.All,
@ -360,10 +361,7 @@ final class EnsureCompiledJob(
changeset: Changeset[_]
)(implicit ctx: RuntimeContext): Unit = {
val invalidationCommands =
buildCacheInvalidationCommands(
changeset,
module.getIr.preorder()
)
buildCacheInvalidationCommands(changeset, module.getIr)
ctx.contextManager.getAllContexts.values
.foreach { stack =>
if (stack.nonEmpty && isStackInModule(module.getName, stack)) {