Batched update of factory tests.

client/site_tests/suite_Factory/control

 # -*- coding: utf-8 -*-
 #
 # Copyright (c) 2010 The Chromium OS Authors. All rights reserved.
 # Use of this source code is governed by a BSD-style license that can be
 # found in the LICENSE file.
 
 AUTHOR = "Chrome OS Team"
 NAME = "Factory"
 TIME = "LONG"
 TEST_CATEGORY = "Functional"
@@ skipping 17 matching lines @@
 import time
 
 
 _FACTORY_LOG_PATH = '/var/log/factory.log'
 _RESULT_FILE_PATH = '/var/run/factory_test_result'
 
 _REBOOT_SEQ_ITERATIONS = 2
 
 
 def XXX_log(s):
-    print >> sys.stderr, '--- XXX : ' + s
+    print >> sys.stderr, 'FACTORY: ' + s
 
 
 # Hack to work around autotest's obsession with GRUB.
 job.bootloader.set_default = lambda x: None
 job.bootloader.boot_once = lambda x: None
 
 
 # This is the definition of the test_data class, which holds
 # factory-specific information on the tests to be run.  Specifically,
 # the order of items in the list reflect the order they are to be run
@@ skipping 23 matching lines @@
 
 
 test_list = [
     test_data(
         label_en='start',
         formal_name='factory_Dummy',
         trigger='a',
         dargs={'quit_key':ord(' '),
                'msg':'Hit SPACE to start testing...\n按 "空白鍵" 開始測試...'}),
     test_data(
+        label_en='sync',
+        formal_name='factory_ScriptWrapper',
+        trigger='s',
+        dargs={'cmdline':'/usr/local/autotest/exscr'}),
+    test_data(
+        label_en='leds',
+        formal_name='factory_Dummy',
+        trigger='l',
+        dargs={'msg':'LEDs test, one day...'}),
+   test_data(
+        label_en='usb',
+        formal_name='factory_ExternalStorage',
+        trigger='u'),
+   test_data(
+        label_en='display',
+        formal_name='factory_Display',
+        trigger='m'),
+    test_data(
+        label_en='camera',
+        formal_name='factory_Dummy',
+        trigger='c',
+        dargs={'msg':'camera test, one day...'}),
+    test_data(
+        label_en='keyboard',
+        label_zw='鍵盤',
+        formal_name='factory_Keyboard',
+        trigger='k',
+        dargs={'layout':'en_us'}),
+    test_data(
+        label_en='touchpad',
+        label_zw='觸控板',
+        formal_name='factory_Synaptics',
+        trigger='t'),
+    test_data(
         label_en='run-in',
         formal_name='step_runin',
         automated_seq=[
             test_data(
                 label_en='component validation',
-                formal_name='hardware_Components'),
+                formal_name='hardware_Components',
+                dargs={'approved_db':'qualified_components'}),
             test_data(
                 label_en='gpio switch check',
                 formal_name='hardware_GPIOSwitches'),
             test_data(
                 label_en='system stress',
                 formal_name='hardware_SAT'),
             test_data(
                 label_en='reboot (%s times)' % _REBOOT_SEQ_ITERATIONS,
                 formal_name='factory_RebootStub')],
         trigger='r'),
     test_data(
-        label_en='camera',
+        label_en='end',
         formal_name='factory_Dummy',
-        trigger='c',
-        dargs={'msg':'camera test, one day...'}),
-    test_data(
-        label_en='keyboard',
-        label_zw='鍵盤',
-        formal_name='factory_Keyboard',
-        trigger='k',
-        dargs={'layout':'en_us'}),
-    test_data(
-        label_en='trackpad',
-        label_zw='觸控板',
-        formal_name='hardware_Touchpad',
-        trigger='t'),
+        trigger='e',
+        dargs={'msg':'end of testing...\n(chinese)...'}),
 ]
 
 for test in test_list:
     test.tag_prefix = test.trigger
     for subtest in test.automated_seq:
         subtest.tag_prefix = test.formal_name
 
 def test_map_index(formal_name, tag_prefix):
     return formal_name + '.' + tag_prefix
 
