Introduce WPTServe for running W3C Blink Layout tests

Tools/Scripts/webkitpy/layout_tests/servers/wptserve.py

Index: Tools/Scripts/webkitpy/layout_tests/servers/wptserve.py
diff --git a/Tools/Scripts/webkitpy/layout_tests/servers/wptserve.py b/Tools/Scripts/webkitpy/layout_tests/servers/wptserve.py
new file mode 100644
index 0000000000000000000000000000000000000000..9a0a6037874f3a7c21c1b80c31399d93796f81d1
--- /dev/null
+++ b/Tools/Scripts/webkitpy/layout_tests/servers/wptserve.py
@@ -0,0 +1,80 @@
+# 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.
+
+"""Start and stop the WPTserve servers as they're used by the layout tests."""
+
+import logging
+import os
+import socket
+
+from webkitpy.layout_tests.servers import server_base
+
+
+_log = logging.getLogger(__name__)
+
+
+class WPTServe(server_base.ServerBase):
+    def __init__(self, port_obj, output_dir):
+        super(WPTServe, self).__init__(port_obj, output_dir)
+        # These ports must match wpt_support/wpt.config.json
+        http_port, http_alt_port, https_port = (8001, 8081, 8444)
+        ws_port, wss_port = (9001, 9444)
+        self._name = 'wptserve'
+        self._log_prefixes = ('access_log', 'error_log')
+        self._mappings = [{'port': http_port},
+                          {'port': http_alt_port},
+                          {'port': https_port, 'sslcert': True},
+                          {'port': ws_port},
+                          {'port': wss_port, 'sslcert': True}]
+
+        # TODO(burnik): We can probably avoid PID files for WPT in the future.
+        self._pid_file = self._filesystem.join(self._runtime_path, '%s.pid' % self._name)
+
+        script_path = os.path.dirname(os.path.abspath(__file__))
+        path_to_wpt_support = os.path.join(script_path, 'wpt_support')
+        self._path_to_wpt = os.path.join(path_to_wpt_support, 'wpt')
+        self._executable = os.path.join(self._path_to_wpt, 'serve')
+        path_to_wpt_config = os.path.join(path_to_wpt_support, 'wpt.config.json')
+        path_to_wpt_tests = os.path.abspath(os.path.join(self._port_obj.layout_tests_dir(),
+                                                         'imported', 'web-platform-tests'))
+        path_to_ws_handlers = os.path.join(path_to_wpt_tests, 'websockets', 'handlers')
+        start_cmd = [self._executable,
+                     '--config', path_to_wpt_config,
+                     '--doc_root', path_to_wpt_tests]
+
+        # TODO(burnik): Merge with default start_cmd once we roll in websockets.
+        if self._port_obj.host.filesystem.exists(path_to_ws_handlers):
+            start_cmd += ['--ws_doc_root', path_to_ws_handlers]
+
+        self._start_cmd = start_cmd
+
+    def _spawn_process(self):
+        _log.debug('Starting %s server, cmd="%s"' % (self._name, str(self._start_cmd)))
+        self._process = self._executive.popen(' '.join(self._start_cmd),
+                                              cwd=self._path_to_wpt,
+                                              shell=True,
+                                              stdout=self._executive.DEVNULL,
+                                              stderr=self._executive.DEVNULL,
+                                              preexec_fn=os.setsid)
+
+        # We probably won't need a PID file, but server_base needs it.
+        fs = self._port_obj.host.filesystem
+        fs.write_text_file(self._pid_file, str(self._process.pid))
+        return self._process.pid
+
+    def stop(self):
+        self._stop_running_server()
+
+    def _stop_running_server(self):
+        # Clean up the pid file.
+        if self._pid and not self._executive.check_running_pid(self._pid):
+            self._filesystem.remove(self._pid_file)
+            return
+
+        # TODO(burnik): Figure out a cleaner way of stopping wptserve.
+        self._executive.interrupt(self._pid)
+
+        # According to Popen.wait(), this can deadlock when using stdout=PIPE and/or stderr=PIPE.
+        # We're using DEVNULL for both so that should not occur.
+        self._process.wait()