Chromium Code Reviews| Index: tools/telemetry/telemetry/results/page_test_results.py |
| diff --git a/tools/telemetry/telemetry/results/page_test_results.py b/tools/telemetry/telemetry/results/page_test_results.py |
| index fe01c0be1a1655644e38814eeaddc64df74474b8..5d907c6425e34712e02f94d4c03b14a26f440a03 100644 |
| --- a/tools/telemetry/telemetry/results/page_test_results.py |
| +++ b/tools/telemetry/telemetry/results/page_test_results.py |
| @@ -4,18 +4,14 @@ |
| import collections |
| import copy |
| -import datetime |
| import itertools |
| -import logging |
| -import random |
| -import sys |
| import traceback |
| from telemetry import value as value_module |
| from telemetry.results import page_run |
| from telemetry.results import progress_reporter as progress_reporter_module |
| -from telemetry.util import cloud_storage |
| from telemetry.value import failure |
| +from telemetry.value import profiler |
| from telemetry.value import skip |
| from telemetry.value import trace |
| @@ -49,8 +45,6 @@ class PageTestResults(object): |
| self._all_page_runs = [] |
| self._representative_value_for_each_value_name = {} |
| self._all_summary_values = [] |
| - self._pages_to_profiling_files = collections.defaultdict(list) |
| - self._pages_to_profiling_files_cloud_url = collections.defaultdict(list) |
| def __copy__(self): |
| cls = self.__class__ |
| @@ -62,10 +56,6 @@ class PageTestResults(object): |
| return result |
| @property |
| - def pages_to_profiling_files_cloud_url(self): |
| - return self._pages_to_profiling_files_cloud_url |
| - |
| - @property |
| def all_page_specific_values(self): |
| values = [] |
| for run in self._all_page_runs: |
| @@ -154,9 +144,6 @@ class PageTestResults(object): |
| self._current_page_run.AddValue(value) |
| self._progress_reporter.DidAddValue(value) |
| - def AddProfilingFile(self, page, file_handle): |
| - self._pages_to_profiling_files[page].append(file_handle) |
| - |
| def AddSummaryValue(self, value): |
| assert value.page is None |
| self._ValidateValue(value) |
| @@ -189,26 +176,24 @@ class PageTestResults(object): |
| values.append(value) |
| return values |
| - def UploadTraceFilesToCloud(self, bucket): |
| + def FindAllTraceValue(self): |
|
nednguyen
2014/11/20 02:04:11
FindAllTraceValues
Yufeng Shen (Slow to review)
2014/11/20 17:56:15
Done.
|
| + values = [] |
| for value in self.all_page_specific_values: |
| if isinstance(value, trace.TraceValue): |
| - value.UploadToCloud(bucket) |
| + values.append(value) |
| + return values |
| + |
| + def FindAllProfilerValue(self): |
|
nednguyen
2014/11/20 02:04:11
FindAllProfilerValues
Yufeng Shen (Slow to review)
2014/11/20 17:56:15
removed.
|
| + values = [] |
| + for value in self.all_page_specific_values: |
| + if isinstance(value, profiler.ProfilerValue): |
| + values.append(value) |
| + return values |
| + |
| + def UploadTraceFilesToCloud(self, bucket): |
| + for value in self.FindAllTraceValue(): |
| + value.UploadToCloud(bucket) |
| def UploadProfilingFilesToCloud(self, bucket): |
| - for page, file_handle_list in self._pages_to_profiling_files.iteritems(): |
| - for file_handle in file_handle_list: |
| - remote_path = ('profiler-file-id_%s-%s%-d%s' % ( |
| - file_handle.id, |
| - datetime.datetime.now().strftime('%Y-%m-%d_%H-%M-%S'), |
| - random.randint(1, 100000), |
| - file_handle.extension)) |
| - try: |
| - cloud_url = cloud_storage.Insert( |
| - bucket, remote_path, file_handle.GetAbsPath()) |
| - sys.stderr.write( |
| - 'View generated profiler files online at %s for page %s\n' % |
| - (cloud_url, page.display_name)) |
| - self._pages_to_profiling_files_cloud_url[page].append(cloud_url) |
| - except cloud_storage.PermissionError as e: |
| - logging.error('Cannot upload profiling files to cloud storage due to ' |
| - ' permission error: %s' % e.message) |
| + for value in self.FindAllProfilerValue(): |
| + value.UploadToCloud(bucket) |