Implement dispatcher

Author: outercloudstudio

src/main/scala/main/Dispatcher.scala

@@ -4,11 +4,36 @@ import _root_.circt.stage.ChiselStage
 
 class Dispatcher extends Module {
   val io = IO(new Bundle {
-    val read_requested = Output(Bool());
-    val read_address = Output(UInt(8.W));
+    val thread_requesting_opcode = Input(Bool());
+    val thread_program_pointer = Input(UInt(8.W));
+
+    val read_requested = Output(UInt(8.W));
+    val read_program_pointer = Output(UInt(8.W));
     val read_ready = Input(Bool());
-    val read_data = Input(UInt(8.W));
+    val read_opcode = Input(Operation());
+    
+    val opcode = Output(Operation());
+    val program_pointer = Output(UInt(8.W));
   });
 
-  val memory = SRAM(1024, UInt(8.W), 2, 2);
+  val read_requested = RegInit(0.U(8.W));
+  io.read_requested := read_requested;
+  val read_program_pointer = RegInit(0.U(8.W));
+  io.read_program_pointer := read_program_pointer;
+
+  val opcode = RegInit(Operation.NoOp);
+  io.opcode := opcode;
+  val program_pointer = RegInit(0.U(8.W));
+  io.program_pointer := program_pointer;
+
+  when(io.thread_requesting_opcode) {
+    read_program_pointer := io.thread_program_pointer;
+    read_requested := true.B;
+  }
+  
+  when(io.read_ready) {
+    opcode := io.read_opcode;
+    program_pointer := io.read_program_pointer;
+    read_requested := false.B;
+  }
 }

src/main/scala/main/Memory.scala

@@ -3,7 +3,7 @@ import chisel3.util._
 import _root_.circt.stage.ChiselStage
 
 class Memory extends Module {
-  val io = IO(new SRAMInterface(1024, UInt(8.W), 1, 1));
+  val io = IO(new SRAMInterface(1024, UInt(8.W), 1, 1, 0));
 
-  val memory = SRAM(1024, UInt(8.W), 1, 1);
+  val memory = SRAM(1024, UInt(8.W), 1, 1, 0);
 }

src/test/scala/main/DispatcherTest.scala

@@ -5,7 +5,23 @@ import org.scalatest.flatspec.AnyFlatSpec
 class DispatcherTest extends AnyFlatSpec with ChiselScalatestTester {
   "Dispatcher" should "work" in {
     test(new Dispatcher) { dut =>
+      dut.io.thread_requesting_opcode.poke(true.B);
+      dut.io.thread_program_pointer.poke(1.U(8.W));
+
+      dut.clock.step(1);
+
+      dut.io.read_requested.expect(true.B);
+      dut.io.read_program_pointer.expect(1.U(8.W));
 
+      dut.clock.step(1);
+    
+      dut.io.read_ready.poke(true.B);
+      dut.io.read_opcode.poke(Operation.Add);
+
+      dut.clock.step(1);
+
+      dut.io.opcode.expect(Operation.Add);
+      dut.io.program_pointer.expect(1.U(8.W));
     }
   }
 }