simpletrace: fix flight recorder --no-header option

The simpletrace.py script can pretty-print flight recorder ring buffers.
These are not full simpletrace binary trace files but just the end of a
trace file.  There is no header and the event ID mapping information is
often unavailable since the ring buffer may have filled up and discarded
event ID mapping records.

The simpletrace.stp script that generates ring buffer traces uses the
same trace-events-all input file as simpletrace.py.  Therefore both
scripts have the same global ordering of trace events.  A dynamic event
ID mapping isn't necessary: just use the trace-events-all file as the
reference for how event IDs are numbered.

It is now possible to analyze simpletrace.stp ring buffers again using:

  $ ./simpletrace.py trace-events-all path/to/ring-buffer

Signed-off-by: Stefan Hajnoczi <stefanha@redhat.com>
Reviewed-by: Daniel P. Berrange <berrange@redhat.com>
Message-id: 20170815084430.7128-3-stefanha@redhat.com
Signed-off-by: Stefan Hajnoczi <stefanha@redhat.com>
This commit is contained in:
Stefan Hajnoczi 2017-08-15 09:44:30 +01:00
parent d6b76d6805
commit 840d835177

View File

@ -97,11 +97,17 @@ def read_trace_header(fobj):
raise ValueError('Log format %d not supported with this QEMU release!' raise ValueError('Log format %d not supported with this QEMU release!'
% log_version) % log_version)
def read_trace_records(edict, fobj): def read_trace_records(edict, idtoname, fobj):
"""Deserialize trace records from a file, yielding record tuples (event_num, timestamp, pid, arg1, ..., arg6).""" """Deserialize trace records from a file, yielding record tuples (event_num, timestamp, pid, arg1, ..., arg6).
idtoname = {
dropped_event_id: "dropped" Note that `idtoname` is modified if the file contains mapping records.
}
Args:
edict (str -> Event): events dict, indexed by name
idtoname (int -> str): event names dict, indexed by event ID
fobj (file): input file
"""
while True: while True:
t = fobj.read(8) t = fobj.read(8)
if len(t) == 0: if len(t) == 0:
@ -171,10 +177,16 @@ def process(events, log, analyzer, read_header=True):
dropped_event = Event.build("Dropped_Event(uint64_t num_events_dropped)") dropped_event = Event.build("Dropped_Event(uint64_t num_events_dropped)")
edict = {"dropped": dropped_event} edict = {"dropped": dropped_event}
idtoname = {dropped_event_id: "dropped"}
for event in events: for event in events:
edict[event.name] = event edict[event.name] = event
# If there is no header assume event ID mapping matches events list
if not read_header:
for event_id, event in enumerate(events):
idtoname[event_id] = event.name
def build_fn(analyzer, event): def build_fn(analyzer, event):
if isinstance(event, str): if isinstance(event, str):
return analyzer.catchall return analyzer.catchall
@ -197,7 +209,7 @@ def process(events, log, analyzer, read_header=True):
analyzer.begin() analyzer.begin()
fn_cache = {} fn_cache = {}
for rec in read_trace_records(edict, log): for rec in read_trace_records(edict, idtoname, log):
event_num = rec[0] event_num = rec[0]
event = edict[event_num] event = edict[event_num]
if event_num not in fn_cache: if event_num not in fn_cache: