fb_requested on lock

This commit is contained in:
Devaev Maxim 2020-04-25 15:41:12 +03:00
parent 6a5e3e47bb
commit 775f8741a0
2 changed files with 4 additions and 3 deletions

View File

@ -77,8 +77,6 @@ class RfbClient(RfbClientStream): # pylint: disable=too-many-instance-attribute
self.__rfb_version = 0 self.__rfb_version = 0
self._encodings = RfbClientEncodings(frozenset()) self._encodings = RfbClientEncodings(frozenset())
self._lock = asyncio.Lock()
get_logger(0).info("Connected client: %s", self._remote) get_logger(0).info("Connected client: %s", self._remote)
# ===== # =====

View File

@ -108,6 +108,8 @@ class _Client(RfbClient): # pylint: disable=too-many-instance-attributes
self.__mouse_buttons: Dict[str, Optional[bool]] = {"left": None, "right": None, "middle": None} self.__mouse_buttons: Dict[str, Optional[bool]] = {"left": None, "right": None, "middle": None}
self.__mouse_move = {"x": -1, "y": -1} self.__mouse_move = {"x": -1, "y": -1}
self._lock = asyncio.Lock()
# ===== # =====
async def run(self) -> None: async def run(self) -> None:
@ -277,7 +279,8 @@ class _Client(RfbClient): # pylint: disable=too-many-instance-attributes
await self.__kvmd.set_streamer_params(user, passwd, self._encodings.tight_jpeg_quality, self.__desired_fps) await self.__kvmd.set_streamer_params(user, passwd, self._encodings.tight_jpeg_quality, self.__desired_fps)
async def _on_fb_update_request(self) -> None: async def _on_fb_update_request(self) -> None:
self.__fb_requested = True async with self._lock:
self.__fb_requested = True
# ===== # =====