Index: tools/telemetry/telemetry/timeline/trace_event_importer_unittest.py |
diff --git a/tools/telemetry/telemetry/timeline/trace_event_importer_unittest.py b/tools/telemetry/telemetry/timeline/trace_event_importer_unittest.py |
index 9eef94578a3b66d9e4f468a90470f9f81bbc7ba7..3390acccef9c0461e4d1c4b4d8ba49f3d79840f8 100644 |
--- a/tools/telemetry/telemetry/timeline/trace_event_importer_unittest.py |
+++ b/tools/telemetry/telemetry/timeline/trace_event_importer_unittest.py |
@@ -6,9 +6,9 @@ import json |
import unittest |
from telemetry.timeline import trace_event_importer |
-from telemetry.timeline import tracing_timeline_data |
import telemetry.timeline.counter as tracing_counter |
import telemetry.timeline.model as timeline_model |
+import telemetry.value.trace as trace_value_module |
def FindEventNamed(events, name): |
@@ -18,18 +18,6 @@ def FindEventNamed(events, name): |
raise ValueError('No event found with name %s' % name) |
class TraceEventTimelineImporterTest(unittest.TestCase): |
- def testCanImportEmpty(self): |
- # TraceEventTimelineImporter needs to return false for empty lists and |
- # strings, because it assumes that they are >0 in len. But, TimelineMode can |
- # still import empty lists and strings (wrapped in a TimelineData object) |
- # via EmptyTimelineDataImporter. |
- self.assertFalse( |
- trace_event_importer.TraceEventTimelineImporter.CanImport( |
- tracing_timeline_data.TracingTimelineData([]))) |
- self.assertFalse( |
- trace_event_importer.TraceEventTimelineImporter.CanImport( |
- tracing_timeline_data.TracingTimelineData(''))) |
- |
def testBasicSingleThreadNonnestedParsing(self): |
events = [ |
{'name': 'a', 'args': {}, 'pid': 52, 'ts': 520, 'tts': 280, 'cat': 'foo', |
@@ -46,8 +34,8 @@ class TraceEventTimelineImporterTest(unittest.TestCase): |
'tid': 53, 'ph': 'E'} |
] |
- timeline_data = tracing_timeline_data.TracingTimelineData(events) |
- m = timeline_model.TimelineModel(timeline_data=timeline_data) |
+ trace_value = trace_value_module.TraceValue(events) |
+ m = timeline_model.TimelineModel(trace_value) |
processes = m.GetAllProcesses() |
self.assertEqual(1, len(processes)) |
p = processes[0] |
@@ -98,8 +86,8 @@ class TraceEventTimelineImporterTest(unittest.TestCase): |
'tid': 1, 'ph': 'E'} |
] |
- timeline_data = tracing_timeline_data.TracingTimelineData(events) |
- m = timeline_model.TimelineModel(timeline_data=timeline_data) |
+ trace_value = trace_value_module.TraceValue(events) |
+ m = timeline_model.TimelineModel(trace_value) |
processes = m.GetAllProcesses() |
t = processes[0].threads[1] |
slice_a = FindEventNamed(t.all_slices, 'a') |
@@ -115,8 +103,8 @@ class TraceEventTimelineImporterTest(unittest.TestCase): |
'tid': 53, 'ph': 'E'} |
] |
- timeline_data = tracing_timeline_data.TracingTimelineData(events) |
- m = timeline_model.TimelineModel(timeline_data=timeline_data) |
+ trace_value = trace_value_module.TraceValue(events) |
+ m = timeline_model.TimelineModel(trace_value) |
processes = m.GetAllProcesses() |
self.assertEqual(1, len(processes)) |
p = processes[0] |
@@ -141,9 +129,8 @@ class TraceEventTimelineImporterTest(unittest.TestCase): |
{'name': 'a', 'args': {}, 'pid': 1, 'ts': 7, 'tts': 5, 'cat': 'foo', |
'tid': 1, 'ph': 'E'} |
] |
- timeline_data = tracing_timeline_data.TracingTimelineData(events) |
- m = timeline_model.TimelineModel(timeline_data=timeline_data, |
- shift_world_to_zero=False) |
+ trace_value = trace_value_module.TraceValue(events) |
+ m = timeline_model.TimelineModel(trace_value) |
t = m.GetAllProcesses()[0].threads[1] |
slice_a = FindEventNamed(t.all_slices, 'a') |
@@ -182,8 +169,8 @@ class TraceEventTimelineImporterTest(unittest.TestCase): |
{'name': 'd', 'args': {}, 'pid': 1, 'ts': 7, 'tts': 5, 'cat': 'bar', |
'tid': 2, 'ph': 'E'} |
] |
- timeline_data = tracing_timeline_data.TracingTimelineData(events) |
- m = timeline_model.TimelineModel(timeline_data=timeline_data) |
+ trace_value = trace_value_module.TraceValue(events) |
+ m = timeline_model.TimelineModel(trace_value) |
p = m.GetAllProcesses()[0] |
t1 = p.threads[1] |
slice_event = FindEventNamed(t1.all_slices, 'a') |
@@ -211,8 +198,8 @@ class TraceEventTimelineImporterTest(unittest.TestCase): |
{'name': 'a', 'args': {}, 'pid': 1, 'ts': 1, 'tts': 1, 'cat': 'foo', |
'tid': 1, 'ph': 'B'} |
] |
- timeline_data = tracing_timeline_data.TracingTimelineData(events) |
- m = timeline_model.TimelineModel(timeline_data=timeline_data) |
+ trace_value = trace_value_module.TraceValue(events) |
+ m = timeline_model.TimelineModel(trace_value) |
p = m.GetAllProcesses()[0] |
t = p.threads[1] |
slice_event = t.all_slices[0] |
@@ -235,9 +222,8 @@ class TraceEventTimelineImporterTest(unittest.TestCase): |
{'name': 'b2', 'args': {}, 'pid': 1, 'ts': 3, 'cat': 'foo', |
'tid': 1, 'ph': 'B'} |
] |
- timeline_data = tracing_timeline_data.TracingTimelineData(events) |
- m = timeline_model.TimelineModel(timeline_data=timeline_data, |
- shift_world_to_zero=False) |
+ trace_value = trace_value_module.TraceValue(events) |
+ m = timeline_model.TimelineModel(trace_value) |
t = m.GetAllProcesses()[0].threads[1] |
slice_a = FindEventNamed(t.all_slices, 'a') |
@@ -262,9 +248,8 @@ class TraceEventTimelineImporterTest(unittest.TestCase): |
{'name': 'c', 'args': {}, 'pid': 1, 'ts': 4, 'tts': 2, 'cat': 'bar', |
'tid': 2, 'ph': 'E'} |
] |
- timeline_data = tracing_timeline_data.TracingTimelineData(events) |
- m = timeline_model.TimelineModel(timeline_data=timeline_data, |
- shift_world_to_zero=False) |
+ trace_value = trace_value_module.TraceValue(events) |
+ m = timeline_model.TimelineModel(trace_value) |
p = m.GetAllProcesses()[0] |
t1 = p.threads[1] |
t1_thread_time_bounds = m._thread_time_bounds[t1] # pylint: disable=W0212 |
@@ -309,9 +294,8 @@ class TraceEventTimelineImporterTest(unittest.TestCase): |
{'name': 'b', 'args': {}, 'pid': 1, 'ts': 2, 'cat': 'foo', |
'tid': 2, 'ph': 'E'} |
] |
- timeline_data = tracing_timeline_data.TracingTimelineData(events) |
- m = timeline_model.TimelineModel(timeline_data=timeline_data, |
- shift_world_to_zero=False) |
+ trace_value = trace_value_module.TraceValue(events) |
+ m = timeline_model.TimelineModel(trace_value) |
t1 = m.GetAllProcesses()[0].threads[1] |
t2 = m.GetAllProcesses()[0].threads[2] |
@@ -333,8 +317,8 @@ class TraceEventTimelineImporterTest(unittest.TestCase): |
{'name': 'b', 'args': {}, 'pid': 1, 'ts': 8, 'tts': 4, 'cat': 'bar', |
'tid': 2, 'ph': 'E'} |
] |
- timeline_data = tracing_timeline_data.TracingTimelineData(events) |
- m = timeline_model.TimelineModel(timeline_data=timeline_data) |
+ trace_value = trace_value_module.TraceValue(events) |
+ m = timeline_model.TimelineModel(trace_value) |
processes = m.GetAllProcesses() |
self.assertEqual(1, len(processes)) |
p = processes[0] |
@@ -379,8 +363,8 @@ class TraceEventTimelineImporterTest(unittest.TestCase): |
'tid': 2, 'ph': 'E'} |
] |
- timeline_data = tracing_timeline_data.TracingTimelineData(events) |
- m = timeline_model.TimelineModel(timeline_data=timeline_data) |
+ trace_value = trace_value_module.TraceValue(events) |
+ m = timeline_model.TimelineModel(trace_value) |
processes = m.GetAllProcesses() |
self.assertEqual(2, len(processes)) |
@@ -438,8 +422,8 @@ class TraceEventTimelineImporterTest(unittest.TestCase): |
{'name': 'thread_name', 'args': {'name': 'Thread 2'}, |
'pid': 2, 'ts': 0, 'tid': 2, 'ph': 'M'} |
] |
- timeline_data = tracing_timeline_data.TracingTimelineData(events) |
- m = timeline_model.TimelineModel(timeline_data=timeline_data) |
+ trace_value = trace_value_module.TraceValue(events) |
+ m = timeline_model.TimelineModel(trace_value) |
processes = m.GetAllProcesses() |
self.assertEqual('Thread 1', processes[0].threads[1].name) |
self.assertEqual('Thread 2', processes[1].threads[2].name) |
@@ -453,9 +437,8 @@ class TraceEventTimelineImporterTest(unittest.TestCase): |
{'name': 'a', 'args': {}, 'pid': 1, 'ts': 5, 'tts': 5, 'cat': 'foo', |
'tid': 1, 'ph': 'E'} |
] |
- timeline_data = tracing_timeline_data.TracingTimelineData(events) |
- m = timeline_model.TimelineModel(timeline_data=timeline_data, |
- shift_world_to_zero=False) |
+ trace_value = trace_value_module.TraceValue(events) |
+ m = timeline_model.TimelineModel(trace_value) |
p = m.GetAllProcesses()[0] |
t = p.threads[1] |
self.assertEqual(1, len(t.all_slices)) |
@@ -480,9 +463,8 @@ class TraceEventTimelineImporterTest(unittest.TestCase): |
{'name': 'a', 'args': {}, 'pid': 1, 'ts': 8, 'tts': 4, 'cat': 'foo', |
'tid': 1, 'ph': 'E'} |
] |
- timeline_data = tracing_timeline_data.TracingTimelineData(events) |
- m = timeline_model.TimelineModel(timeline_data=timeline_data, |
- shift_world_to_zero=False) |
+ trace_value = trace_value_module.TraceValue(events) |
+ m = timeline_model.TimelineModel(trace_value) |
p = m.GetAllProcesses()[0] |
t = p.threads[1] |
self.assertEqual(3, len(t.all_slices)) |
@@ -517,8 +499,8 @@ class TraceEventTimelineImporterTest(unittest.TestCase): |
{'name': 'ctr', 'args': {'value': 0}, 'pid': 1, 'ts': 20, 'cat': 'foo', |
'tid': 1, 'ph': 'C'} |
] |
- timeline_data = tracing_timeline_data.TracingTimelineData(events) |
- m = timeline_model.TimelineModel(timeline_data=timeline_data) |
+ trace_value = trace_value_module.TraceValue(events) |
+ m = timeline_model.TimelineModel(trace_value) |
p = m.GetAllProcesses()[0] |
ctr = p.counters['foo.ctr'] |
@@ -554,8 +536,8 @@ class TraceEventTimelineImporterTest(unittest.TestCase): |
'tid': 1, |
'ph': 'C', 'id': 2} |
] |
- timeline_data = tracing_timeline_data.TracingTimelineData(events) |
- m = timeline_model.TimelineModel(timeline_data=timeline_data) |
+ trace_value = trace_value_module.TraceValue(events) |
+ m = timeline_model.TimelineModel(trace_value) |
p = m.GetAllProcesses()[0] |
ctr = p.counters['foo.ctr[0]'] |
self.assertEqual('ctr[0]', ctr.name) |
@@ -614,8 +596,8 @@ class TraceEventTimelineImporterTest(unittest.TestCase): |
{'name': 'ctr', 'args': {'value1': 0, 'value2': 1 }, 'pid': 1, 'ts': 20, |
'cat': 'foo', 'tid': 1, 'ph': 'C'} |
] |
- timeline_data = tracing_timeline_data.TracingTimelineData(events) |
- m = timeline_model.TimelineModel(timeline_data=timeline_data) |
+ trace_value = trace_value_module.TraceValue(events) |
+ m = timeline_model.TimelineModel(trace_value) |
p = m.GetAllProcesses()[0] |
ctr = p.counters['foo.ctr'] |
self.assertEqual('ctr', ctr.name) |
@@ -632,124 +614,6 @@ class TraceEventTimelineImporterTest(unittest.TestCase): |
# the order in which the series names are added. |
self.assertEqual(14, ctr.max_total) |
- def testImportObjectInsteadOfArray(self): |
- events = { 'traceEvents': [ |
- {'name': 'a', 'args': {}, 'pid': 52, 'ts': 524, 'cat': 'foo', |
- 'tid': 53, 'ph': 'B'}, |
- {'name': 'a', 'args': {}, 'pid': 52, 'ts': 560, 'cat': 'foo', |
- 'tid': 53, 'ph': 'E'} |
- ] } |
- |
- timeline_data = tracing_timeline_data.TracingTimelineData(events) |
- m = timeline_model.TimelineModel(timeline_data=timeline_data) |
- self.assertEqual(1, len(m.GetAllProcesses())) |
- |
- def testImportString(self): |
- events = [ |
- {'name': 'a', 'args': {}, 'pid': 52, 'ts': 524, 'cat': 'foo', |
- 'tid': 53, 'ph': 'B'}, |
- {'name': 'a', 'args': {}, 'pid': 52, 'ts': 560, 'cat': 'foo', |
- 'tid': 53, 'ph': 'E'} |
- ] |
- |
- timeline_data = tracing_timeline_data.TracingTimelineData( |
- json.dumps(events)) |
- m = timeline_model.TimelineModel(timeline_data=timeline_data) |
- self.assertEqual(1, len(m.GetAllProcesses())) |
- |
- def testImportStringWithTrailingNewLine(self): |
- events = [ |
- {'name': 'a', 'args': {}, 'pid': 52, 'ts': 524, 'cat': 'foo', |
- 'tid': 53, 'ph': 'B'}, |
- {'name': 'a', 'args': {}, 'pid': 52, 'ts': 560, 'cat': 'foo', |
- 'tid': 53, 'ph': 'E'} |
- ] |
- |
- timeline_data = tracing_timeline_data.TracingTimelineData( |
- json.dumps(events) + '\n') |
- m = timeline_model.TimelineModel(timeline_data=timeline_data) |
- self.assertEqual(1, len(m.GetAllProcesses())) |
- |
- def testImportStringWithMissingCloseSquareBracket(self): |
- events = [ |
- {'name': 'a', 'args': {}, 'pid': 52, 'ts': 524, 'cat': 'foo', |
- 'tid': 53, 'ph': 'B'}, |
- {'name': 'a', 'args': {}, 'pid': 52, 'ts': 560, 'cat': 'foo', |
- 'tid': 53, 'ph': 'E'} |
- ] |
- |
- tmp = json.dumps(events) |
- self.assertEqual(']', tmp[-1]) |
- |
- # Drop off the trailing ] |
- dropped = tmp[:-1] |
- timeline_data = tracing_timeline_data.TracingTimelineData(dropped) |
- m = timeline_model.TimelineModel(timeline_data=timeline_data) |
- self.assertEqual(1, len(m.GetAllProcesses())) |
- |
- def testImportStringWithEndingCommaButMissingCloseSquareBracket(self): |
- lines = [ |
- '[', |
- '{"name": "a", "args": {}, "pid": 52, "ts": 524, "cat": "foo", ' |
- '"tid": 53, "ph": "B"},', |
- '{"name": "a", "args": {}, "pid": 52, "ts": 560, "cat": "foo", ' |
- '"tid": 53, "ph": "E"},' |
- ] |
- text = '\n'.join(lines) |
- |
- timeline_data = tracing_timeline_data.TracingTimelineData(text) |
- m = timeline_model.TimelineModel(timeline_data=timeline_data) |
- processes = m.GetAllProcesses() |
- self.assertEqual(1, len(processes)) |
- self.assertEqual(1, len(processes[0].threads[53].all_slices)) |
- |
- def testImportStringWithMissingCloseSquareBracketAndNewline(self): |
- events = [ |
- {'name': 'a', 'args': {}, 'pid': 52, 'ts': 524, 'cat': 'foo', |
- 'tid': 53, 'ph': 'B'}, |
- {'name': 'a', 'args': {}, 'pid': 52, 'ts': 560, 'cat': 'foo', |
- 'tid': 53, 'ph': 'E'} |
- ] |
- |
- tmp = json.dumps(events) |
- self.assertEqual(']', tmp[-1]) |
- |
- # Drop off the trailing ] and add a newline |
- dropped = tmp[:-1] |
- timeline_data = tracing_timeline_data.TracingTimelineData(dropped + '\n') |
- m = timeline_model.TimelineModel(timeline_data=timeline_data) |
- self.assertEqual(1, len(m.GetAllProcesses())) |
- |
- def testImportStringWithEndingCommaButMissingCloseSquareBracketCRLF(self): |
- lines = [ |
- '[', |
- '{"name": "a", "args": {}, "pid": 52, "ts": 524, "cat": "foo", ' |
- '"tid": 53, "ph": "B"},', |
- '{"name": "a", "args": {}, "pid": 52, "ts": 560, "cat": "foo", ' |
- '"tid": 53, "ph": "E"},' |
- ] |
- text = '\r\n'.join(lines) |
- |
- timeline_data = tracing_timeline_data.TracingTimelineData(text) |
- m = timeline_model.TimelineModel(timeline_data=timeline_data) |
- processes = m.GetAllProcesses() |
- self.assertEqual(1, len(processes)) |
- self.assertEqual(1, len(processes[0].threads[53].all_slices)) |
- |
- def testImportOldFormat(self): |
- lines = [ |
- '[', |
- '{"cat":"a","pid":9,"tid":8,"ts":194,"ph":"E","name":"I","args":{}},', |
- '{"cat":"b","pid":9,"tid":8,"ts":194,"ph":"B","name":"I","args":{}}', |
- ']' |
- ] |
- text = '\n'.join(lines) |
- timeline_data = tracing_timeline_data.TracingTimelineData(text) |
- m = timeline_model.TimelineModel(timeline_data=timeline_data) |
- processes = m.GetAllProcesses() |
- self.assertEqual(1, len(processes)) |
- self.assertEqual(1, len(processes[0].threads[8].all_slices)) |
- |
def testStartFinishOneSliceOneThread(self): |
events = [ |
# Time is intentionally out of order. |
@@ -761,8 +625,8 @@ class TraceEventTimelineImporterTest(unittest.TestCase): |
'ph': 'S', 'id': 72, 'args': {'foo': 'bar'}} |
] |
- timeline_data = tracing_timeline_data.TracingTimelineData(events) |
- m = timeline_model.TimelineModel(timeline_data=timeline_data) |
+ trace_value = trace_value_module.TraceValue(events) |
+ m = timeline_model.TimelineModel(trace_value) |
events = list(m.IterAllEvents()) |
self.assertEqual(2, len(events)) |
@@ -788,8 +652,8 @@ class TraceEventTimelineImporterTest(unittest.TestCase): |
'tid': 53, 'ph': 'E'} |
] |
- timeline_data = tracing_timeline_data.TracingTimelineData(events) |
- m = timeline_model.TimelineModel(timeline_data=timeline_data) |
+ trace_value = trace_value_module.TraceValue(events) |
+ m = timeline_model.TimelineModel(trace_value) |
processes = m.GetAllProcesses() |
self.assertEqual(1, len(processes)) |
p = processes[0] |
@@ -813,8 +677,8 @@ class TraceEventTimelineImporterTest(unittest.TestCase): |
'tid': 53, 'ph': 'E'} |
] |
- timeline_data = tracing_timeline_data.TracingTimelineData(events) |
- m = timeline_model.TimelineModel(timeline_data=timeline_data) |
+ trace_value = trace_value_module.TraceValue(events) |
+ m = timeline_model.TimelineModel(trace_value) |
processes = m.GetAllProcesses() |
self.assertEqual(1, len(processes)) |
p = processes[0] |
@@ -855,9 +719,8 @@ class TraceEventTimelineImporterTest(unittest.TestCase): |
{'name': 'e', 'args': {}, 'pid': 52, 'ts': 165, 'cat': 'foo', |
'tid': 53, 'ph': 'E'} |
] |
- timeline_data = tracing_timeline_data.TracingTimelineData(events) |
- m = timeline_model.TimelineModel(timeline_data=timeline_data, |
- shift_world_to_zero=False) |
+ trace_value = trace_value_module.TraceValue(events) |
+ m = timeline_model.TimelineModel(trace_value) |
processes = m.GetAllProcesses() |
self.assertEqual(1, len(processes)) |
p = processes[0] |
@@ -893,8 +756,8 @@ class TraceEventTimelineImporterTest(unittest.TestCase): |
'ph': 'S', 'id': 72} |
] |
- timeline_data = tracing_timeline_data.TracingTimelineData(events) |
- m = timeline_model.TimelineModel(timeline_data=timeline_data) |
+ trace_value = trace_value_module.TraceValue(events) |
+ m = timeline_model.TimelineModel(trace_value) |
t = m.GetAllProcesses()[0].threads[53] |
self.assertEqual(1, len(t.async_slices)) |
parent_slice = t.async_slices[0] |
@@ -917,8 +780,8 @@ class TraceEventTimelineImporterTest(unittest.TestCase): |
'ph': 'S', 'id': 72} |
] |
- timeline_data = tracing_timeline_data.TracingTimelineData(events) |
- m = timeline_model.TimelineModel(timeline_data=timeline_data) |
+ trace_value = trace_value_module.TraceValue(events) |
+ m = timeline_model.TimelineModel(trace_value) |
t = m.GetAllProcesses()[0].threads[53] |
self.assertEqual(1, len(t.async_slices)) |
parent_slice = t.async_slices[0] |
@@ -940,8 +803,8 @@ class TraceEventTimelineImporterTest(unittest.TestCase): |
'tid': 53, 'ph': 'S', 'id': 72, 'tts': 17} |
] |
- timeline_data = tracing_timeline_data.TracingTimelineData(events) |
- m = timeline_model.TimelineModel(timeline_data=timeline_data) |
+ trace_value = trace_value_module.TraceValue(events) |
+ m = timeline_model.TimelineModel(trace_value) |
t = m.GetAllProcesses()[0].threads[53] |
self.assertEqual(1, len(t.async_slices)) |
parent_slice = t.async_slices[0] |
@@ -978,8 +841,8 @@ class TraceEventTimelineImporterTest(unittest.TestCase): |
'cat': 'foo', 'tid': 53, 'ph': 'T', 'id': 72} |
] |
- timeline_data = tracing_timeline_data.TracingTimelineData(events) |
- m = timeline_model.TimelineModel(timeline_data=timeline_data) |
+ trace_value = trace_value_module.TraceValue(events) |
+ m = timeline_model.TimelineModel(trace_value) |
t = m.GetAllProcesses()[0].threads[53] |
self.assertTrue(t is not None) |
@@ -992,8 +855,8 @@ class TraceEventTimelineImporterTest(unittest.TestCase): |
'tid': 53, 'ph': 'S', 'id': 72} |
] |
- timeline_data = tracing_timeline_data.TracingTimelineData(events) |
- m = timeline_model.TimelineModel(timeline_data=timeline_data) |
+ trace_value = trace_value_module.TraceValue(events) |
+ m = timeline_model.TimelineModel(trace_value) |
t = m.GetAllProcesses()[0].threads[53] |
self.assertTrue(t is not None) |
@@ -1006,8 +869,8 @@ class TraceEventTimelineImporterTest(unittest.TestCase): |
{'name': 'c', 'args': {}, 'pid': 52, 'ts': 558, 'cat': 'test', |
'tid': 53, 'ph': 'P'} |
] |
- timeline_data = tracing_timeline_data.TracingTimelineData(events) |
- m = timeline_model.TimelineModel(timeline_data=timeline_data) |
+ trace_value = trace_value_module.TraceValue(events) |
+ m = timeline_model.TimelineModel(trace_value) |
p = m.GetAllProcesses()[0] |
t = p.threads[53] |
self.assertEqual(3, len(t.samples)) |
@@ -1028,8 +891,8 @@ class TraceEventTimelineImporterTest(unittest.TestCase): |
{'name': 'c', 'pid': 52, 'ts': 549, 'cat': 'test', |
'tid': 53, 'ph': 'P'} |
] |
- timeline_data = tracing_timeline_data.TracingTimelineData(events) |
- m = timeline_model.TimelineModel(timeline_data=timeline_data) |
+ trace_value = trace_value_module.TraceValue(events) |
+ m = timeline_model.TimelineModel(trace_value) |
p = m.GetAllProcesses()[0] |
t = p.threads[53] |
self.assertEqual(3, len(t.samples)) |
@@ -1044,8 +907,8 @@ class TraceEventTimelineImporterTest(unittest.TestCase): |
{'name': 'c', 'args': {}, 'pid': 52, 'ts': 740, 'tts': 625, 'cat': 'baz', |
'tid': 53, 'ph': 'X'}, |
] |
- timeline_data = tracing_timeline_data.TracingTimelineData(events) |
- m = timeline_model.TimelineModel(timeline_data=timeline_data) |
+ trace_value = trace_value_module.TraceValue(events) |
+ m = timeline_model.TimelineModel(trace_value) |
p = m.GetAllProcesses()[0] |
t = p.threads[53] |
self.assertEqual(3, len(t.all_slices)) |
@@ -1088,8 +951,8 @@ class TraceEventTimelineImporterTest(unittest.TestCase): |
'ph': 'f', 'args': {}}, |
] |
- timeline_data = tracing_timeline_data.TracingTimelineData(events) |
- m = timeline_model.TimelineModel(timeline_data=timeline_data) |
+ trace_value = trace_value_module.TraceValue(events) |
+ m = timeline_model.TimelineModel(trace_value) |
p = m.GetAllProcesses()[0] |
t = p.threads[53] |
self.assertTrue(t is not None) |
@@ -1132,8 +995,8 @@ class TraceEventTimelineImporterTest(unittest.TestCase): |
] |
expected = [[0.4, 0.412], [0.0, 0.422], [0.412, 0.432]] |
- timeline_data = tracing_timeline_data.TracingTimelineData(events) |
- m = timeline_model.TimelineModel(timeline_data=timeline_data) |
+ trace_value = trace_value_module.TraceValue(events) |
+ m = timeline_model.TimelineModel(trace_value) |
self.assertEqual(3, len(m.flow_events)) |
for i in range(len(expected)): |
@@ -1152,65 +1015,6 @@ class TraceEventTimelineImporterTest(unittest.TestCase): |
'ph': 't', 'args': {}}, |
] |
- timeline_data = tracing_timeline_data.TracingTimelineData(events) |
- m = timeline_model.TimelineModel(timeline_data=timeline_data) |
+ trace_value = trace_value_module.TraceValue(events) |
+ m = timeline_model.TimelineModel(trace_value) |
self.assertEqual(0, len(m.flow_events)) |
- |
- def testImportOverflowedTrace(self): |
- events = [ |
- {'name': 'a', 'args': {}, 'pid': 1, 'ts': 7, 'cat': 'foo', |
- 'tid': 1, 'ph': 'B'}, |
- {'name': 'a', 'args': {}, 'pid': 1, 'ts': 8, 'cat': 'foo', |
- 'tid': 1, 'ph': 'E'}, |
- {'name': 'b', 'args': {}, 'pid': 2, 'ts': 9, 'cat': 'foo', |
- 'tid': 2, 'ph': 'B'}, |
- {'name': 'b', 'args': {}, 'pid': 2, 'ts': 10, 'cat': 'foo', |
- 'tid': 2, 'ph': 'E'}, |
- {'name': 'trace_buffer_overflowed', |
- 'args': {'overflowed_at_ts': 12}, |
- 'pid': 2, 'ts': 0, 'tid': 2, 'ph': 'M'} |
- ] |
- timeline_data = tracing_timeline_data.TracingTimelineData(events) |
- |
- with self.assertRaises(trace_event_importer.TraceBufferOverflowException) \ |
- as context: |
- timeline_model.TimelineModel(timeline_data=timeline_data) |
- self.assertTrue( |
- 'Trace buffer of process with pid=2 overflowed at timestamp 12' in |
- context.exception.message) |
- |
- |
- def testTraceEventsWithTabIdsMarkers(self): |
- trace_events = [ |
- {'name': 'a', 'args': {}, 'pid': 1, 'ts': 20, 'tts': 10, 'cat': 'foo', |
- 'tid': 1, 'ph': 'B'}, |
- # tab-id-1 |
- {'name': 'tab-id-1', 'args': {}, 'pid': 1, 'ts': 25, 'cat': 'foo', |
- 'tid': 1, |
- 'ph': 'S', 'id': 72}, |
- {'name': 'a', 'args': {}, 'pid': 1, 'ts': 30, 'tts': 20, 'cat': 'foo', |
- 'tid': 1, 'ph': 'E'}, |
- {'name': 'tab-id-1', 'args': {}, 'pid': 1, 'ts': 35, 'cat': 'foo', |
- 'tid': 1, |
- 'ph': 'F', 'id': 72}, |
- # tab-id-2 |
- {'name': 'tab-id-2', 'args': {}, 'pid': 1, 'ts': 25, 'cat': 'foo', |
- 'tid': 2, |
- 'ph': 'S', 'id': 72}, |
- {'name': 'tab-id-2', 'args': {}, 'pid': 1, 'ts': 26, 'cat': 'foo', |
- 'tid': 2, |
- 'ph': 'F', 'id': 72}, |
- ] |
- event_data = {'traceEvents': trace_events, |
- 'tabIds': ['tab-id-1', 'tab-id-2']} |
- timeline_data = tracing_timeline_data.TracingTimelineData(event_data) |
- m = timeline_model.TimelineModel(timeline_data=timeline_data) |
- processes = m.GetAllProcesses() |
- self.assertEqual(1, len(processes)) |
- self.assertIs(processes[0], m.GetRendererProcessFromTabId('tab-id-1')) |
- self.assertIs(processes[0], m.GetRendererProcessFromTabId('tab-id-2')) |
- |
- p = processes[0] |
- self.assertEqual(2, len(p.threads)) |
- self.assertIs(p.threads[1], m.GetRendererThreadFromTabId('tab-id-1')) |
- self.assertIs(p.threads[2], m.GetRendererThreadFromTabId('tab-id-2')) |