- streams = sorted(trace['stream-infos'], key=sort_predictably)
- self.assertEqual(streams[0]['range-ns']['begin'], 13515309000000000 + offset)
- self.assertEqual(streams[0]['range-ns']['end'], 13515309000000100 + offset)
- self.assertEqual(streams[1]['range-ns']['begin'], 13515309000000070 + offset)
- self.assertEqual(streams[1]['range-ns']['end'], 13515309000000120 + offset)
+ streams = sorted(trace["stream-infos"], key=sort_predictably)
+ self.assertEqual(streams[0]["range-ns"]["begin"], 13515309000000000 + offset)
+ self.assertEqual(streams[0]["range-ns"]["end"], 13515309000000100 + offset)
+ self.assertEqual(streams[1]["range-ns"]["begin"], 13515309000000070 + offset)
+ self.assertEqual(streams[1]["range-ns"]["end"], 13515309000000120 + offset)
# Test various cominations of the clock-class-offset-s and
# clock-class-offset-ns parameters to babeltrace.trace-infos queries.
# Test various cominations of the clock-class-offset-s and
# clock-class-offset-ns parameters to babeltrace.trace-infos queries.
- 'babeltrace.trace-infos',
- {'inputs': self._inputs, 'clock-class-offset-s': 2},
+ "babeltrace.trace-infos",
+ {"inputs": self._inputs, "clock-class-offset-s": 2},
- 'babeltrace.trace-infos',
- {'inputs': self._inputs, 'clock-class-offset-ns': 2},
+ "babeltrace.trace-infos",
+ {"inputs": self._inputs, "clock-class-offset-ns": 2},
- 'inputs': self._inputs,
- 'clock-class-offset-s': -2,
- 'clock-class-offset-ns': -2,
+ "inputs": self._inputs,
+ "clock-class-offset-s": -2,
+ "clock-class-offset-ns": -2,
- 'babeltrace.trace-infos',
- {'inputs': self._inputs, 'clock-class-offset-s': "2"},
+ "babeltrace.trace-infos",
+ {"inputs": self._inputs, "clock-class-offset-s": "2"},
- 'babeltrace.trace-infos',
- {'inputs': self._inputs, 'clock-class-offset-s': None},
+ "babeltrace.trace-infos",
+ {"inputs": self._inputs, "clock-class-offset-s": None},
- 'babeltrace.trace-infos',
- {'inputs': self._inputs, 'clock-class-offset-ns': "2"},
+ "babeltrace.trace-infos",
+ {"inputs": self._inputs, "clock-class-offset-ns": "2"},
- 'babeltrace.trace-infos',
- {'inputs': self._inputs, 'clock-class-offset-ns': None},
+ "babeltrace.trace-infos",
+ {"inputs": self._inputs, "clock-class-offset-ns": None},
{"inputs": [os.path.join(test_ctf_traces_path, "succeed", "succeed1")]},
).query()
{"inputs": [os.path.join(test_ctf_traces_path, "succeed", "succeed1")]},
).query()
- if os.environ['BT_TESTS_OS_TYPE'] == 'mingw':
- os_stream_path = '\\tests\\data\\ctf-traces\\succeed\\succeed1\\dummystream'
+ if os.environ["BT_TESTS_OS_TYPE"] == "mingw":
+ os_stream_path = "\\tests\\data\\ctf-traces\\succeed\\succeed1\\dummystream"
streams = trace["stream-infos"]
self.assertEqual(len(streams), 1)
streams = trace["stream-infos"]
self.assertEqual(len(streams), 1)
- self.assertRaises(KeyError, lambda: trace['range-ns'])
- self.assertRaises(KeyError, lambda: streams[0]['range-ns'])
+ self.assertRaises(KeyError, lambda: trace["range-ns"])
+ self.assertRaises(KeyError, lambda: streams[0]["range-ns"])
# index files, because fix_index_lttng_event_after_packet_bug changes
# them based on the time of the last event in the stream.
# index files, because fix_index_lttng_event_after_packet_bug changes
# them based on the time of the last event in the stream.
- self.assertEqual(streams[0]['range-ns']['begin'], 1571261795455986789)
- self.assertEqual(streams[0]['range-ns']['end'], 1571261797582611840)
+ self.assertEqual(streams[0]["range-ns"]["begin"], 1571261795455986789)
+ self.assertEqual(streams[0]["range-ns"]["end"], 1571261797582611840)
- self.assertEqual(streams[1]['range-ns']['begin'], 1571261795456368232)
- self.assertEqual(streams[1]['range-ns']['end'], 1571261797577754111)
+ self.assertEqual(streams[1]["range-ns"]["begin"], 1571261795456368232)
+ self.assertEqual(streams[1]["range-ns"]["end"], 1571261797577754111)
- self.assertEqual(streams[2]['range-ns']['begin'], 1571261795456748255)
- self.assertEqual(streams[2]['range-ns']['end'], 1571261797577727795)
+ self.assertEqual(streams[2]["range-ns"]["begin"], 1571261795456748255)
+ self.assertEqual(streams[2]["range-ns"]["end"], 1571261797577727795)
- self.assertEqual(streams[3]['range-ns']['begin'], 1571261795457285142)
- self.assertEqual(streams[3]['range-ns']['end'], 1571261797582522088)
+ self.assertEqual(streams[3]["range-ns"]["begin"], 1571261795457285142)
+ self.assertEqual(streams[3]["range-ns"]["end"], 1571261797582522088)
- ctf = bt2.find_plugin('ctf')
- self._fs = ctf.source_component_classes['fs']
- self._path = os.path.join(test_ctf_traces_path, 'succeed')
+ ctf = bt2.find_plugin("ctf")
+ self._fs = ctf.source_component_classes["fs"]
+ self._path = os.path.join(test_ctf_traces_path, "succeed")
streams = trace["stream-infos"]
self.assertEqual(len(streams), 1)
streams = trace["stream-infos"]
self.assertEqual(len(streams), 1)
- self.assertEqual(streams[0]['range-ns']['begin'], 1565957300948091100)
- self.assertEqual(streams[0]['range-ns']['end'], 1565957302180016069)
+ self.assertEqual(streams[0]["range-ns"]["begin"], 1565957300948091100)
+ self.assertEqual(streams[0]["range-ns"]["end"], 1565957302180016069)
def test_lttng_crash(self):
trace = self._test_lttng_quirks("lttng-crash")
streams = trace["stream-infos"]
self.assertEqual(len(streams), 1)
def test_lttng_crash(self):
trace = self._test_lttng_quirks("lttng-crash")
streams = trace["stream-infos"]
self.assertEqual(len(streams), 1)
- self.assertEqual(streams[0]['range-ns']['begin'], 1565891729288866738)
- self.assertEqual(streams[0]['range-ns']['end'], 1565891729293526525)
+ self.assertEqual(streams[0]["range-ns"]["begin"], 1565891729288866738)
+ self.assertEqual(streams[0]["range-ns"]["end"], 1565891729293526525)