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"