more cleaning

examples/multiport_mutation/consumer.hh

@@ -1,3 +1,11 @@
+/*
+ * Copyright (C) 2025 TU Dresden
+ * All rights reserved.
+ *
+ * Authors:
+ *   Tassilo Tanneberger
+ */
+
 #ifndef CONSUMER_HH // NOLINT
 #define CONSUMER_HH // NOLINT
 

examples/multiport_mutation/load_balancer.hh

@@ -1,9 +1,16 @@
-#ifndef LOAD_BALANCER_HH // NOLINT
-#define LOAD_BALANCER_HH // NOLINT
+/*
+ * Copyright (C) 2025 TU Dresden
+ * All rights reserved.
+ *
+ * Authors:
+ *   Tassilo Tanneberger
+ */
 
-#include <reactor-cpp/reactor-cpp.hh>
+#ifndef MULTIPORT_MUTATION_LOAD_BALANCER_HH // NOLINT
+#define MULTIPORT_MUTATION_LOAD_BALANCER_HH // NOLINT
 
-#include "reactor-cpp/mutations/multiport.hh"
+#include <reactor-cpp/mutations/multiport.hh>
+#include <reactor-cpp/reactor-cpp.hh>
 
 using namespace reactor;
 using namespace std::chrono_literals;
@@ -19,24 +26,21 @@ class LoadBalancer final : public Reactor { // NOLINT
       if (std::rand() % 15 == 0) {            // NOLINT
         scale_bank.set(std::rand() % 20 + 1); // NOLINT
       }
-      const unsigned sel = std::rand() % outbound.size(); // NOLINT
-      // std::cout << "Sending out to:" << sel << '\n';
-      outbound[sel].set(inbound.get());
-      outbound[std::min(4ul, outbound.size() - 1)].set(inbound.get());
+      const unsigned outbound_port = std::rand() % outbound.size(); // NOLINT
+      outbound[outbound_port].set(inbound.get());
     }
 
     friend LoadBalancer;
   };
 
   Inner _lf_inner;
-  Reaction process{"process", 2, this, [this]() { Inner::reaction_1(this->inbound, this->scale_bank, this->out); }};
+  Reaction process{"process", 1, this, [this]() { Inner::reaction_1(this->inbound, this->scale_bank, this->out); }};
 
 public:
   LoadBalancer(const std::string& name, Environment* env)
       : Reactor(name, env)
       , _lf_inner(this) {
     out.reserve(4);
-    std::cout << "creating instance of load balancer" << '\n';
     for (size_t _lf_idx = 0; _lf_idx < 4; _lf_idx++) {
       out.create_new_port();
     }
@@ -45,16 +49,16 @@ public:
 
   ModifableMultiport<Output<unsigned>> out{"out", this}; // NOLINT
   std::size_t out_size_ = 0;
+
   Input<unsigned> inbound{"inbound", this};        // NOLINT
   Output<unsigned> scale_bank{"scale_bank", this}; // NOLINT
 
   void assemble() override {
-    std::cout << "assemble LoadBalancer\n";
     for (auto& _lf_port : out) {
       process.declare_antidependency(&_lf_port);
     }
     process.declare_trigger(&inbound);
   }
 };
 
-#endif // LOAD_BALANCER_HH
+#endif // MULTIPORT_MUTATION_LOAD_BALANCER_HH

examples/multiport_mutation/main.cc

@@ -1,14 +1,20 @@
+/*
+ * Copyright (C) 2025 TU Dresden
+ * All rights reserved.
+ *
+ * Authors:
+ *   Tassilo Tanneberger
+ */
+
 #include <iostream>
 #include <memory>
 
-#include <reactor-cpp/mutations/bank.hh>
-#include <reactor-cpp/mutations/connection.hh>
+#include <reactor-cpp/reactor-cpp.hh>
 
 #include "./consumer.hh"
 #include "./load_balancer.hh"
 #include "./multiport_to_bank.hh"
 #include "./producer.hh"
-#include <reactor-cpp/reactor-cpp.hh>
 
 class Deployment final : public Reactor { // NOLINT
 

examples/multiport_mutation/multiport_to_bank.hh

@@ -1,9 +1,13 @@
-//
-// Created by tanneberger on 1/13/25.
-//
+/*
+ * Copyright (C) 2025 TU Dresden
+ * All rights reserved.
+ *
+ * Authors:
+ *   Tassilo Tanneberger
+ */
 
-#ifndef MULTIPORT_TO_BANK_HH
-#define MULTIPORT_TO_BANK_HH
+#ifndef MULTIPORT_MUTATION_MULTIPORT_TO_BANK_HH
+#define MULTIPORT_MUTATION_MULTIPORT_TO_BANK_HH
 
 #include <reactor-cpp/multiport.hh>
 #include <reactor-cpp/mutations.hh>
@@ -88,4 +92,4 @@ public:
 };
 } // namespace reactor
 
-#endif // MULTIPORT_TO_BANK_HH
+#endif // MULTIPORT_MUTATION_MULTIPORT_TO_BANK_HH

examples/multiport_mutation/producer.hh

