GithubFollow/One-KVM
1
0
Fork 0
mirror of https://github.com/mofeng-git/One-KVM.git synced 2025-12-13 01:30:31 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

wscli: timestamps

Browse Source
This commit is contained in:
Devaev Maxim 2018-07-03 07:03:09 +03:00
parent 67439d6194
commit fb60b0dd60
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
kvmd/kvmd/extras/wscli/__init__.py
View File

@ -5,6 +5,7 @@ import sys
import signal import signal
import asyncio import asyncio
import argparse import argparse
import time
import aiohttp import aiohttp
@ -24,12 +25,12 @@ async def _run_client(loop: asyncio.AbstractEventLoop, url: str) -> None:
while True: while True:
msg = await ws.receive() msg = await ws.receive()
if msg.type == aiohttp.WSMsgType.TEXT: if msg.type == aiohttp.WSMsgType.TEXT:
print("Received:", msg.data.strip()) print("[%.5f] Received: %s" % (time.time(), msg.data.strip()))
else: else:
if msg.type == aiohttp.WSMsgType.CLOSE: if msg.type == aiohttp.WSMsgType.CLOSE:
await ws.close() await ws.close()
elif msg.type == aiohttp.WSMsgType.ERROR: elif msg.type == aiohttp.WSMsgType.ERROR:
print("Error during receive:", ws.exception()) print("[%.5f] Error during receive: %s" % (time.time(), ws.exception()))
elif msg.type == aiohttp.WSMsgType.CLOSED: elif msg.type == aiohttp.WSMsgType.CLOSED:
pass pass
break break