1 files changed, 69 insertions, 0 deletions
diff --git a/src/devices/value_list_source.cpp b/src/devices/value_list_source.cpp
new file mode 100644
index 0000000..a10c1a1
--- /dev/null
+++ b/src/devices/value_list_source.cpp
@@ -0,0 +1,69 @@
+#include "specs.h"
+#include "value_list_source.h"
+
+using std::cout;
+using std::cerr;
+using std::endl;
+
+void VLSource::runner()
+{
+    if (specsGlobalConfig.verbose_component_initialization)
+    {
+        cout << name() << ":" << endl;
+        cout << "value list (" << m_values_queue.size() << " values)";
+        if (false)
+        {
+            cout << ":" << endl;
+            for (const auto& val : m_values_queue)
+                cout << "\t" << "@" << sc_time(val.first, SC_SEC) << ": " << val.second << endl;
+        }
+        cout << endl;
+        cout << "--> " <<
+            (dynamic_cast<spx::oa_signal_type *>(p_out.get_interface()))->name() << endl;
+        cout << endl;
+    }
+
+    // Wait for enable signal
+    if (! enable.read().to_bool())
+    {
+        // cout << name() << " waiting for enable" << endl;
+        wait(enable.posedge_event());
+        cout << name() << " was enabled" << endl;
+    }
+
+    // Emitting 0 at enable (will only go through if there is no value at t=0)
+    if (m_values_queue.cbegin() == m_values_queue.cend()
+        || sc_time(m_values_queue.front().first, SC_SEC).value() > 0)
+    {
+        cout << "@" << sc_time_stamp() << ", " << name() << " emitted: " << spx::oa_value_type(0) << endl;
+        m_out_writer.delayedWrite(spx::oa_value_type(0), SC_ZERO_TIME);
+    }
+
+    auto it = m_values_queue.cbegin();
+    while (it != m_values_queue.cend())
+    {
+        sc_time now = sc_time_stamp();
+        sc_time next_emit;
+        if (sc_time(it->first, SC_SEC) < now)
+        {
+            cout << name() << ": invalid time for signal emission !" << endl;
+            ++it;
+            continue;
+        }
+        sc_time delay = sc_time(it->first, SC_SEC) - now;
+
+        // Wait until next output time
+        wait(delay);
+
+        auto s = it->second;
+
+        // Write value to output
+        m_out_writer.delayedWrite(s, SC_ZERO_TIME);
+        cout << "@" << sc_time_stamp() << ", " << name() << " emitted: " << s << endl;
+
+        ++it;
+    }
+
+    // cout << name() << " completed" << endl;
+    while(true) { wait(); }
+}