1 # Copyright 2016 The Chromium OS Authors. All rights reserved. 2 # Use of this source code is governed by a BSD-style license that can be 3 # found in the LICENSE file. 4 5 """Tester feedback backend service implementation.""" 6 7 import SimpleXMLRPCServer 8 import multiprocessing 9 10 import feedback_delegate 11 import request_multiplexer 12 13 # TODO(garnold) Load query delegate implementations as they become available 14 # (b/26769927). 15 # pylint: disable=unused-import 16 import audio_query_delegate_impl 17 18 19 class FeedbackService(object): 20 """The feedback service main object.""" 21 22 def __init__(self): 23 self._multiplexer = None 24 self._server_port = 0 25 self._server_process = None 26 self._running = False 27 28 29 @property 30 def server_port(self): 31 """Returns the service listening port.""" 32 return self._server_port 33 34 35 def start(self): 36 """Starts the feedback service.""" 37 if self._running: 38 return 39 40 # Start the feedback request multiplexer. 41 self._multiplexer = request_multiplexer.FeedbackRequestMultiplexer() 42 self._multiplexer.start() 43 44 # Start the feedback delegate RPC server. 45 rpc_server = SimpleXMLRPCServer.SimpleXMLRPCServer(('localhost', 0)) 46 rpc_server.register_instance( 47 feedback_delegate.FeedbackDelegate(self._multiplexer)) 48 self._server_port = rpc_server.server_address[1] 49 self._server_process = multiprocessing.Process( 50 target=rpc_server.serve_forever) 51 self._server_process.start() 52 53 self._running = True 54 55 56 def stop(self): 57 """Stops the feedback service.""" 58 if not self._running: 59 return 60 61 # Stop the RPC server. 62 self._server_process.terminate() 63 self._server_process.join() 64 self._server_port = 0 65 66 # Stop the multiplexer. 67 self._multiplexer.stop() 68 69 self._running = False 70
