diff options
| author | Devaev Maxim <[email protected]> | 2018-11-05 06:13:08 +0300 |
|---|---|---|
| committer | Devaev Maxim <[email protected]> | 2018-11-05 06:13:08 +0300 |
| commit | 18a626a30c63367b97af74bc3e30fc6b75cc48dd (patch) | |
| tree | 76443a01079bb809f03d88e4220bcb356afabc7e /kvmd/server.py | |
| parent | 4e49931a252ebd555ab523673c2c69808c20ab6a (diff) | |
soft fps limit
Diffstat (limited to 'kvmd/server.py')
| -rw-r--r-- | kvmd/server.py | 14 |
1 files changed, 11 insertions, 3 deletions
diff --git a/kvmd/server.py b/kvmd/server.py index 16de7dd8..cb9db787 100644 --- a/kvmd/server.py +++ b/kvmd/server.py @@ -141,6 +141,7 @@ class Server: # pylint: disable=too-many-instance-attributes self.__reset_streamer = False self.__streamer_quality = streamer.get_current_quality() + self.__streamer_soft_fps = streamer.get_current_soft_fps() def run(self, host: str, port: int) -> None: self.__hid.start() @@ -355,6 +356,9 @@ class Server: # pylint: disable=too-many-instance-attributes quality = request.query.get("quality") if quality: self.__streamer_quality = _valid_int("quality", quality, 1, 100) + soft_fps = request.query.get("soft_fps") + if soft_fps: + self.__streamer_soft_fps = _valid_int("soft_fps", soft_fps, 1, 30) return _json() async def __streamer_reset_handler(self, _: aiohttp.web.Request) -> aiohttp.web.Response: @@ -400,7 +404,7 @@ class Server: # pylint: disable=too-many-instance-attributes cur = len(self.__sockets) if prev == 0 and cur > 0: if not self.__streamer.is_running(): - await self.__streamer.start(self.__streamer_quality) + await self.__streamer.start(self.__streamer_quality, self.__streamer_soft_fps) await self.__broadcast_event("streamer_state", **self.__streamer.get_state()) elif prev > 0 and cur == 0: shutdown_at = time.time() + self.__streamer_shutdown_delay @@ -409,10 +413,14 @@ class Server: # pylint: disable=too-many-instance-attributes await self.__streamer.stop() await self.__broadcast_event("streamer_state", **self.__streamer.get_state()) - if self.__reset_streamer or self.__streamer_quality != self.__streamer.get_current_quality(): + if ( + self.__reset_streamer + or self.__streamer_quality != self.__streamer.get_current_quality() + or self.__streamer_soft_fps != self.__streamer.get_current_soft_fps() + ): if self.__streamer.is_running(): await self.__streamer.stop() - await self.__streamer.start(self.__streamer_quality, no_init_restart=True) + await self.__streamer.start(self.__streamer_quality, self.__streamer_soft_fps, no_init_restart=True) await self.__broadcast_event("streamer_state", **self.__streamer.get_state()) self.__reset_streamer = False |