input to reactor bank input port wiring added

Author: OmerMajNition

include/reactor-sdk/InputPort.hh

@@ -23,6 +23,16 @@ class Input : public reactor::Input<T> {
                 origin.connect_fanout (input);
             }
 
+            template <typename OtherReactorType>
+            void operator>(ReactorBankInputPortOffset<OtherReactorType, T> &&other_bank_ports) {
+                origin.connect(std::move(other_bank_ports));
+            }
+
+            template <typename OtherReactorType>
+            void operator>>(ReactorBankInputPortOffset<OtherReactorType, T> &&other_bank_ports) {
+                origin.connect_fanout(std::move(other_bank_ports));
+            }
+
         private:
             Input& origin;
     };
@@ -31,6 +41,12 @@ class Input : public reactor::Input<T> {
     void connect(MultiportInput<T>& input);
     void connect_fanout(MultiportInput<T>& input);
 
+    template <typename ReactorType>
+    void connect(ReactorBankInputPortOffset<ReactorType, T> &&other_bank_ports);
+
+    template <typename ReactorType>
+    void connect_fanout(ReactorBankInputPortOffset<ReactorType, T> &&other_bank_ports);
+
 public:
     using value_type = T;
     Input(const std::string& name, reactor::Reactor* container)

include/reactor-sdk/impl/InputPort_wiring_impl.hh

@@ -42,5 +42,39 @@ void Input<T>::connect_fanout(MultiportInput<T>& input) {
     }
     connect_fanout_ (left_ports, right_ports, reactor::ConnectionProperties{});
 }
+
+template <typename T>
+template <typename ReactorType>
+void Input<T>::connect(ReactorBankInputPortOffset<ReactorType, T> &&other_bank_ports) {
+    std::set<reactor::Port<T>*> left_ports;
+    std::set<reactor::Port<T>*> right_ports;
+    bool result = left_ports.insert(this).second;
+    reactor_assert(result);
+    for (auto &p_reactor : other_bank_ports) {
+        auto *reactor = p_reactor.get();
+        char* reactor_base = reinterpret_cast<char*>(reactor);
+        Input<T>* port = reinterpret_cast<Input<T>*>(reactor_base + other_bank_ports.get_offset());
+        result = right_ports.insert(port).second;
+        reactor_assert(result);
+    }
+    connect_ (left_ports, right_ports, reactor::ConnectionProperties{});
+}
+
+template <typename T>
+template <typename ReactorType>
+void Input<T>::connect_fanout(ReactorBankInputPortOffset<ReactorType, T> &&other_bank_ports) {
+    std::set<reactor::Port<T>*> left_ports;
+    std::set<reactor::Port<T>*> right_ports;
+    bool result = left_ports.insert(this).second;
+    reactor_assert(result);
+    for (auto &p_reactor : other_bank_ports) {
+        auto *reactor = p_reactor.get();
+        char* reactor_base = reinterpret_cast<char*>(reactor);
+        Input<T>* port = reinterpret_cast<Input<T>*>(reactor_base + other_bank_ports.get_offset());
+        result = right_ports.insert(port).second;
+        reactor_assert(result);
+    }
+    connect_fanout_ (left_ports, right_ports, reactor::ConnectionProperties{});
+}
 
 } // namespace sdk