niklas/tracetools_analysis
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Improve event handling

Browse source
This commit is contained in:
Christophe Bedard 2019-06-06 09:23:03 +02:00
parent 02f5eb339a
commit b51910805c
1 changed files with 6 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

9
analysis/ros_processor.py
View file

@ -1,5 +1,6 @@
# Process trace events and create ROS model # Process trace events and create ROS model
import sys
from .lttng_models import EventMetadata, get_field, get_name from .lttng_models import EventMetadata, get_field, get_name
def ros_process(events): def ros_process(events):
@ -41,15 +42,17 @@ class RosProcessor():
self._handle(event) self._handle(event)
def _handle(self, event): def _handle(self, event):
handler_function = self._handler_map.get(get_name(event), None) event_name = get_name(event)
handler_function = self._handler_map.get(event_name, None)
if handler_function is not None: if handler_function is not None:
name = get_name(event)
pid = get_field(event, 'vpid', default=get_field(event, 'pid')) pid = get_field(event, 'vpid', default=get_field(event, 'pid'))
tid = get_field(event, 'vtid', default=get_field(event, 'tid')) tid = get_field(event, 'vtid', default=get_field(event, 'tid'))
timestamp = get_field(event, '_timestamp') timestamp = get_field(event, '_timestamp')
procname = get_field(event, 'procname') procname = get_field(event, 'procname')
metadata = EventMetadata(name, pid, tid, timestamp, procname) metadata = EventMetadata(event_name, pid, tid, timestamp, procname)
handler_function(event, metadata) handler_function(event, metadata)
else:
print(f'unhandled event name: {event_name}', file=sys.stderr)
def _handle_subscription_init(self, event, metadata): def _handle_subscription_init(self, event, metadata):
# TODO # TODO