Fixed automatic append of py_ports and var_ports

src/lava/magma/compiler/channels/pypychannel.py

@@ -280,7 +280,6 @@ def recv(self):
         result = self._array[self._idx].copy()
         self._idx = (self._idx + 1) % self._size
         self._ack.release()
-
         return result
 
     def join(self):

src/lava/magma/core/model/py/model.py

@@ -74,10 +74,9 @@ def __setattr__(self, key: str, value: ty.Any):
 
         """
         self.__dict__[key] = value
-        if isinstance(value, AbstractPyPort):
+        if isinstance(value, AbstractPyPort) and value not in self.py_ports:
             self.py_ports.append(value)
-            # Store all VarPorts for efficient RefPort -> VarPort handling
-            if isinstance(value, PyVarPort):
+            if isinstance(value, PyVarPort) and value not in self.var_ports:
                 self.var_ports.append(value)
 
     def start(self):

src/lava/magma/core/model/py/ports.py

@@ -699,13 +699,16 @@ def read(self) -> np.ndarray:
             The value of the referenced Var.
         """
         if self._csp_send_port and self._csp_recv_port:
-            header = np.ones(self._csp_send_port.shape) * VarPortCmd.GET
-            self._csp_send_port.send(header)
-
+            if not hasattr(self, 'get_header'):
+                self.get_header = (np.ones(self._csp_send_port.shape)
+                                   * VarPortCmd.GET)
+            self._csp_send_port.send(self.get_header)
             return self._transformer.transform(self._csp_recv_port.recv(),
                                                self._csp_recv_port)
-
-        return np.zeros(self._shape, self._d_type)
+        else:
+            if not hasattr(self, 'get_zeros'):
+                self.get_zeros = np.zeros(self._shape, self._d_type)
+            return self.get_zeros
 
     def write(self, data: np.ndarray):
         """Abstract method to write data to a VarPort to set the value of the
@@ -717,8 +720,10 @@ def write(self, data: np.ndarray):
             The data to send via _csp_send_port.
         """
         if self._csp_send_port:
-            header = np.ones(self._csp_send_port.shape) * VarPortCmd.SET
-            self._csp_send_port.send(header)
+            if not hasattr(self, 'set_header'):
+                self.set_header = (np.ones(self._csp_send_port.shape)
+                                   * VarPortCmd.SET)
+            self._csp_send_port.send(self.set_header)
             self._csp_send_port.send(data)