From ff9b8bb838ecdfbfc1dc81038fcf3b2a87636982 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Cl=C3=A9ment=20Zrounba?=
 <6691770+clement-z@users.noreply.github.com>
Date: Sat, 30 Sep 2023 23:06:01 +0200
Subject: Initial release

---
 src/devices/merger.h | 51 +++++++++++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 51 insertions(+)
 create mode 100644 src/devices/merger.h

(limited to 'src/devices/merger.h')

diff --git a/src/devices/merger.h b/src/devices/merger.h
new file mode 100644
index 0000000..a3c0704
--- /dev/null
+++ b/src/devices/merger.h
@@ -0,0 +1,51 @@
+#pragma once
+
+#include <systemc.h>
+#include <map>
+
+#include <spx_module.h>
+#include <optical_output_port.h>
+#include <optical_signal.h>
+
+#include "specs.h"
+#include "spx_module.h"
+
+// A symmetric no-delay merger
+class Merger : public spx_module {
+public:
+    // Ports
+    spx::oa_port_in_type p_in1;
+    spx::oa_port_in_type p_in2;
+    spx::oa_port_out_type p_out;
+
+    // Timed ports writers
+    OpticalOutputPort m_out_writer;
+
+    // Member variables
+    double m_attenuation_dB;
+
+    // Memory for multi-wavelength purposes
+    // maybe with vector it has better performance
+    std::map<uint32_t,OpticalSignal::field_type> m_memory_in1;
+    std::map<uint32_t,OpticalSignal::field_type> m_memory_in2;
+
+    // Processes
+    void on_port_in1_changed();
+    void on_port_in2_changed();
+
+    // Constructor
+    Merger(sc_module_name name,
+           double attenuation_dB = 0)
+        : spx_module(name)
+        , m_out_writer("out_delayed_writer", p_out)
+        , m_attenuation_dB(attenuation_dB)
+    {
+        SC_HAS_PROCESS(Merger);
+
+        SC_THREAD(on_port_in1_changed);
+        sensitive << p_in1;
+
+        SC_THREAD(on_port_in2_changed);
+        sensitive << p_in2;
+    }
+};
-- 
cgit v1.2.3