| OLD | NEW |
| (Empty) |
| 1 #!/usr/bin/env python | |
| 2 # Copyright (c) 2014 The Chromium Authors. All rights reserved. | |
| 3 # Use of this source code is governed by a BSD-style license that can be | |
| 4 # found in the LICENSE file. | |
| 5 | |
| 6 """Module that downloads SKPs from Google Storage into a specified dir. | |
| 7 | |
| 8 Downloads SKPs which were generated by Cluster Telemetry's GCE slaves using: | |
| 9 http://skia-tree-status.appspot.com/skia-telemetry | |
| 10 """ | |
| 11 | |
| 12 import optparse | |
| 13 import os | |
| 14 import posixpath | |
| 15 import sys | |
| 16 | |
| 17 # This number is unlikely to ever change. | |
| 18 # TODO(rmistry): Read NUMBER_OF_GCE_SLAVES and DEST_GSBASE from a Cluster | |
| 19 # Telemetry global_variables.json | |
| 20 NUMBER_OF_GCE_SLAVES = 100 | |
| 21 # This bucket is also unlikely to ever change (though it would be great if it | |
| 22 # did). | |
| 23 DEST_GSBASE = 'gs://chromium-skia-gm' | |
| 24 | |
| 25 PARENT_DIR = os.path.dirname(os.path.realpath(__file__)) | |
| 26 CHROMIUM_SITE_CONFIG_DIR = os.path.join(PARENT_DIR, os.pardir, 'third_party', | |
| 27 'chromium_buildbot', 'site_config') | |
| 28 | |
| 29 # Set the PYTHONPATH for this script to include chromium_buildbot scripts | |
| 30 # and site_config. Also include skia buildbot's slave utils directory. | |
| 31 sys.path.append( | |
| 32 os.path.join(PARENT_DIR, os.pardir, 'third_party', 'chromium_buildbot', | |
| 33 'scripts')) | |
| 34 sys.path.append(CHROMIUM_SITE_CONFIG_DIR) | |
| 35 sys.path.append( | |
| 36 os.path.join(PARENT_DIR, os.pardir, 'slave', 'skia_slave_scripts', 'utils')) | |
| 37 | |
| 38 import gs_utils | |
| 39 | |
| 40 | |
| 41 def DownloadSKPs(chromium_build, pageset_type, dest_dir): | |
| 42 | |
| 43 # Validate that the .boto file exists. | |
| 44 if not os.path.isfile(os.path.join(CHROMIUM_SITE_CONFIG_DIR, '.boto')): | |
| 45 raise Exception( | |
| 46 'Please copy your .boto file to %s.' % CHROMIUM_SITE_CONFIG_DIR) | |
| 47 | |
| 48 gs_skp_slave_template = posixpath.join( | |
| 49 DEST_GSBASE, 'telemetry', 'skps', 'slave%s', pageset_type, chromium_build) | |
| 50 | |
| 51 # Validate that the requested SKP directory exists for worker1. | |
| 52 if not gs_utils.does_storage_object_exist(gs_skp_slave_template % '1'): | |
| 53 raise Exception( | |
| 54 'There are no SKPs generated for the pageset: %s and the ' | |
| 55 'chromium_build: %s' % (pageset_type, chromium_build)) | |
| 56 | |
| 57 # Create destination directory if it does not exist. | |
| 58 if not os.path.isdir(dest_dir): | |
| 59 os.makedirs(dest_dir) | |
| 60 | |
| 61 # Ensure that the specified destination directory is empty. | |
| 62 if os.listdir(dest_dir): | |
| 63 raise Exception('%s is not empty. Please provide an empty dir.' % dest_dir) | |
| 64 | |
| 65 # Transfer one slave's generated SKPs at a time to the specified directory. | |
| 66 for slave_num in range(1, NUMBER_OF_GCE_SLAVES + 1): | |
| 67 # Create a directory for the slave to download to. | |
| 68 local_slave_dir = os.path.join(dest_dir, chromium_build, | |
| 69 'slave%s' % slave_num) | |
| 70 os.makedirs(local_slave_dir) | |
| 71 # Download from Google Storage to the local slave directory. | |
| 72 gs_utils.copy_storage_directory( | |
| 73 src_dir=posixpath.join(gs_skp_slave_template % slave_num, '*'), | |
| 74 dest_dir=local_slave_dir) | |
| 75 | |
| 76 | |
| 77 if '__main__' == __name__: | |
| 78 option_parser = optparse.OptionParser() | |
| 79 option_parser.add_option( | |
| 80 '-b', '--chromium_build', | |
| 81 help='Specifies which chromium build was used to generate the SKPs. ' | |
| 82 'Eg: e69f2ce-e2b1569. The list of all builds are at: ' | |
| 83 'http://skia-tree-status.appspot.com/skia-telemetry/chromium_builds') | |
| 84 option_parser.add_option( | |
| 85 '-p', '--pageset_type', | |
| 86 help='Specifies the pageset type we want to download. Options are ' | |
| 87 'All/100k/10k/IndexSample10k. Defaults to All.', | |
| 88 default='All') | |
| 89 option_parser.add_option( | |
| 90 '-d', '--dest_dir', | |
| 91 help='Specifies the directory where the SKPs will be downloaded too. %s ' | |
| 92 'slave directories will be created each containing their own ' | |
| 93 'corresponding SKPs.' % NUMBER_OF_GCE_SLAVES) | |
| 94 options, unused_args = option_parser.parse_args() | |
| 95 | |
| 96 # Validate required parameters. | |
| 97 assert options.chromium_build, 'Must specify --chromium_build' | |
| 98 assert options.dest_dir, 'Must specify --dest_dir' | |
| 99 | |
| 100 DownloadSKPs(options.chromium_build, options.pageset_type, options.dest_dir) | |
| 101 | |
| OLD | NEW |