@@ -1,5 +1,13 @@
-#ifndef PRODUCER_HH // NOLINT
-#define PRODUCER_HH // NOLINT
+/*
+ * Copyright (C) 2025 TU Dresden
+ * All rights reserved.
+ *
+ * Authors:
+ *   Tassilo Tanneberger
+ */
+
+#ifndef MULTIPORT_MUTATION_PRODUCER_HH // NOLINT
+#define MULTIPORT_MUTATION_PRODUCER_HH // NOLINT
 
 #include <reactor-cpp/reactor-cpp.hh>
 
@@ -44,4 +52,4 @@ public:
   }
 };
 
-#endif // PRODUCER_HH
+#endif // MULTIPORT_MUTATION_PRODUCER_HH

include/reactor-cpp/mutations/bank.hh

@@ -1,6 +1,10 @@
-//
-// Created by tanneberger on 11/18/24.
-//
+/*
+ * Copyright (C) 2025 TU Dresden
+ * All rights reserved.
+ *
+ * Authors:
+ *   Tassilo Tanneberger
+ */
 
 #ifndef REACTOR_CPP_MUTATIONS_BANK_HH
 #define REACTOR_CPP_MUTATIONS_BANK_HH

include/reactor-cpp/mutations/connection.hh

@@ -1,6 +1,10 @@
-//
-// Created by tanneberger on 11/18/24.
-//
+/*
+ * Copyright (C) 2025 TU Dresden
+ * All rights reserved.
+ *
+ * Authors:
+ *   Tassilo Tanneberger
+ */
 
 #ifndef REACTOR_CPP_MUTATIONS_CONNECTION_HH
 #define REACTOR_CPP_MUTATIONS_CONNECTION_HH

include/reactor-cpp/mutations/multiport.hh

@@ -1,6 +1,10 @@
-//
-// Created by tanneberger on 11/11/24.
-//
+/*
+ * Copyright (C) 2025 TU Dresden
+ * All rights reserved.
+ *
+ * Authors:
+ *   Tassilo Tanneberger
+ */
 
 #ifndef REACTOR_CPP_MUTATIONS_MULTIPORT_HH
 #define REACTOR_CPP_MUTATIONS_MULTIPORT_HH

lib/mutations/bank.cc

@@ -1,6 +1,10 @@
-//
-// Created by tanneberger on 11/11/24.
-//
+/*
+ * Copyright (C) 2025 TU Dresden
+ * All rights reserved.
+ *
+ * Authors:
+ *   Tassilo Tanneberger
+ */
 
 #include "reactor-cpp/mutations/bank.hh"
 #include "reactor-cpp/action.hh"
@@ -10,17 +14,17 @@ reactor::MutationChangeBankSize<T>::MutationChangeBankSize(
     std::vector<T>* bank, Environment* env, std::size_t size,
     std::function<T(Environment* env, std::size_t index)> create_lambda)
     : bank_(bank)
-    , env_(env)
     , desired_size_(size)
+    , env_(env)
     , create_lambda_(std::move(create_lambda)) {}
 
 template <class T> void reactor::MutationChangeBankSize<T>::change_size(std::size_t new_size) {
   auto current_size = bank_->size();
 
-  if (current_size >= new_size) { // downscale
+  if (current_size >= new_size) { // down-size
     bank_->resize(new_size);
 
-  } else { // upscale
+  } else { // up-size
     bank_->reserve(new_size);
 
     for (auto i = 0; i < new_size - current_size; i++) {

lib/mutations/connection.cc

@@ -1,8 +1,14 @@
+/*
+ * Copyright (C) 2025 TU Dresden
+ * All rights reserved.
+ *
+ * Authors:
+ *   Tassilo Tanneberger
+ */
+
 #include "reactor-cpp/mutations/connection.hh"
 #include "reactor-cpp/reactor.hh"
 
-#include <reactor-cpp/port.hh>
-
 template <class A, class B>
 reactor::MutationAddConnection<A, B>::MutationAddConnection(A* source, B* sink, Environment* env, bool add_connection)
     : source_(source)

lib/mutations/multiport.cc

@@ -1,9 +1,12 @@
-//
-// Created by tanneberger on 11/11/24.
-//
+/*
+ * Copyright (C) 2025 TU Dresden
+ * All rights reserved.
+ *
+ * Authors:
+ *   Tassilo Tanneberger
+ */
 
 #include "reactor-cpp/mutations/multiport.hh"
-#include "reactor-cpp/reaction.hh"
 
 template <class T>
 reactor::MutationChangeOutputMultiportSize<T>::MutationChangeOutputMultiportSize(
@@ -14,11 +17,11 @@ reactor::MutationChangeOutputMultiportSize<T>::MutationChangeOutputMultiportSize
 template <class T> void reactor::MutationChangeOutputMultiportSize<T>::change_size(std::size_t new_size) {
   auto current_size = multiport_->size();
   if (current_size >= new_size) {
-    // downscale
+    // down-size
     multiport_->resize(new_size);
 
   } else {
-    // upscale
+    // up-size
     multiport_->reserve(new_size);
     for (auto i = 0; i < new_size - current_size; i++) {
       std::string port_name_ = multiport_->name() + "_" + std::to_string(current_size + i);