Remove legacy, broken Connector; rename Merger&Splitter to avoid mixups

[Mograsim.git] / net.mograsim.logic.core / src / net / mograsim / logic / core / components / UnidirectionalMerger.java

diff --git a/net.mograsim.logic.core/src/net/mograsim/logic/core/components/UnidirectionalMerger.java b/net.mograsim.logic.core/src/net/mograsim/logic/core/components/UnidirectionalMerger.java
new file mode 100644 (file)
index 0000000..f1c3f8b
--- /dev/null
+++ b/net.mograsim.logic.core/src/net/mograsim/logic/core/components/UnidirectionalMerger.java
@@ -0,0 +1,85 @@
+package net.mograsim.logic.core.components;
+
+import java.util.List;
+
+import net.mograsim.logic.core.LogicObservable;
+import net.mograsim.logic.core.LogicObserver;
+import net.mograsim.logic.core.timeline.Timeline;
+import net.mograsim.logic.core.wires.Wire;
+import net.mograsim.logic.core.wires.Wire.ReadEnd;
+import net.mograsim.logic.core.wires.Wire.ReadWriteEnd;
+
+public class UnidirectionalMerger extends Component implements LogicObserver
+{
+       private ReadWriteEnd out;
+       private ReadEnd[] inputs;
+       private int[] beginningIndex;
+
+       /**
+        * 
+        * @param union  The output of merging n {@link Wire}s into one. Must have width = a1.width() + a2.width() + ... + an.width().
+        * @param inputs The inputs to be merged into the union
+        */
+       public UnidirectionalMerger(Timeline timeline, ReadWriteEnd union, ReadEnd... inputs)
+       {
+               super(timeline);
+               this.inputs = inputs;
+               this.out = union;
+               this.beginningIndex = new int[inputs.length];
+
+               int width = 0;
+               for (int i = 0; i < inputs.length; i++)
+               {
+                       beginningIndex[i] = width;
+                       width += inputs[i].width();
+                       inputs[i].registerObserver(this);
+               }
+
+               if (width != union.width())
+                       throw new IllegalArgumentException(
+                                       "The output of merging n WireArrays into one must have width = a1.width() + a2.width() + ... + an.width().");
+       }
+
+       public ReadEnd getInput(int index)
+       {
+               return inputs[index];
+       }
+
+       public ReadEnd getUnion()
+       {
+               return out;
+       }
+
+       @Override
+       public void update(LogicObservable initiator)
+       {
+               int index = find(initiator);
+               int beginning = beginningIndex[index];
+               out.feedSignals(beginning, inputs[index].getValues());
+       }
+
+       private int find(LogicObservable r)
+       {
+               for (int i = 0; i < inputs.length; i++)
+                       if (inputs[i] == r)
+                               return i;
+               return -1;
+       }
+
+       public ReadEnd[] getInputs()
+       {
+               return inputs.clone();
+       }
+
+       @Override
+       public List<ReadEnd> getAllInputs()
+       {
+               return List.of(inputs);
+       }
+
+       @Override
+       public List<ReadWriteEnd> getAllOutputs()
+       {
+               return List.of(out);
+       }
+}