From 0a47444c670f6a203c3b42bdc1001a94d8efe871 Mon Sep 17 00:00:00 2001 From: kapeps Date: Tue, 28 Jan 2025 16:36:23 -0300 Subject: [PATCH] fix: minor code improvements --- lib/syskit/log/datastore/normalize.rb | 6 ++---- 1 file changed, 2 insertions(+), 4 deletions(-) diff --git a/lib/syskit/log/datastore/normalize.rb b/lib/syskit/log/datastore/normalize.rb index 884f036..985ff8e 100644 --- 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"