From ead06e741acd277a3643a0094d16d864c7ffb248 Mon Sep 17 00:00:00 2001
From: Maxim Devaev <mdevaev@gmail.com>
Date: Sun, 19 Dec 2021 01:28:57 +0300
Subject: [PATCH] removed grabbed_mutex

---
 src/ustreamer/device.c | 9 ---------
 src/ustreamer/device.h | 7 ++-----
 2 files changed, 2 insertions(+), 14 deletions(-)

diff --git a/src/ustreamer/device.c b/src/ustreamer/device.c
index 92e4e54..cd724dc 100644
--- a/src/ustreamer/device.c
+++ b/src/ustreamer/device.c
@@ -194,7 +194,6 @@ void device_close(device_s *dev) {
 					free(HW(raw.data));
 				}
 			}
-			A_MUTEX_DESTROY(&HW(grabbed_mutex));
 
 #			undef HW
 		}
@@ -346,14 +345,11 @@ int device_grab_buffer(device_s *dev, hw_buffer_s **hw) {
 
 #	define HW(_next) RUN(hw_bufs)[buf.index]._next
 
-	A_MUTEX_LOCK(&HW(grabbed_mutex));
 	if (HW(grabbed)) {
 		LOG_ERROR("V4L2 error: grabbed device buffer=%u is already used", buf.index);
-		A_MUTEX_UNLOCK(&HW(grabbed_mutex));
 		return -1;
 	}
 	HW(grabbed) = true;
-	A_MUTEX_UNLOCK(&HW(grabbed_mutex));
 
 	HW(raw.dma_fd) = HW(dma_fd);
 	HW(raw.used) = buf.bytesused;
@@ -374,14 +370,11 @@ int device_release_buffer(device_s *dev, hw_buffer_s *hw) {
 	const unsigned index = hw->buf.index;
 	LOG_DEBUG("Releasing device buffer=%u ...", index);
 
-	A_MUTEX_LOCK(&hw->grabbed_mutex);
 	if (xioctl(RUN(fd), VIDIOC_QBUF, &hw->buf) < 0) {
 		LOG_PERROR("Unable to release device buffer=%u", index);
-		A_MUTEX_UNLOCK(&hw->grabbed_mutex);
 		return -1;
 	}
 	hw->grabbed = false;
-	A_MUTEX_UNLOCK(&hw->grabbed_mutex);
 	return 0;
 }
 
@@ -688,8 +681,6 @@ static int _device_open_io_method_mmap(device_s *dev) {
 
 		HW(dma_fd) = -1;
 
-		A_MUTEX_INIT(&HW(grabbed_mutex));
-
 		LOG_DEBUG("Mapping device buffer=%u ...", RUN(n_bufs));
 		if ((HW(raw.data) = mmap(
 			NULL,
diff --git a/src/ustreamer/device.h b/src/ustreamer/device.h
index 9311d28..b0d2d19 100644
--- a/src/ustreamer/device.h
+++ b/src/ustreamer/device.h
@@ -68,13 +68,10 @@
 
 
 typedef struct {
-	frame_s raw;
-
+	frame_s				raw;
 	struct v4l2_buffer	buf;
 	int					dma_fd;
-
-	pthread_mutex_t grabbed_mutex;
-	bool			grabbed;
+	bool				grabbed;
 } hw_buffer_s;
 
 typedef struct {