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

refactoring

Browse Source
This commit is contained in:
Devaev Maxim 2018-12-03 06:58:40 +03:00
parent 3a98909688
commit a57e5cdaa9
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
kvmd/apps/kvmd/server.py
View File

@ -104,9 +104,9 @@ def _wrap_exceptions_for_web(msg: str) -> Callable:
class _Events(Enum): class _Events(Enum):
INFO_STATE = "info_state" INFO_STATE = "info_state"
STREAMER_STATE = "streamer_state"
ATX_STATE = "atx_state" ATX_STATE = "atx_state"
MSD_STATE = "msd_state" MSD_STATE = "msd_state"
STREAMER_STATE = "streamer_state"
class Server: # pylint: disable=too-many-instance-attributes class Server: # pylint: disable=too-many-instance-attributes
@ -228,9 +228,9 @@ class Server: # pylint: disable=too-many-instance-attributes
await self.__register_socket(ws) await self.__register_socket(ws)
await asyncio.gather(*[ await asyncio.gather(*[
self.__broadcast_event(_Events.INFO_STATE, (await self.__make_info())), self.__broadcast_event(_Events.INFO_STATE, (await self.__make_info())),
self.__broadcast_event(_Events.STREAMER_STATE, (await self.__streamer.get_state())),
self.__broadcast_event(_Events.ATX_STATE, self.__atx.get_state()), self.__broadcast_event(_Events.ATX_STATE, self.__atx.get_state()),
self.__broadcast_event(_Events.MSD_STATE, self.__msd.get_state()), self.__broadcast_event(_Events.MSD_STATE, self.__msd.get_state()),
self.__broadcast_event(_Events.STREAMER_STATE, (await self.__streamer.get_state())),
]) ])
async for msg in ws: async for msg in ws:
if msg.type == aiohttp.web.WSMsgType.TEXT: if msg.type == aiohttp.web.WSMsgType.TEXT:
@ -396,9 +396,9 @@ class Server: # pylint: disable=too-many-instance-attributes
await self.__remove_socket(ws) await self.__remove_socket(ws)
async def __on_cleanup(self, _: aiohttp.web.Application) -> None: async def __on_cleanup(self, _: aiohttp.web.Application) -> None:
await self.__hid.cleanup()
await self.__streamer.cleanup() await self.__streamer.cleanup()
await self.__msd.cleanup() await self.__msd.cleanup()
await self.__hid.cleanup()
@_system_task @_system_task
async def __hid_watchdog(self) -> None: async def __hid_watchdog(self) -> None: