diff options
| -rw-r--r-- | kvmd/plugins/hid/_mcu/__init__.py | 19 |
1 files changed, 9 insertions, 10 deletions
diff --git a/kvmd/plugins/hid/_mcu/__init__.py b/kvmd/plugins/hid/_mcu/__init__.py index 39f9f03d..cbecd286 100644 --- a/kvmd/plugins/hid/_mcu/__init__.py +++ b/kvmd/plugins/hid/_mcu/__init__.py @@ -256,22 +256,21 @@ class BaseMcuHid(BaseHid, multiprocessing.Process): # pylint: disable=too-many- self.__queue_event(MouseWheelEvent(delta_x, delta_y)) def set_keyboard_output(self, output: str) -> None: - # FIXME: Если очистка производится со стороны процесса хида, то возможна гонка между - # очисткой и добавлением нового события. Неприятно, но не смертельно. - # Починить блокировкой после перехода на асинхронные очереди. - tools.clear_queue(self.__events_queue) - self.__queue_event(SetKeyboardOutputEvent(output)) + self.__queue_event(SetKeyboardOutputEvent(output), clear=True) def set_mouse_output(self, output: str) -> None: - tools.clear_queue(self.__events_queue) - self.__queue_event(SetMouseOutputEvent(output)) + self.__queue_event(SetMouseOutputEvent(output), clear=True) def clear_events(self) -> None: - tools.clear_queue(self.__events_queue) - self.__queue_event(ClearEvent()) + self.__queue_event(ClearEvent(), clear=True) - def __queue_event(self, event: BaseEvent) -> None: + def __queue_event(self, event: BaseEvent, clear: bool=False) -> None: if not self.__stop_event.is_set(): + if clear: + # FIXME: Если очистка производится со стороны процесса хида, то возможна гонка между + # очисткой и добавлением нового события. Неприятно, но не смертельно. + # Починить блокировкой после перехода на асинхронные очереди. + tools.clear_queue(self.__events_queue) self.__events_queue.put_nowait(event) def run(self) -> None: # pylint: disable=too-many-branches |