OLD | NEW |
| (Empty) |
1 # Copyright 2014 The Chromium Authors. All rights reserved. | |
2 # Use of this source code is governed by a BSD-style license that can be | |
3 # found in the LICENSE file. | |
4 | |
5 import gzip | |
6 import json | |
7 import os | |
8 import shutil | |
9 import sys | |
10 import zipfile | |
11 | |
12 from adb_profile_chrome import util | |
13 | |
14 from pylib import constants | |
15 | |
16 sys.path.append(os.path.join(constants.DIR_SOURCE_ROOT, | |
17 'third_party', | |
18 'trace-viewer')) | |
19 # pylint: disable=F0401 | |
20 from trace_viewer.build import trace2html | |
21 | |
22 | |
23 def _PackageTracesAsHtml(trace_files, html_file): | |
24 with open(html_file, 'w') as f: | |
25 trace2html.WriteHTMLForTracesToFile(trace_files, f) | |
26 for trace_file in trace_files: | |
27 os.unlink(trace_file) | |
28 | |
29 | |
30 def _CompressFile(host_file, output): | |
31 with gzip.open(output, 'wb') as out, \ | |
32 open(host_file, 'rb') as input_file: | |
33 out.write(input_file.read()) | |
34 os.unlink(host_file) | |
35 | |
36 | |
37 def _ArchiveFiles(host_files, output): | |
38 with zipfile.ZipFile(output, 'w', zipfile.ZIP_DEFLATED) as z: | |
39 for host_file in host_files: | |
40 z.write(host_file) | |
41 os.unlink(host_file) | |
42 | |
43 | |
44 def _MergeTracesIfNeeded(trace_files): | |
45 if len(trace_files) <= 1: | |
46 return trace_files | |
47 merge_candidates = [] | |
48 for trace_file in trace_files: | |
49 with open(trace_file) as f: | |
50 # Try to detect a JSON file cheaply since that's all we can merge. | |
51 if f.read(1) != '{': | |
52 continue | |
53 f.seek(0) | |
54 try: | |
55 json_data = json.load(f) | |
56 except ValueError: | |
57 continue | |
58 merge_candidates.append((trace_file, json_data)) | |
59 if len(merge_candidates) <= 1: | |
60 return trace_files | |
61 | |
62 other_files = [f for f in trace_files | |
63 if not f in [c[0] for c in merge_candidates]] | |
64 merged_file, merged_data = merge_candidates[0] | |
65 for trace_file, json_data in merge_candidates[1:]: | |
66 for key, value in json_data.items(): | |
67 if not merged_data.get(key) or json_data[key]: | |
68 merged_data[key] = value | |
69 os.unlink(trace_file) | |
70 | |
71 with open(merged_file, 'w') as f: | |
72 json.dump(merged_data, f) | |
73 return [merged_file] + other_files | |
74 | |
75 | |
76 def PackageTraces(trace_files, output=None, compress=False, write_json=False): | |
77 trace_files = _MergeTracesIfNeeded(trace_files) | |
78 if not write_json: | |
79 html_file = os.path.splitext(trace_files[0])[0] + '.html' | |
80 _PackageTracesAsHtml(trace_files, html_file) | |
81 trace_files = [html_file] | |
82 | |
83 if compress and len(trace_files) == 1: | |
84 result = output or trace_files[0] + '.gz' | |
85 _CompressFile(trace_files[0], result) | |
86 elif len(trace_files) > 1: | |
87 result = output or 'chrome-combined-trace-%s.zip' % util.GetTraceTimestamp() | |
88 _ArchiveFiles(trace_files, result) | |
89 elif output: | |
90 result = output | |
91 shutil.move(trace_files[0], result) | |
92 else: | |
93 result = trace_files[0] | |
94 return result | |
OLD | NEW |