aboutsummaryrefslogtreecommitdiff
path: root/catapult/telemetry/third_party/websocket-client/examples/echoapp_client.py
diff options
context:
space:
mode:
authorChris Craik <ccraik@google.com>2017-03-29 15:00:32 -0700
committerChris Craik <ccraik@google.com>2017-03-29 15:05:30 -0700
commitd0ebf633155e2d637d289933ef7dbc5d86f73881 (patch)
treedf2eac86f23cb2dab056b1972c16a6222e005a89 /catapult/telemetry/third_party/websocket-client/examples/echoapp_client.py
parent6f2b0c6d0bda132ba19956163f25b42919940261 (diff)
downloadchromium-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.py48
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()