Method server_handler

tests/ctl/test_client.py:150–158

()

            response_sent = threading.Event()

            def server_handler():
                conn, _ = server_sock.accept()
                try:
                    msg = ControlProtocol.read_message(conn)
                    resp = make_response(msg["id"], response_data)
                    ControlProtocol.write_message(conn, resp)
                    response_sent.set()
                finally:
                    conn.close()

            server_thread = threading.Thread(target=server_handler)
            server_thread.start()