File tree Expand file tree Collapse file tree 6 files changed +6
-15
lines changed
Expand file tree Collapse file tree 6 files changed +6
-15
lines changed Original file line number Diff line number Diff line change @@ -52,7 +52,6 @@ class Demultiplexer : public Operator {
5252 protected:
5353
5454 void process_data () override {
55-
5655 while (true ) {
5756
5857 bool is_any_control_empty;
@@ -90,9 +89,8 @@ class Demultiplexer : public Operator {
9089 get_control_queue (i).pop_front ();
9190
9291 }
93- }
94- }
95-
92+ }
93+ }
9694};
9795
9896// Factory functions for common configurations using PortType
Original file line number Diff line number Diff line change @@ -46,9 +46,9 @@ class Input : public Operator {
4646 // Do not throw exceptions in receive_data
4747 void receive_data (std::unique_ptr<BaseMessage> msg, size_t port_index) override {
4848 try {
49- Operator::receive_data (std::move (msg), port_index);
49+ Operator::receive_data (std::move (msg), port_index);
5050 } catch (const std::exception& e) {
51-
51+ // Do nothing
5252 }
5353 }
5454
Original file line number Diff line number Diff line change @@ -92,7 +92,6 @@ class Join : public Operator {
9292
9393 protected:
9494 // Performs synchronization of input messages
95-
9695
9796 void process_data () override {
9897
@@ -124,7 +123,6 @@ class Join : public Operator {
124123
125124 private:
126125 std::vector<std::string> port_type_names_;
127-
128126};
129127
130128// Factory functions remain unchanged
Original file line number Diff line number Diff line change @@ -133,7 +133,6 @@ struct VectorNumberData {
133133 it += sizeof (double );
134134 data.values .push_back (value);
135135 }
136-
137136 return data;
138137 }
139138
@@ -191,7 +190,6 @@ struct VectorBooleanData {
191190
192191 // Number of bytes in the packed bitfield
193192 size_t byte_count = (size + 7 ) / 8 ;
194-
195193 data.values .reserve (size);
196194
197195 // ---- decode packed bits ----
@@ -203,7 +201,6 @@ struct VectorBooleanData {
203201
204202 // Advance iterator past the packed bytes
205203 it += byte_count;
206-
207204 return data;
208205 }
209206
Original file line number Diff line number Diff line change @@ -78,7 +78,6 @@ class Multiplexer : public Operator {
7878 protected:
7979
8080 void process_data () override {
81-
8281 while (true ) {
8382
8483 int num_empty_data_ports = 0 ;
@@ -135,7 +134,6 @@ class Multiplexer : public Operator {
135134 get_control_queue (i).pop_front ();
136135 }
137136 }
138-
139137 }
140138 }
141139
@@ -163,7 +161,7 @@ class Multiplexer : public Operator {
163161 }
164162
165163 return (active_count == 1 ) ? selected_port : -1 ;
166- }
164+ }
167165};
168166
169167// Factory function for creating a Multiplexer operator
Original file line number Diff line number Diff line change @@ -93,7 +93,7 @@ class ReduceJoin : public Join {
9393
9494 if (result.has_value ()) {
9595 get_output_queue (0 ).push_back (create_message<T>(time, *result));
96- }
96+ }
9797 }
9898 }
9999
You can’t perform that action at this time.
0 commit comments