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 chrome_profiler 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 |