@@ skipping 32 matching lines @@
         self.send(('switch_to', trigger))
 
     def recv(self):
         return eval(self._proc.stdout.readline().rstrip())
 
     def recv_target_test_update(self):
         update = self.recv()
         XXX_log('control recv target test %s' % repr(update))
         formal_name, tag_prefix, count = update
         test = test_map.get(test_map_index(formal_name, tag_prefix), None)
-        if test is not None:
-            test.count = count
-        return test
+        return (test, count)
 
 
 def step_reboot_seq(i, tag):
     if i < _REBOOT_SEQ_ITERATIONS:
-        job.next_step([step_reboot_seq, i + 1, tag])
+        job.next_step_prepend([step_reboot_seq, i + 1, tag])
         XXX_log('rebooting (iteration %d)' % i)
         time.sleep(5)
         job.reboot()
     else:
         job.run_test('factory_RebootStub', tag=tag)
         step_init()
 
 
 def step_runin(ui, tag):
     job.run_test('hardware_Components',
                  approved_db='qualified_components',
                  tag=tag)
-    ui.send()
     job.run_test('hardware_GPIOSwitches', tag=tag)
-    ui.send()
     job.drop_caches_between_iterations = True
     job.run_test('hardware_SAT', tag=tag)
     job.drop_caches_between_iterations = False
-    ui.send()
     step_reboot_seq(0, tag)
 
 
 def step_init():
 
     '''Launch the factory UI, which will then make decisions on which
     tests to run in which order.  This is to support user driven
     out-of-order test execution based on keyboard shortcuts.
 
     For each test, a trigger (possibly None) is communicated to the
     UI, which then replies with the test name and a count number that
     becomes the autotest tag to allow repeated test execution while
     preserving logs.
 
     When the tests themselves run, they are expected to look for
     (using the factory_test library) keyboard events that match test
     switching triggers.  When a trigger happens, it should be written
     to the _RESULT_FILE_PATH, which will be read after the test
     completed and the result comminicated onwards to the UI.'''
 
+    job.next_step([step_init])
+
     status_file_path = job.autodir + '/results/default/status'
-    factory_ui_path = job.autodir + '/factory_ui'
+    factory_ui_path = job.autodir + '/deps/factory/ui'
 
     ui = factory_ui(factory_ui_path)
 
     ui.send(test_data_class_def)
     ui.send(test_list)
     ui.send(status_file_path)
     ui.send(_FACTORY_LOG_PATH)
 
     test_widget_size = ui.recv()
     XXX_log('received test_widget_size = %s' % repr(test_widget_size))
 
     ui.send_cmd_next_test()
-    test = ui.recv_target_test_update()
+    test, test_count = ui.recv_target_test_update()
 
     while test is not None:
         if test.automated_seq:
-            tag = '%s_%s' % (test.formal_name, test.count)
+            tag = '%s_%s' % (test.formal_name, test_count)
             exec('%s(ui, "%s")' % (test.formal_name, tag))
             result = None
         else:
             dargs = test.dargs
             dargs.update({
-                'tag': '%s_%s' % (test.tag_prefix, test.count),
+                'tag': '%s_%s' % (test.tag_prefix, test_count),
+                'test_tag_prefix': test.tag_prefix,
+                'test_count': test_count,
                 'test_widget_size': test_widget_size,
                 'trigger_set': trigger_set,
                 'result_file_path': _RESULT_FILE_PATH})
             with open(_RESULT_FILE_PATH, 'w') as file:
                 file.write('None\n')
             job.run_test(test.formal_name, **dargs)
             with open(_RESULT_FILE_PATH, 'r') as file:
                 result = eval(file.readline())
 
         if result is not None:
             ui.send_cmd_switch_to(result)
         else:
             ui.send_cmd_next_test()
 
-        test = ui.recv_target_test_update()
+        test, test_count = ui.recv_target_test_update()
 
     XXX_log('factory testing completed')