CT Skia recipe to run DM on the top 10k SKPs using swarming

scripts/slave/recipes/skia/ct_10k_skps_dm.py

Index: scripts/slave/recipes/skia/ct_10k_skps_dm.py
diff --git a/scripts/slave/recipes/skia/ct_10k_skps_dm.py b/scripts/slave/recipes/skia/ct_10k_skps_dm.py
new file mode 100644
index 0000000000000000000000000000000000000000..f3fdf97ce0d090a1db75f17c54d56e119d53d33b
--- /dev/null
+++ b/scripts/slave/recipes/skia/ct_10k_skps_dm.py
@@ -0,0 +1,115 @@
+# Copyright 2015 The Chromium Authors. All rights reserved.
+# Use of this source code is governed by a BSD-style license that can be
+# found in the LICENSE file.
+
+from common.skia import global_constants
+
+
+DEPS = [
+  'ct_swarming',
+  'file',
+  'gclient',
+  'path',
+  'properties',
+  'step',
+  'swarming',
+  'swarming_client',
+]
+
+
+CT_PAGE_TYPE = '10k'
+CT_DM_ISOLATE = 'ct_dm.isolate'
+
+# Number of slaves to shard CT runs to.
+DEFAULT_CT_NUM_SLAVES = 100
+
+# The SKP repository to use.
+DEFAULT_SKPS_CHROMIUM_BUILD = '310ea93-42bd6bf'
+
+
+def RunSteps(api):
+  # Checkout Skia and Chromium.
+  gclient_cfg = api.gclient.make_config()
+  src = gclient_cfg.solutions.add()
+  src.name = 'src'
+  src.url = 'https://chromium.googlesource.com/chromium/src.git'
+  skia = gclient_cfg.solutions.add()
+  skia.name = 'skia'
+  skia.url = global_constants.SKIA_REPO
+  gclient_cfg.got_revision_mapping['skia'] = 'got_revision'
+  api.gclient.checkout(gclient_config=gclient_cfg)
+
+  # Checkout Swarming scripts.
+  api.swarming_client.checkout()
+  # Ensure swarming_client is compatible with what recipes expect.
+  api.swarming.check_client_version()
+
+  chromium_checkout = api.path['checkout']
+
+  # Build DM in Debug mode.
+  api.step('build dm', ['make', 'dm'], cwd=api.path['slave_build'].join('skia'))
+
+  # TODO(rmistry): Remove the following after crrev.com/1469823003 is submitted.
+  api.file.copy(
+      'copy %s' % CT_DM_ISOLATE,
+      '/repos/chromium/src/chrome/%s' % CT_DM_ISOLATE,
+      chromium_checkout.join('chrome', CT_DM_ISOLATE))
+  for f in ['run_ct_dm.py']:
+    api.file.copy(
+        'copy %s' % f,
+        '/repos/chromium/src/content/test/ct/%s' % f,
+        chromium_checkout.join('content', 'test', 'ct', f))
+
+  skps_chromium_build = api.properties.get(
+      'skps_chromium_build', DEFAULT_SKPS_CHROMIUM_BUILD)
+  ct_num_slaves = api.properties.get('ct_num_slaves', DEFAULT_CT_NUM_SLAVES)
+
+  for slave_num in range(1, ct_num_slaves + 1):
+    # Download SKPs.
+    api.ct_swarming.download_skps(CT_PAGE_TYPE, slave_num, skps_chromium_build)
+
+    # Create this slave's isolated.gen.json file to use for batcharchiving.
+    isolate_dir = chromium_checkout.join('chrome')
+    isolate_path = isolate_dir.join(CT_DM_ISOLATE)
+    extra_variables = {
+        'SLAVE_NUM': str(slave_num),
+    }
+    api.ct_swarming.create_isolated_gen_json(
+        isolate_path, isolate_dir, 'linux', slave_num, extra_variables)
+
+  # Batcharchive everything on the isolate server for efficiency.
+  api.ct_swarming.batcharchive(ct_num_slaves)
+  swarm_hashes = (
+      api.step.active_result.presentation.properties['swarm_hashes']).values()
+
+  # Trigger all swarming tasks.
+  tasks = api.ct_swarming.trigger_swarming_tasks(
+      swarm_hashes, task_name_prefix='ct-10k-dm',
+      dimensions={'os': 'Ubuntu', 'gpu': '10de'})
+
+  # Now collect all tasks.
+  api.ct_swarming.collect_swarming_tasks(tasks)
+
+
+def GenTests(api):
+  parent_got_swarming_client_revision = '12345'
+  ct_num_slaves = 5
+
+  yield(
+    api.test('CT_DM_10k_SKPs') +
+    api.properties(
+        buildername='CT-DM-10k-SKPs',
+        parent_got_swarming_client_revision=parent_got_swarming_client_revision,
+        ct_num_slaves=ct_num_slaves,
+    )
+  )
+
+  yield(
+    api.test('CT_DM_10k_SKPs_slave3_failure') +
+    api.step_data('ct-10k-dm-3 on Ubuntu', retcode=1) +
+    api.properties(
+        buildername='CT-DM-10k-SKPs',
+        parent_got_swarming_client_revision=parent_got_swarming_client_revision,
+        ct_num_slaves=ct_num_slaves,
+    )
+  )