diff options
author | Chris Craik <ccraik@google.com> | 2017-03-29 15:00:32 -0700 |
---|---|---|
committer | Chris Craik <ccraik@google.com> | 2017-03-29 15:05:30 -0700 |
commit | d0ebf633155e2d637d289933ef7dbc5d86f73881 (patch) | |
tree | df2eac86f23cb2dab056b1972c16a6222e005a89 /catapult/telemetry/third_party/websocket-client/examples/echoapp_client.py | |
parent | 6f2b0c6d0bda132ba19956163f25b42919940261 (diff) | |
download | chromium-trace-d0ebf633155e2d637d289933ef7dbc5d86f73881.tar.gz |
Update to latest catapult (c69b7871)
Bug:21565824
Bug:34394562
Bug:36573168
Test: ./systrace.py
Notable changes:
- Freq tracing on by default
- Binder driver tracing on by default
- Renderscript tracing on by default (on M+ devices)
- UI thread ordering fixed
- Async sections no longer shown twice
Change-Id: I83e4b2a3964aa8898e638def81fbe3603e2a51cc
Diffstat (limited to 'catapult/telemetry/third_party/websocket-client/examples/echoapp_client.py')
-rw-r--r-- | catapult/telemetry/third_party/websocket-client/examples/echoapp_client.py | 48 |
1 files changed, 48 insertions, 0 deletions
diff --git a/catapult/telemetry/third_party/websocket-client/examples/echoapp_client.py b/catapult/telemetry/third_party/websocket-client/examples/echoapp_client.py new file mode 100644 index 00000000..c15b35f0 --- /dev/null +++ b/catapult/telemetry/third_party/websocket-client/examples/echoapp_client.py @@ -0,0 +1,48 @@ +import websocket +try: + import thread +except ImportError: # TODO use Threading instead of _thread in python3 + import _thread as thread +import time +import sys + + +def on_message(ws, message): + print(message) + + +def on_error(ws, error): + print(error) + + +def on_close(ws): + print("### closed ###") + + +def on_open(ws): + def run(*args): + for i in range(3): + # send the message, then wait + # so thread doesn't exit and socket + # isn't closed + ws.send("Hello %d" % i) + time.sleep(1) + + time.sleep(1) + ws.close() + print("Thread terminating...") + + thread.start_new_thread(run, ()) + +if __name__ == "__main__": + websocket.enableTrace(True) + if len(sys.argv) < 2: + host = "ws://echo.websocket.org/" + else: + host = sys.argv[1] + ws = websocket.WebSocketApp(host, + on_message=on_message, + on_error=on_error, + on_close=on_close) + ws.on_open = on_open + ws.run_forever() |