flt.utils.muxer: use a heap to sort iterators (also: rewrite in C++)

[babeltrace.git] / src / plugins / utils / muxer / comp.cpp

diff --git a/src/plugins/utils/muxer/comp.cpp b/src/plugins/utils/muxer/comp.cpp
new file mode 100644 (file)
index 0000000..d81a4c2
--- /dev/null
+++ b/src/plugins/utils/muxer/comp.cpp
@@ -0,0 +1,53 @@
+/*
+ * SPDX-License-Identifier: MIT
+ *
+ * Copyright 2017-2023 Philippe Proulx <pproulx@efficios.com>
+ */
+
+#include "cpp-common/vendor/fmt/core.h"
+
+#include "comp.hpp"
+
+namespace bt2mux {
+
+Comp::Comp(const bt2::SelfFilterComponent selfComp, const bt2::ConstMapValue params) :
+    bt2::UserFilterComponent<Comp> {selfComp, "PLUGIN/FLT.UTILS.MUXER"}
+{
+    BT_CPPLOGI_STR("Initializing component.");
+
+    /* No parameters expected */
+    if (!params.isEmpty()) {
+        BT_CPPLOGE_APPEND_CAUSE_AND_THROW(
+            bt2c::Error, "This component expects no parameters: param-count={}", params.length());
+    }
+
+    /* Add initial available input port */
+    this->_addAvailInputPort();
+
+    /* Add single output port */
+    try {
+        this->_addOutputPort("out");
+    } catch (const bt2c::Error&) {
+        BT_CPPLOGE_STR_APPEND_CAUSE_AND_RETHROW("Failed to add a single output port.");
+    }
+
+    BT_CPPLOGI_STR("Initialized component.");
+}
+
+void Comp::_inputPortConnected(const bt2::SelfComponentInputPort, const bt2::ConstOutputPort)
+{
+    this->_addAvailInputPort();
+}
+
+void Comp::_addAvailInputPort()
+{
+    try {
+        this->_addInputPort(fmt::format("in{}", this->_inputPorts().length()));
+    } catch (const bt2c::Error&) {
+        BT_CPPLOGE_STR_APPEND_CAUSE_AND_RETHROW("Failed to add an available input port.");
+    }
+
+    BT_CPPLOGI("Added one available input port: name={}", this->_inputPorts().back().name());
+}
+
+} /* namespace bt2mux */