fix: minor code improvements

rock-core · Jan 28, 2025 · 0a47444 · 0a47444
1 parent 53a5594
commit 0a47444
Showing 1 changed file with 2 additions and 4 deletions.
diff --git a/lib/syskit/log/datastore/normalize.rb b/lib/syskit/log/datastore/normalize.rb
@@ -124,8 +124,8 @@ def add_data_block(rt_time, lg_time, raw_data, raw_payload)
                     write ZERO_BYTE
                     write raw_data[4..-1]
 
-                    logical_time = extract_logical_time(raw_payload)
-                    if logical_time
+                    if @logical_time_field
+                        logical_time = extract_logical_time(raw_payload)
                         lg_time = logical_time.microseconds
                         raw_payload = update_raw_payload_logical_time(
                             raw_payload, logical_time
@@ -149,8 +149,6 @@ def resolve_logical_time_field(stream_block)
 
                     metadata = type.field_metadata
                     type.each_field do |field|
-                        next unless metadata[field].include?("role")
-
                         role = metadata[field].get("role").first
 
                         return field if role == "logical_time"