Refactor. Make idOf and nameOf methods of MicroVM.

Also updated testing class structures.

src/main/scala/uvm/Bundle.scala

@@ -21,9 +21,9 @@ class Bundle {
    * 
    * TODO: Should there be a global "basic block ns for all function versions"?
    */
-  
+
   val allNs = new SimpleNamespace[Identified]()
-  
+
   val typeNs = new SimpleNamespace[Type]()
   val funcSigNs = new SimpleNamespace[FuncSig]()
   val funcVerNs = new SimpleNamespace[FuncVer]()
@@ -33,7 +33,22 @@ class Bundle {
   val constantNs = new SimpleNamespace[Constant]()
   val globalCellNs = new SimpleNamespace[GlobalCell]()
   val funcNs = new SimpleNamespace[Function]()
-  
+
+  /**
+   * Add an identified entity to its appropriate global namespaces.
+   */
+  def add(obj: Identified): Unit = {
+    allNs.add(obj)
+    if (obj.isInstanceOf[Type]) typeNs.add(obj.asInstanceOf[Type])
+    if (obj.isInstanceOf[FuncSig]) funcSigNs.add(obj.asInstanceOf[FuncSig])
+    if (obj.isInstanceOf[FuncVer]) funcVerNs.add(obj.asInstanceOf[FuncVer])
+    if (obj.isInstanceOf[SSAVariable]) varNs.add(obj.asInstanceOf[SSAVariable])
+    if (obj.isInstanceOf[GlobalVariable]) globalVarNs.add(obj.asInstanceOf[GlobalVariable])
+    if (obj.isInstanceOf[Constant]) constantNs.add(obj.asInstanceOf[Constant])
+    if (obj.isInstanceOf[GlobalCell]) globalCellNs.add(obj.asInstanceOf[GlobalCell])
+    if (obj.isInstanceOf[Function]) funcNs.add(obj.asInstanceOf[Function])
+  }
+
   private def simpleMerge[T <: Identified](oldNs: Namespace[T], newNs: Namespace[T]) {
     for (cand <- newNs.all) {
       if (!cand.isInstanceOf[Function] || oldNs.get(cand.id) == None) {
@@ -54,12 +69,12 @@ class Bundle {
     for (cand <- newNs.all) {
       val id = cand.id
       oldNs.get(id) match {
-        case None => oldNs.add(cand)
+        case None         => oldNs.add(cand)
         case Some(oldObj) => oldObj.versions = cand.versions.head :: oldObj.versions
       }
     }
   }
-  
+
   def merge(newBundle: Bundle) {
     simpleMerge(allNs, newBundle.allNs)
     simpleMerge(typeNs, newBundle.typeNs)

src/main/scala/uvm/ir/textinput/UIRTextReader.scala

@@ -28,11 +28,11 @@ class UIRTextReader(val idFactory: IDFactory) {
     val buf = new ArrayBuffer[String]()
     var hasError = false
     override def syntaxError(recognizer: Recognizer[_, _], offendingSymbol: Object,
-      line: Int, charPositionInLine: Int, msg: String, e: RecognitionException): Unit = {
+                             line: Int, charPositionInLine: Int, msg: String, e: RecognitionException): Unit = {
       buf.add("line %d:%d %s".format(line, charPositionInLine, msg))
       hasError = true
     }
-    
+
     def getMessages(): String = buf.mkString("\n")
   }
 
@@ -45,7 +45,7 @@ class UIRTextReader(val idFactory: IDFactory) {
     parser.addErrorListener(ea)
     val ast = parser.ir()
     if (ea.hasError) {
-      throw new TextIRParsingException("Syntax error:\n"+ea.getMessages)
+      throw new TextIRParsingException("Syntax error:\n" + ea.getMessages)
     }
     read(ast, globalBundle)
 
@@ -65,12 +65,12 @@ class UIRTextReader(val idFactory: IDFactory) {
         val neg = sign match {
           case "+" => false
           case "-" => true
-          case "" => false
+          case ""  => false
         }
         val abs = prefix match {
           case "0x" => BigInt(nums, 16)
-          case "0" => if(nums=="") BigInt(0) else BigInt(nums, 8)
-          case "" => BigInt(nums, 10)
+          case "0"  => if (nums == "") BigInt(0) else BigInt(nums, 8)
+          case ""   => BigInt(nums, 10)
         }
         return if (neg) -abs else abs
       }
@@ -84,7 +84,7 @@ class UIRTextReader(val idFactory: IDFactory) {
         java.lang.Float.NEGATIVE_INFINITY
       else java.lang.Float.POSITIVE_INFINITY
     }
-    case _: FloatNanContext => java.lang.Float.NaN
+    case _: FloatNanContext     => java.lang.Float.NaN
     case bits: FloatBitsContext => java.lang.Float.intBitsToFloat(bits.intLiteral().intValue())
   }
 
@@ -95,7 +95,7 @@ class UIRTextReader(val idFactory: IDFactory) {
         java.lang.Double.NEGATIVE_INFINITY
       else java.lang.Double.POSITIVE_INFINITY
     }
-    case _: DoubleNanContext => java.lang.Double.NaN
+    case _: DoubleNanContext     => java.lang.Double.NaN
     case bits: DoubleBitsContext => java.lang.Double.longBitsToDouble(bits.intLiteral().longValue())
   }
 
@@ -139,39 +139,26 @@ class UIRTextReader(val idFactory: IDFactory) {
     // Add entities to namespaces.
 
     def addTy(obj: Type): Unit = {
-      bundle.allNs.add(obj)
-      bundle.typeNs.add(obj)
+      bundle.add(obj)
     }
     def addSig(obj: FuncSig): Unit = {
-      bundle.allNs.add(obj)
-      bundle.funcSigNs.add(obj)
+      bundle.add(obj)
     }
     def addConst(obj: Constant): Unit = {
-      bundle.allNs.add(obj)
-      bundle.constantNs.add(obj)
-      bundle.globalVarNs.add(obj)
-      bundle.varNs.add(obj)
+      bundle.add(obj)
     }
     def addGlobalCell(obj: GlobalCell): Unit = {
-      bundle.allNs.add(obj)
-      bundle.globalCellNs.add(obj)
-      bundle.globalVarNs.add(obj)
-      bundle.varNs.add(obj)
+      bundle.add(obj)
     }
     def addFunc(obj: Function): Unit = {
-      bundle.allNs.add(obj)
-      bundle.funcNs.add(obj)
-      bundle.globalVarNs.add(obj)
-      bundle.varNs.add(obj)
+      bundle.add(obj)
     }
     def addLocalVar(obj: LocalVariable, localNs: Namespace[LocalVariable]) = {
       localNs.add(obj)
-      bundle.varNs.add(obj)
-      bundle.allNs.add(obj)
+      bundle.add(obj)
     }
     def addFuncVer(obj: FuncVer): Unit = {
-      bundle.allNs.add(obj)
-      bundle.funcVerNs.add(obj)
+      bundle.add(obj)
     }
 
     // Resolve types, with parse-time checking.
@@ -197,22 +184,22 @@ class UIRTextReader(val idFactory: IDFactory) {
 
     def mkType(tc: TypeConstructorContext): Type = {
       val ty = tc match {
-        case t: TypeIntContext => TypeInt(t.length.intValue())
-        case t: TypeFloatContext => TypeFloat()
-        case t: TypeDoubleContext => TypeDouble()
-        case t: TypeRefContext => TypeRef(null).later(phase1) { _.ty = resTy(t.`type`()) }
-        case t: TypeIRefContext => TypeIRef(null).later(phase1) { _.ty = resTy(t.`type`()) }
-        case t: TypeWeakRefContext => TypeWeakRef(null).later(phase1) { _.ty = resTy(t.`type`()) }
-        case t: TypeStructContext => TypeStruct(null).later(phase1) { _.fieldTy = t.`type`().map(resTy) }
-        case t: TypeArrayContext => TypeArray(null, t.length.longValue()).later(phase1) { _.elemTy = resTy(t.`type`()) }
-        case t: TypeHybridContext => TypeHybrid(null, null).later(phase1) { tt => tt.fixedTy = resTy(t.fixedTy); tt.varTy = resTy(t.varTy) }
-        case t: TypeVoidContext => TypeVoid()
-        case t: TypeFuncContext => TypeFunc(null).later(phase1) { _.sig = resSig(t.funcSig()) }
-        case t: TypeThreadContext => TypeThread()
-        case t: TypeStackContext => TypeStack()
+        case t: TypeIntContext      => TypeInt(t.length.intValue())
+        case t: TypeFloatContext    => TypeFloat()
+        case t: TypeDoubleContext   => TypeDouble()
+        case t: TypeRefContext      => TypeRef(null).later(phase1) { _.ty = resTy(t.`type`()) }
+        case t: TypeIRefContext     => TypeIRef(null).later(phase1) { _.ty = resTy(t.`type`()) }
+        case t: TypeWeakRefContext  => TypeWeakRef(null).later(phase1) { _.ty = resTy(t.`type`()) }
+        case t: TypeStructContext   => TypeStruct(null).later(phase1) { _.fieldTy = t.`type`().map(resTy) }
+        case t: TypeArrayContext    => TypeArray(null, t.length.longValue()).later(phase1) { _.elemTy = resTy(t.`type`()) }
+        case t: TypeHybridContext   => TypeHybrid(null, null).later(phase1) { tt => tt.fixedTy = resTy(t.fixedTy); tt.varTy = resTy(t.varTy) }
+        case t: TypeVoidContext     => TypeVoid()
+        case t: TypeFuncContext     => TypeFunc(null).later(phase1) { _.sig = resSig(t.funcSig()) }
+        case t: TypeThreadContext   => TypeThread()
+        case t: TypeStackContext    => TypeStack()
         case t: TypeTagRef64Context => TypeTagRef64()
-        case t: TypeVectorContext => TypeVector(null, t.length.longValue()).later(phase1) { _.elemTy = resTy(t.`type`()) }
-        case _ => throw new TextIRParsingException("foo")
+        case t: TypeVectorContext   => TypeVector(null, t.length.longValue()).later(phase1) { _.elemTy = resTy(t.`type`()) }
+        case _                      => throw new TextIRParsingException("foo")
       }
       return ty
     }
@@ -247,8 +234,8 @@ class UIRTextReader(val idFactory: IDFactory) {
 
     def mkConst(t: Type, c: ConstConstructorContext): Constant = {
       val con = c match {
-        case cc: ConstIntContext => ConstInt(t, cc.intLiteral)
-        case cc: ConstFloatContext => ConstFloat(t, cc.floatLiteral)
+        case cc: ConstIntContext    => ConstInt(t, cc.intLiteral)
+        case cc: ConstFloatContext  => ConstFloat(t, cc.floatLiteral)
         case cc: ConstDoubleContext => ConstDouble(t, cc.doubleLiteral)
         case cc: ConstStructContext => ConstStruct(t, null).later(phase2) {
           _.fields = for (gn <- cc.GLOBAL_NAME()) yield resGlobalVar(gn)
@@ -341,7 +328,7 @@ class UIRTextReader(val idFactory: IDFactory) {
         bb.id = idFactory.getID()
         bb.name = Some(globalize(bbCtx.label().name()))
         ver.bbNs.add(bb)
-        bundle.allNs.add(bb)
+        bundle.add(bb)
 
         bb.insts = bbCtx.inst.map(mkInst)
 
@@ -574,8 +561,8 @@ class UIRTextReader(val idFactory: IDFactory) {
               }
               i.newStackAction = ii.newStackClause match {
                 case a: NewStackPassValueContext => PassValue(a.`type`, a.value)
-                case a: NewStackPassVoidContext => PassVoid()
-                case a: NewStackThrowExcContext => ThrowExc(a.exc)
+                case a: NewStackPassVoidContext  => PassVoid()
+                case a: NewStackThrowExcContext  => ThrowExc(a.exc)
               }
               i.excClause = ii.excClause; i.keepAlives = ii.keepAliveClause
             }
@@ -588,8 +575,8 @@ class UIRTextReader(val idFactory: IDFactory) {
         }
 
         inst.id = idFactory.getID()
-        inst.name = Option(instDef.name).map(n=>globalize(n.getText))
-        
+        inst.name = Option(instDef.name).map(n => globalize(n.getText))
+
         addLocalVar(inst, ver.localVarNs)
 
         return inst
@@ -615,9 +602,9 @@ object UIRTextReader {
   def globalize(name: String, fvName: String): String = {
     val sigil = name.charAt(0)
     sigil match {
-    case '@' => name
-    case '%' => fvName + "." + name.substring(1)
-    case _ => throw new UvmException("Illegal name '%s'. Name must begin with either '@' or '%%'".format(name))
+      case '@' => name
+      case '%' => fvName + "." + name.substring(1)
+      case _   => throw new UvmException("Illegal name '%s'. Name must begin with either '@' or '%%'".format(name))
     }
   }
 }
\ No newline at end of file

src/main/scala/uvm/refimpl/MicroVM.scala

@@ -52,6 +52,18 @@ class MicroVM(heapSize: Word = MicroVM.DEFAULT_HEAP_SIZE,
     }
   }
   
+  /**
+   * Create a new ClientAgent.
+   */
   def newClientAgent(): ClientAgent = new ClientAgent(this)
 
+  /**
+   * Given a name, get the ID of an identified entity.
+   */
+  def idOf(name: String): Int = globalBundle.allNs(name).id
+  
+  /**
+   * Given an ID, get the name of an identified entity.
+   */
+  def nameOf(id: Int): String = globalBundle.allNs(id).name.get
 }
\ No newline at end of file

src/test/scala/junks/FactorialFromRPython.scala

@@ -5,10 +5,11 @@ import uvm.refimpl._
 object FactorialFromRPython extends App {
   val microVM = new MicroVM()
 
-  val r = new java.io.FileReader("tests/extra-progs/factorial.uir")
-
   val ca = microVM.newClientAgent()
+
+  val r = new java.io.FileReader("tests/extra-progs/factorial.uir")
   ca.loadBundle(r)
+  r.close()
 
   // Magical trick. Theoretically the client would publish bundles as binary and knows all the IDs. But in this version
   // only the text form is supported and IDs are automatically generated. So we look into the globalBundle itself.

src/test/scala/uvm/refimpl/UvmBundleTesterBase.scala

+package uvm.refimpl
+
+import org.scalatest._
+import java.io.FileReader
+import uvm._
+import uvm.types._
+import uvm.ssavariables._
+import uvm.refimpl._
+import uvm.refimpl.itpr._
+import uvm.ssavariables.MemoryOrder._
+import uvm.ssavariables.AtomicRMWOptr._
+import uvm.refimpl.mem.TypeSizes.Word
+import com.typesafe.scalalogging.Logger
+import org.slf4j.LoggerFactory
+import ch.qos.logback.classic.{ Logger => LLogger }
+import ch.qos.logback.classic.Level
+
+object UvmBundleTesterBase {
+  val logger = Logger(LoggerFactory.getLogger(getClass.getName))
+}
+
+abstract class UvmBundleTesterBase extends FlatSpec with Matchers {
+  val ROOT_LOGGER_NAME = org.slf4j.Logger.ROOT_LOGGER_NAME
+
+  def setLogLevels(settings: (String, Level)*): Unit = { // Configure logger
+    import org.slf4j.LoggerFactory
+    import org.slf4j.{ Logger => SLogger }
+    import ch.qos.logback.classic.{ Logger => LLogger, Level }
+    import ch.qos.logback.classic.Level._
+
+    def setLevel(name: String, level: Level): Unit = {
+      LoggerFactory.getLogger(name).asInstanceOf[LLogger].setLevel(level)
+    }
+
+    for ((name, lvl) <- settings) {
+      setLevel(name, lvl)
+    }
+  }
+
+  def makeMicroVM(): MicroVM = new MicroVM()
+
+  val microVM = makeMicroVM()
+
+  implicit def idOf(name: String): Int = microVM.idOf(name)
+  implicit def nameOf(id: Int): String = microVM.nameOf(id)
+
+  def preloadBundles(fileNames: String*): Unit = {
+    val ca = microVM.newClientAgent()
+
+    for (fn <- fileNames) {
+      val r = new FileReader(fn)
+      ca.loadBundle(r)
+      r.close()
+    }
+
+    ca.close()
+  }
+
+  type TrapHandlerFunction = (ClientAgent, Handle, Handle, Int) => TrapHandlerResult
+
+  class MockTrapHandler(thf: TrapHandlerFunction) extends TrapHandler {
+    def handleTrap(ca: ClientAgent, thread: Handle, stack: Handle, watchPointID: Int): TrapHandlerResult = {
+      thf(ca, thread, stack, watchPointID)
+    }
+  }
+
+  def testFunc(ca: ClientAgent, func: Handle, args: Seq[Handle])(handler: TrapHandlerFunction): Unit = {
+    microVM.trapManager.trapHandler = new MockTrapHandler(handler)
+    val hStack = ca.newStack(func, args)
+    val hThread = ca.newThread(hStack)
+    microVM.threadStackManager.joinAll()
+  }
+
+  implicit class MagicalBox(vb: ValueBox) {
+    def asInt: BigInt = vb.asInstanceOf[BoxInt].value
+    def asSInt(l: Int): BigInt = OpHelper.prepareSigned(vb.asInstanceOf[BoxInt].value, l)
+    def asUInt(l: Int): BigInt = OpHelper.prepareUnsigned(vb.asInstanceOf[BoxInt].value, l)
+    def asFloat: Float = vb.asInstanceOf[BoxFloat].value
+    def asDouble: Double = vb.asInstanceOf[BoxDouble].value
+    def asRef: Word = vb.asInstanceOf[BoxRef].objRef
+    def asIRef: (Word, Word) = { val b = vb.asInstanceOf[BoxIRef]; (b.objRef, b.offset) }
+    def asIRefAddr: Word = { val b = vb.asInstanceOf[BoxIRef]; b.objRef + b.offset }
+    def asStruct: Seq[ValueBox] = vb.asInstanceOf[BoxStruct].values
+    def asFunc: Option[Function] = vb.asInstanceOf[BoxFunc].func
+    def asThread: Option[InterpreterThread] = vb.asInstanceOf[BoxThread].thread
+    def asStack: Option[InterpreterStack] = vb.asInstanceOf[BoxStack].stack
+    def asTR64Box: BoxTagRef64 = vb.asInstanceOf[BoxTagRef64]
+    def asTR64Raw: Long = vb.asInstanceOf[BoxTagRef64].raw
+    def asVec: Seq[ValueBox] = vb.asInstanceOf[BoxVector].values
+  }
+}
\ No newline at end of file

src/test/scala/uvm/refimpl/itpr/UvmInterpreterSimpleTests.scala

@@ -10,74 +10,16 @@ import uvm.refimpl.itpr._
 import MemoryOrder._
 import AtomicRMWOptr._
 import uvm.refimpl.mem.TypeSizes.Word
+import ch.qos.logback.classic.Level._
+import uvm.refimpl.UvmBundleTesterBase
 
-class UvmInterpreterSimpleTests extends FlatSpec with Matchers {
+class UvmInterpreterSimpleTests extends UvmBundleTesterBase {
+  setLogLevels(
+    ROOT_LOGGER_NAME -> INFO,
+    "uvm.refimpl.itpr" -> DEBUG)
 
-  { // Configure logger
-    import org.slf4j.LoggerFactory
-    import org.slf4j.{ Logger => SLogger }
-    import ch.qos.logback.classic.{ Logger => LLogger, Level }
-    import ch.qos.logback.classic.Level._
-
-    def setLevel(name: String, level: Level): Unit = {
-      LoggerFactory.getLogger(name).asInstanceOf[LLogger].setLevel(level)
-    }
-
-    setLevel(SLogger.ROOT_LOGGER_NAME, INFO)
-    setLevel("uvm.refimpl.itpr", DEBUG)
-  }
-
-  val microVM = new MicroVM();
-
-  implicit def idOf(name: String): Int = microVM.globalBundle.allNs(name).id
-  implicit def nameOf(id: Int): String = microVM.globalBundle.allNs(id).name.get
-
-  {
-    val ca = microVM.newClientAgent()
-
-    val r = new FileReader("tests/uvm-refimpl-test/primitives.uir")
-    ca.loadBundle(r)
-    r.close()
-
-    val r2 = new FileReader("tests/uvm-refimpl-test/simple-tests.uir")
-    ca.loadBundle(r2)
-    r2.close()
-
-    ca.close()
-  }
-
-  type TrapHandlerFunction = (ClientAgent, Handle, Handle, Int) => TrapHandlerResult
-
-  class MockTrapHandler(thf: TrapHandlerFunction) extends TrapHandler {
-    def handleTrap(ca: ClientAgent, thread: Handle, stack: Handle, watchPointID: Int): TrapHandlerResult = {
-      thf(ca, thread, stack, watchPointID)
-    }
-  }
-
-  def testFunc(ca: ClientAgent, func: Handle, args: Seq[Handle])(handler: TrapHandlerFunction): Unit = {
-    microVM.trapManager.trapHandler = new MockTrapHandler(handler)
-    val hStack = ca.newStack(func, args)
-    val hThread = ca.newThread(hStack)
-    microVM.threadStackManager.joinAll()
-  }
-
-  implicit class MagicalBox(vb: ValueBox) {
-    def asInt: BigInt = vb.asInstanceOf[BoxInt].value
-    def asSInt(l: Int): BigInt = OpHelper.prepareSigned(vb.asInstanceOf[BoxInt].value, l)
-    def asUInt(l: Int): BigInt = OpHelper.prepareUnsigned(vb.asInstanceOf[BoxInt].value, l)
-    def asFloat: Float = vb.asInstanceOf[BoxFloat].value
-    def asDouble: Double = vb.asInstanceOf[BoxDouble].value
-    def asRef: Word = vb.asInstanceOf[BoxRef].objRef
-    def asIRef: (Word, Word) = { val b = vb.asInstanceOf[BoxIRef]; (b.objRef, b.offset) }
-    def asIRefAddr: Word = { val b = vb.asInstanceOf[BoxIRef]; b.objRef + b.offset }
-    def asStruct: Seq[ValueBox] = vb.asInstanceOf[BoxStruct].values
-    def asFunc: Option[Function] = vb.asInstanceOf[BoxFunc].func
-    def asThread: Option[InterpreterThread] = vb.asInstanceOf[BoxThread].thread
-    def asStack: Option[InterpreterStack] = vb.asInstanceOf[BoxStack].stack
-    def asTR64Box: BoxTagRef64 = vb.asInstanceOf[BoxTagRef64]
-    def asTR64Raw: Long = vb.asInstanceOf[BoxTagRef64].raw
-    def asVec: Seq[ValueBox] = vb.asInstanceOf[BoxVector].values
-  }
+  preloadBundles("tests/uvm-refimpl-test/primitives.uir",
+    "tests/uvm-refimpl-test/simple-tests.uir")
 
   "Factorial functions" should "work" in {
     val ca = microVM.newClientAgent()

src/test/scala/uvm/refimpl/itpr/UvmInterpreterSpec.scala

@@ -11,69 +11,15 @@ import MemoryOrder._
 import AtomicRMWOptr._
 import uvm.refimpl.mem.TypeSizes.Word
 
-class UvmInterpreterSpec extends FlatSpec with Matchers {
+import ch.qos.logback.classic.Level._
 
-  { // Configure logger
-    import org.slf4j.LoggerFactory
-    import org.slf4j.{ Logger => SLogger }
-    import ch.qos.logback.classic.{ Logger => LLogger, Level }
-    import ch.qos.logback.classic.Level._
+class UvmInterpreterSpec extends UvmBundleTesterBase {
 
-    def setLevel(name: String, level: Level): Unit = {
-      LoggerFactory.getLogger(name).asInstanceOf[LLogger].setLevel(level)
-    }
-
-    setLevel(SLogger.ROOT_LOGGER_NAME, INFO)
-    setLevel("uvm.refimpl.itpr", DEBUG)
-  }
-
-  val microVM = new MicroVM();
-
-  implicit def idOf(name: String): Int = microVM.globalBundle.allNs(name).id
-  implicit def nameOf(id: Int): String = microVM.globalBundle.allNs(id).name.get
-
-  {
-    val ca = microVM.newClientAgent()
-
-    val r = new FileReader("tests/uvm-refimpl-test/basic-tests.uir")
-    ca.loadBundle(r)
-
-    r.close()
-    ca.close()
-  }
-
-  type TrapHandlerFunction = (ClientAgent, Handle, Handle, Int) => TrapHandlerResult
-
-  class MockTrapHandler(thf: TrapHandlerFunction) extends TrapHandler {
-    def handleTrap(ca: ClientAgent, thread: Handle, stack: Handle, watchPointID: Int): TrapHandlerResult = {
-      thf(ca, thread, stack, watchPointID)
-    }
-  }
-
-  def testFunc(ca: ClientAgent, func: Handle, args: Seq[Handle])(handler: TrapHandlerFunction): Unit = {
-    microVM.trapManager.trapHandler = new MockTrapHandler(handler)
-    val hStack = ca.newStack(func, args)
-    val hThread = ca.newThread(hStack)
-    microVM.threadStackManager.joinAll()
-  }
-
-  implicit class MagicalBox(vb: ValueBox) {
-    def asInt: BigInt = vb.asInstanceOf[BoxInt].value
-    def asSInt(l: Int): BigInt = OpHelper.prepareSigned(vb.asInstanceOf[BoxInt].value, l)
-    def asUInt(l: Int): BigInt = OpHelper.prepareUnsigned(vb.asInstanceOf[BoxInt].value, l)
-    def asFloat: Float = vb.asInstanceOf[BoxFloat].value
-    def asDouble: Double = vb.asInstanceOf[BoxDouble].value
-    def asRef: Word = vb.asInstanceOf[BoxRef].objRef
-    def asIRef: (Word, Word) = { val b = vb.asInstanceOf[BoxIRef]; (b.objRef, b.offset) }
-    def asIRefAddr: Word = { val b = vb.asInstanceOf[BoxIRef]; b.objRef + b.offset }
-    def asStruct: Seq[ValueBox] = vb.asInstanceOf[BoxStruct].values
-    def asFunc: Option[Function] = vb.asInstanceOf[BoxFunc].func
-    def asThread: Option[InterpreterThread] = vb.asInstanceOf[BoxThread].thread
-    def asStack: Option[InterpreterStack] = vb.asInstanceOf[BoxStack].stack
-    def asTR64Box: BoxTagRef64 = vb.asInstanceOf[BoxTagRef64]
-    def asTR64Raw: Long = vb.asInstanceOf[BoxTagRef64].raw
-    def asVec: Seq[ValueBox] = vb.asInstanceOf[BoxVector].values
-  }
+  setLogLevels(
+    ROOT_LOGGER_NAME -> INFO,
+    "uvm.refimpl.itpr" -> DEBUG)
+    
+  preloadBundles("tests/uvm-refimpl-test/basic-tests.uir")
 
   "The constant pool" should "contain appropriate constant values" in {
     def gvb(name: String) = microVM.constantPool.getGlobalVarBox(microVM.globalBundle.globalVarNs(name))

src/test/scala/uvm/refimpl/mem/UvmMemOperationsSpec.scala

@@ -10,28 +10,18 @@ import uvm.refimpl.itpr._
 import MemoryOrder._
 import AtomicRMWOptr._
 
-class UvmMemOperationsSpec extends FlatSpec with Matchers with BeforeAndAfter {
+class UvmMemOperationsSpec extends UvmBundleTesterBase {
 
   // The heap size is intentionally reduced to make GC more often
   // The heap is divided in two halves. There is a 256KiB small object space (with 8 32KiB blocks) and a 256KiB large
   // object space.
-  val microVM = new MicroVM(heapSize = 512L * 1024L);
+  override def makeMicroVM() = new MicroVM(heapSize = 512L * 1024L)
 
-  implicit def idOf(name: String): Int = microVM.globalBundle.allNs(name).id
+  microVM.memoryManager.heap.space.debugLogBlockStates()
 
-  {
-    microVM.memoryManager.heap.space.debugLogBlockStates()
-
-    val ca = microVM.newClientAgent()
+  preloadBundles("tests/uvm-refimpl-test/uvm-mem-test-bundle.uir")
 
-    val r = new FileReader("tests/uvm-refimpl-test/uvm-mem-test-bundle.uir")
-    ca.loadBundle(r)
-
-    r.close()
-    ca.close()
-
-    microVM.memoryManager.heap.space.debugLogBlockStates()
-  }
+  microVM.memoryManager.heap.space.debugLogBlockStates()
 
   behavior of "UVM memory manager"
 
@@ -287,7 +277,7 @@ class UvmMemOperationsSpec extends FlatSpec with Matchers with BeforeAndAfter {
       val hIOutVal = ca.toInt(hIOut, true)
       hIOutVal.intValue shouldEqual i