revil-O/platypush
1
0
Fork 0
forked from platypush/platypush
Code Pull requests Activity

Camera stream writer fixes.

Browse source 
- The readiness condition should be `multiprocessing.Condition`, not
  `threading.Condition` - in most of the cases it will be checked in a
  multiprocess environment.

- Fixed parameter name for `write`.
This commit is contained in:
Fabio Manganiello 2023-05-30 11:06:48 +02:00
parent 4fffabd82a
commit 8b5eb82497
Signed by untrusted user: blacklight
GPG key ID: D90FBA7F76362774
1 changed files with 4 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
platypush/plugins/camera/model/writer/__init__.py
View file

@ -1,7 +1,7 @@
import io import io
import logging import logging
import multiprocessing
import os import os
import threading
import time import time
from abc import ABC, abstractmethod from abc import ABC, abstractmethod
@ -26,11 +26,11 @@ class VideoWriter(ABC):
self.closed = False self.closed = False
@abstractmethod @abstractmethod
def write(self, img: Image): def write(self, image: Image):
""" """
Write an image to the channel. Write an image to the channel.
:param img: PIL Image instance. :param image: PIL Image instance.
""" """
raise NotImplementedError() raise NotImplementedError()
@ -76,7 +76,7 @@ class StreamWriter(VideoWriter, ABC):
self.frame: Optional[bytes] = None self.frame: Optional[bytes] = None
self.frame_time: Optional[float] = None self.frame_time: Optional[float] = None
self.buffer = io.BytesIO() self.buffer = io.BytesIO()
self.ready = threading.Condition() self.ready = multiprocessing.Condition()
self.sock = sock self.sock = sock
def write(self, image: Image): def write(self, image: Image):