Changed locks to 1s default
This commit is contained in:
parent
f60d85fa89
commit
2435842ff6
4 changed files with 7 additions and 7 deletions
|
|
@ -23,7 +23,7 @@ class BaseCamera(metaclass=ABCMeta):
|
||||||
self.thread = None
|
self.thread = None
|
||||||
self.camera = None
|
self.camera = None
|
||||||
|
|
||||||
self.lock = StrictLock(name="Camera", timeout=None)
|
self.lock = StrictLock(name="Camera", timeout=1)
|
||||||
|
|
||||||
self.frame = None
|
self.frame = None
|
||||||
self.last_access = 0
|
self.last_access = 0
|
||||||
|
|
@ -55,7 +55,7 @@ class BaseCamera(metaclass=ABCMeta):
|
||||||
@abstractmethod
|
@abstractmethod
|
||||||
def update_settings(self, config: dict):
|
def update_settings(self, config: dict):
|
||||||
"""Update settings from a config dictionary"""
|
"""Update settings from a config dictionary"""
|
||||||
with self.lock:
|
with self.lock(timeout=None):
|
||||||
# Apply valid config params to camera object
|
# Apply valid config params to camera object
|
||||||
for key, value in config.items(): # For each provided setting
|
for key, value in config.items(): # For each provided setting
|
||||||
if hasattr(self, key): # If the instance has a matching property
|
if hasattr(self, key): # If the instance has a matching property
|
||||||
|
|
|
||||||
|
|
@ -195,7 +195,7 @@ class PiCameraStreamer(BaseCamera):
|
||||||
logging.debug("PiCameraStreamer: Applying config:")
|
logging.debug("PiCameraStreamer: Applying config:")
|
||||||
logging.debug(config)
|
logging.debug(config)
|
||||||
|
|
||||||
with self.lock:
|
with self.lock(timeout=None):
|
||||||
|
|
||||||
# Apply valid config params to Picamera object
|
# Apply valid config params to Picamera object
|
||||||
if not self.record_active: # If not recording a video
|
if not self.record_active: # If not recording a video
|
||||||
|
|
@ -301,7 +301,7 @@ class PiCameraStreamer(BaseCamera):
|
||||||
"""
|
"""
|
||||||
Change the camera zoom, handling re-centering and scaling.
|
Change the camera zoom, handling re-centering and scaling.
|
||||||
"""
|
"""
|
||||||
with self.lock:
|
with self.lock(timeout=None):
|
||||||
self.zoom_value = float(zoom_value)
|
self.zoom_value = float(zoom_value)
|
||||||
if self.zoom_value < 1:
|
if self.zoom_value < 1:
|
||||||
self.zoom_value = 1
|
self.zoom_value = 1
|
||||||
|
|
@ -448,7 +448,7 @@ class PiCameraStreamer(BaseCamera):
|
||||||
resolution ((int, int)): Resolution to set the camera to, before starting recording.
|
resolution ((int, int)): Resolution to set the camera to, before starting recording.
|
||||||
Defaults to `self.stream_resolution`.
|
Defaults to `self.stream_resolution`.
|
||||||
"""
|
"""
|
||||||
with self.lock:
|
with self.lock(timeout=None):
|
||||||
# If stream object was destroyed
|
# If stream object was destroyed
|
||||||
if not hasattr(self, "stream"):
|
if not hasattr(self, "stream"):
|
||||||
self.stream = io.BytesIO() # Create a stream object
|
self.stream = io.BytesIO() # Create a stream object
|
||||||
|
|
|
||||||
|
|
@ -11,7 +11,7 @@ class BaseStage(metaclass=ABCMeta):
|
||||||
"""
|
"""
|
||||||
|
|
||||||
def __init__(self):
|
def __init__(self):
|
||||||
self.lock = StrictLock(name="Stage", timeout=5)
|
self.lock = StrictLock(name="Stage", timeout=1)
|
||||||
|
|
||||||
@abstractmethod
|
@abstractmethod
|
||||||
def update_settings(self, config: dict):
|
def update_settings(self, config: dict):
|
||||||
|
|
|
||||||
|
|
@ -51,7 +51,7 @@ class SangaStage(BaseStage):
|
||||||
|
|
||||||
@property
|
@property
|
||||||
def position(self):
|
def position(self):
|
||||||
with self.lock:
|
with self.lock(timeout=None):
|
||||||
return self.board.position
|
return self.board.position
|
||||||
|
|
||||||
@property
|
@property
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue