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

Add version to rcl_init handling

Browse source
This commit is contained in:
Christophe Bedard 2019-06-17 11:21:33 +02:00
parent 067a714e83
commit 62fe169634
2 changed files with 6 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

7
tracetools_analysis/analysis/data_model.py
View file

@ -16,7 +16,8 @@ class DataModel():
# Objects (one-time events, usually when something is created) # Objects (one-time events, usually when something is created)
self.contexts = pd.DataFrame(columns=['context_handle', self.contexts = pd.DataFrame(columns=['context_handle',
'timestamp', 'timestamp',
'pid']) 'pid',
'version'])
self.contexts.set_index(['context_handle'], inplace=True, drop=True) self.contexts.set_index(['context_handle'], inplace=True, drop=True)
self.nodes = pd.DataFrame(columns=['node_handle', self.nodes = pd.DataFrame(columns=['node_handle',
'timestamp', 'timestamp',
@ -71,8 +72,8 @@ class DataModel():
'duration', 'duration',
'intra_process']) 'intra_process'])
def add_context(self, context_handle, timestamp, pid) -> None: def add_context(self, context_handle, timestamp, pid, version) -> None:
self.contexts.loc[context_handle] = [timestamp, pid] self.contexts.loc[context_handle] = [timestamp, pid, version]
def add_node(self, node_handle, timestamp, tid, rmw_handle, name, namespace) -> None: def add_node(self, node_handle, timestamp, tid, rmw_handle, name, namespace) -> None:
self.nodes.loc[node_handle] = [timestamp, tid, rmw_handle, name, namespace] self.nodes.loc[node_handle] = [timestamp, tid, rmw_handle, name, namespace]

3
tracetools_analysis/analysis/ros2_processor.py
View file

@ -60,7 +60,8 @@ class Ros2Processor(EventHandler):
context_handle = get_field(event, 'context_handle') context_handle = get_field(event, 'context_handle')
timestamp = metadata.timestamp timestamp = metadata.timestamp
pid = metadata.pid pid = metadata.pid
self._data.add_context(context_handle, timestamp, pid) version = get_field(event, 'version')
self._data.add_context(context_handle, timestamp, pid, version)
def _handle_rcl_node_init(self, event: Dict, metadata: EventMetadata) -> None: def _handle_rcl_node_init(self, event: Dict, metadata: EventMetadata) -> None:
handle = get_field(event, 'node_handle') handle = get_field(event, 'node_handle')