| # Copyright 2016 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. |
| |
| """Tester feedback backend service implementation.""" |
| |
| import SimpleXMLRPCServer |
| import multiprocessing |
| |
| import feedback_delegate |
| import request_multiplexer |
| |
| # TODO(garnold) Load query delegate implementations as they become available |
| # (b/26769927). |
| # pylint: disable=unused-import |
| import audio_query_delegate_impl |
| |
| |
| class FeedbackService(object): |
| """The feedback service main object.""" |
| |
| def __init__(self): |
| self._multiplexer = None |
| self._server_port = 0 |
| self._server_process = None |
| self._running = False |
| |
| |
| @property |
| def server_port(self): |
| """Returns the service listening port.""" |
| return self._server_port |
| |
| |
| def start(self): |
| """Starts the feedback service.""" |
| if self._running: |
| return |
| |
| # Start the feedback request multiplexer. |
| self._multiplexer = request_multiplexer.FeedbackRequestMultiplexer() |
| self._multiplexer.start() |
| |
| # Start the feedback delegate RPC server. |
| rpc_server = SimpleXMLRPCServer.SimpleXMLRPCServer(('localhost', 0)) |
| rpc_server.register_instance( |
| feedback_delegate.FeedbackDelegate(self._multiplexer)) |
| self._server_port = rpc_server.server_address[1] |
| self._server_process = multiprocessing.Process( |
| target=rpc_server.serve_forever) |
| self._server_process.start() |
| |
| self._running = True |
| |
| |
| def stop(self): |
| """Stops the feedback service.""" |
| if not self._running: |
| return |
| |
| # Stop the RPC server. |
| self._server_process.terminate() |
| self._server_process.join() |
| self._server_port = 0 |
| |
| # Stop the multiplexer. |
| self._multiplexer.stop() |
| |
| self._running = False |
