Skip to content

Commit

Permalink
missing changes
Browse files Browse the repository at this point in the history
  • Loading branch information
hubertp committed Nov 29, 2023
1 parent 4142b57 commit a04d09b
Show file tree
Hide file tree
Showing 5 changed files with 12 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -103,6 +103,7 @@ class CommandExecutionEngine(interpreterContext: InterpreterContext)
/** @inheritdoc */
override def stop(): Unit = {
jobExecutionEngine.stop()
sequentialExecutionService.shutdownNow()
commandExecutor.shutdownNow()
}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -106,6 +106,10 @@ class InstrumentTestContext {
true
}

def reset(): Unit = {
messageQueue.clear()
}

}

object InstrumentTestContext {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -325,4 +325,6 @@ class ThreadSafeFileLockManager(locksRoot: Path) extends ThreadSafeLockManager {
case LockType.Shared => lock.tryAcquireReader()
}
}

override def reset(): Unit = localLocks.clear()
}
Original file line number Diff line number Diff line change
@@ -1,4 +1,6 @@
package org.enso.distribution.locking

/** A [[LockManager]] which guarantees to be thread-safe. */
trait ThreadSafeLockManager extends LockManager
trait ThreadSafeLockManager extends LockManager {
def reset(): Unit
}
Original file line number Diff line number Diff line change
Expand Up @@ -58,4 +58,6 @@ class TestLocalLockManager extends ThreadSafeLockManager {
case LockType.Shared => rwLock.readLock()
}
}

override def reset(): Unit = {}
}

0 comments on commit a04d09b

Please sign in to comment.