diff --git a/webservice_serial/target/android/adb.py b/webservice_serial/target/android/adb.py index c1c8a2f..ea39607 100644 --- a/webservice_serial/target/android/adb.py +++ b/webservice_serial/target/android/adb.py @@ -29,7 +29,7 @@ def __init__(self, command="adb", log=None): self.log = log def start(self, port, activity): - #self.execute('shell am start -n {}'.format(activity)) + self.execute('shell am start -n {}'.format(activity)) #self.execute('forward --remove-all') self.execute('forward tcp:{} tcp:{}'.format(port, port)) diff --git a/webservice_serial/target/android/android_display_view.py b/webservice_serial/target/android/android_display_view.py index b265efb..8a31da6 100644 --- a/webservice_serial/target/android/android_display_view.py +++ b/webservice_serial/target/android/android_display_view.py @@ -19,7 +19,7 @@ class AndroidDisplayView(Target): - activity = 'io.github.pedalpi.pedalpi_display/io.github.pedalpi.displayview.activity.ResumeActivity' + activity = 'io.github.pedalpi.displayview/io.github.pedalpi.displayview.activity.resume.ResumeActivity' def __init__(self): super(AndroidDisplayView, self).__init__() diff --git a/webservice_serial/webservice_serial.py b/webservice_serial/webservice_serial.py index 4562c5c..7cfcd5f 100644 --- a/webservice_serial/webservice_serial.py +++ b/webservice_serial/webservice_serial.py @@ -13,14 +13,12 @@ # limitations under the License. from application.component.component import Component -from webservice_serial.protocol.response_verb import ResponseVerb - +from tornado import gen +from tornado.ioloop import IOLoop from webservice_serial.request_message_processor import RequestMessageProcessor from webservice_serial.webservice_serial_client import WebServiceSerialClient from webservice_serial.websocket_client import WebSocketClient -from time import sleep - class WebServiceSerial(Component): port = 8888 @@ -53,9 +51,13 @@ def init(self): self._try_connect() def _try_connect(self, delay=0): + IOLoop.current().spawn_callback(self.__try_connect, delay) + + @gen.coroutine + def __try_connect(self, delay=0): self._log('Trying to connect with {}', self.target.name) self.target.init(self.application, WebServiceSerial.port) - sleep(delay) + yield gen.sleep(delay) self._client.connect() def _on_token_defined(self, token): diff --git a/webservice_serial/webservice_serial_client.py b/webservice_serial/webservice_serial_client.py index 0af223b..99d99bf 100644 --- a/webservice_serial/webservice_serial_client.py +++ b/webservice_serial/webservice_serial_client.py @@ -34,7 +34,7 @@ def __init__(self, address, port, encoding="utf-8"): self.disconnected_listener = lambda: print('Disconnected :(') def connect(self): - IOLoop.current().spawn_callback(lambda: self._connect()) + IOLoop.current().spawn_callback(self._connect) @gen.coroutine def _connect(self):