Add an additional content_shell per worker for running virtual tests.

Tools/Scripts/webkitpy/layout_tests/controllers/layout_test_runner_unittest.py

 # Copyright (C) 2012 Google Inc. All rights reserved.
 # Copyright (C) 2010 Gabor Rapcsanyi (rgabor@inf.u-szeged.hu), University of Szeged
 #
 # Redistribution and use in source and binary forms, with or without
 # modification, are permitted provided that the following conditions are
 # met:
 #
 #     * Redistributions of source code must retain the above copyright
 # notice, this list of conditions and the following disclaimer.
 #     * Redistributions in binary form must reproduce the above
@@ skipping 14 matching lines @@
 # DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
 # THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
 # (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
 # OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
 
 import unittest
 
 from webkitpy.common.host_mock import MockHost
 from webkitpy.common.system.systemhost_mock import MockSystemHost
 from webkitpy.layout_tests import run_webkit_tests
-from webkitpy.layout_tests.controllers.layout_test_runner import LayoutTestRunner, Sharder, TestRunInterruptedException
+from webkitpy.layout_tests.controllers.layout_test_runner import DriverHandler, LayoutTestRunner, Sharder, TestRunInterruptedException
 from webkitpy.layout_tests.models import test_expectations
 from webkitpy.layout_tests.models import test_failures
 from webkitpy.layout_tests.models.test_run_results import TestRunResults
 from webkitpy.layout_tests.models.test_input import TestInput
 from webkitpy.layout_tests.models.test_results import TestResult
 from webkitpy.layout_tests.port.test import TestPort
 
 
 TestExpectations = test_expectations.TestExpectations
 
@@ skipping 103 matching lines @@
         self.assertEqual(1, run_results.expected)
         self.assertEqual(0, run_results.unexpected)
 
         run_results = TestRunResults(expectations, 1)
         result = TestResult(test_name=test, failures=[], reftest_type=['=='])
         runner._update_summary_with_result(run_results, result)
         self.assertEqual(0, run_results.expected)
         self.assertEqual(1, run_results.unexpected)
 
 
+class DriverHandlerTests(unittest.TestCase):
+    def _create_driver_handler(self):
+        port = TestPort(MockSystemHost())
+        return DriverHandler("test_driver", 1, "test_worker", port)
+
+    def test_init(self):
+        self.assertFalse(self._create_driver_handler().driver)
+
+    def test_prepare(self):
+        driver_handler = self._create_driver_handler()
+        driver_handler.prepare()
+        self.assertTrue(driver_handler.driver)
+
+    def test_is_prepared(self):
+        driver_handler = self._create_driver_handler()
+        self.assertFalse(driver_handler.is_prepared())
+        driver_handler.prepare()
+        self.assertTrue(driver_handler.is_prepared())
+        driver_handler.kill()
+        self.assertFalse(driver_handler.is_prepared())
+
+    def test_kill(self):
+        driver_handler = self._create_driver_handler()
+        driver_handler.kill()
+        self.assertFalse(driver_handler.driver)
+        driver_handler.prepare()
+        driver_handler.kill()
+        self.assertFalse(driver_handler.driver)
+
+
 class SharderTests(unittest.TestCase):
 
     test_list = [
         "http/tests/websocket/tests/unicode.htm",
         "animations/keyframes.html",
         "http/tests/security/view-source-no-refresh.html",
         "http/tests/websocket/tests/websocket-protocol-ignored.html",
         "fast/css/display-none-inline-style-change-crash.html",
         "http/tests/xmlhttprequest/supported-xml-content-types.html",
         "dom/html/level2/html/HTMLAnchorElement03.html",
@@ skipping 117 matching lines @@
                 test_list=['virtual/foo/bar1.html', 'virtual/foo/bar2.html'])
         self.assert_shards(unlocked,
             [('virtual/foo', ['virtual/foo/bar1.html', 'virtual/foo/bar2.html'])])
 
         # But, with run_singly=True, we have to restart every time anyway, so we want full parallelism.
         locked, unlocked = self.get_shards(num_workers=2, fully_parallel=True, max_locked_shards=2, run_singly=True,
                 test_list=['virtual/foo/bar1.html', 'virtual/foo/bar2.html'])
         self.assert_shards(unlocked,
             [('.', ['virtual/foo/bar1.html']),
              ('.', ['virtual/foo/bar2.html'])])