From 7acddf88d1bb8cc4f96cec93fa8e78c90c112617 Mon Sep 17 00:00:00 2001
From: Oscar Gustafsson <oscar.gustafsson@gmail.com>
Date: Fri, 9 Sep 2022 17:51:59 +0200
Subject: [PATCH] Add process classes
---
b_asic/operation.py | 1 +
b_asic/process.py | 42 ++++++++++++++++++++++++++++++++++++++++++
2 files changed, 43 insertions(+)
create mode 100644 b_asic/process.py
diff --git a/b_asic/operation.py b/b_asic/operation.py
index a4da4a6f..4b06c1b5 100644
--- a/b_asic/operation.py
+++ b/b_asic/operation.py
@@ -350,6 +350,7 @@ class AbstractOperation(Operation, AbstractGraphComponent):
] = None,
latency: Optional[int] = None,
latency_offsets: Optional[Dict[str, int]] = None,
+ execution_time: Optional[int] = None
):
"""Construct an operation with the given input/output count.
diff --git a/b_asic/process.py b/b_asic/process.py
new file mode 100644
index 00000000..2012a67e
--- /dev/null
+++ b/b_asic/process.py
@@ -0,0 +1,42 @@
+from typing import Dict, Int, List
+
+from b_asic.operation import AbstractOperation
+from b_asic.port import InputPort, OutputPort
+
+
+class Process:
+ def __init__(self, start_time : Int, execution_time : Int):
+ self._start_time = start_time
+ self._execution_time = execution_time
+
+ def __lt__(self, other):
+ return self._start_time < other.start_time or (
+ self._start_time == other.start_time and self.execution_time > _execution_time)
+
+ @property
+ def start_time(self) -> Int:
+ return self._start_time
+
+ @property
+ def execution_time(self) -> Int:
+ return self._execution_time
+
+
+class OperatorProcess(Process):
+ def __init__(self, start_time : Int, operation : AbstractOperation):
+ super().__init__(start_time, operation.execution_time)
+ self._operation = operation
+
+
+class MemoryVariable(Process):
+ def __init__(self, write_time : Int, write_port : OutputPort, reads : Dict[InputPort, Int]):
+ self._read_ports, self._life_times = reads.values()
+ super().__init__(start_time=write_time, execution_time=max(self._life_times))
+
+ @property
+ def life_times(self) -> List[Int]:
+ return self._life_times
+
+ @property
+ def read_ports(self) -> List[InputPort]:
+ return self._read_ports
--
GitLab