[pre-commit.ci] auto fixes from pre-commit.com hooks
for more information, see https://pre-commit.ci
This commit is contained in:
@@ -142,7 +142,6 @@ class RealSenseCamera(Camera):
|
|||||||
self.stop_event: Event | None = None
|
self.stop_event: Event | None = None
|
||||||
self.frame_queue: queue.Queue = queue.Queue(maxsize=1)
|
self.frame_queue: queue.Queue = queue.Queue(maxsize=1)
|
||||||
|
|
||||||
|
|
||||||
self.rotation: int | None = get_cv2_rotation(config.rotation)
|
self.rotation: int | None = get_cv2_rotation(config.rotation)
|
||||||
|
|
||||||
if self.height and self.width:
|
if self.height and self.width:
|
||||||
@@ -177,7 +176,6 @@ class RealSenseCamera(Camera):
|
|||||||
context = rs.context()
|
context = rs.context()
|
||||||
devices = context.query_devices()
|
devices = context.query_devices()
|
||||||
|
|
||||||
|
|
||||||
for device in devices:
|
for device in devices:
|
||||||
camera_info = {
|
camera_info = {
|
||||||
"name": device.get_info(rs.camera_info.name),
|
"name": device.get_info(rs.camera_info.name),
|
||||||
@@ -315,8 +313,7 @@ class RealSenseCamera(Camera):
|
|||||||
self.rs_profile = None
|
self.rs_profile = None
|
||||||
self.rs_pipeline = None
|
self.rs_pipeline = None
|
||||||
raise ConnectionError(
|
raise ConnectionError(
|
||||||
f"Failed to open {self} camera. "
|
f"Failed to open {self} camera. Run 'python -m find_cameras list-cameras' for details."
|
||||||
f"Run 'python -m find_cameras list-cameras' for details."
|
|
||||||
) from e
|
) from e
|
||||||
|
|
||||||
logger.debug(f"Validating stream configuration for {self}...")
|
logger.debug(f"Validating stream configuration for {self}...")
|
||||||
@@ -409,9 +406,7 @@ class RealSenseCamera(Camera):
|
|||||||
ret, frame = self.rs_pipeline.try_wait_for_frames(timeout_ms=timeout_ms)
|
ret, frame = self.rs_pipeline.try_wait_for_frames(timeout_ms=timeout_ms)
|
||||||
|
|
||||||
if not ret or frame is None:
|
if not ret or frame is None:
|
||||||
raise RuntimeError(
|
raise RuntimeError(f"{self} failed to capture frame. Returned status='{ret}'.")
|
||||||
f"{self} failed to capture frame. Returned status='{ret}'."
|
|
||||||
)
|
|
||||||
|
|
||||||
depth_frame = frame.get_depth_frame()
|
depth_frame = frame.get_depth_frame()
|
||||||
depth_map = np.asanyarray(depth_frame.get_data())
|
depth_map = np.asanyarray(depth_frame.get_data())
|
||||||
@@ -553,9 +548,7 @@ class RealSenseCamera(Camera):
|
|||||||
self.stop_event.set()
|
self.stop_event.set()
|
||||||
|
|
||||||
self.stop_event = Event()
|
self.stop_event = Event()
|
||||||
self.thread = Thread(
|
self.thread = Thread(target=self._read_loop, args=(), name=f"{self}_read_loop")
|
||||||
target=self._read_loop, args=(), name=f"{self}_read_loop"
|
|
||||||
)
|
|
||||||
self.thread.daemon = True
|
self.thread.daemon = True
|
||||||
self.thread.start()
|
self.thread.start()
|
||||||
logger.debug(f"Read thread started for {self}.")
|
logger.debug(f"Read thread started for {self}.")
|
||||||
|
|||||||
Reference in New Issue
Block a user