From 5aa9a4b7a00ce4cffa2fff5857a770a72eb8f8d1 Mon Sep 17 00:00:00 2001
From: Devaev Maxim <mdevaev@gmail.com>
Date: Mon, 11 Jan 2021 02:07:56 +0300
Subject: [PATCH] last_id

---
 src/libs/memsink.c | 7 ++++---
 src/libs/memsink.h | 2 +-
 2 files changed, 5 insertions(+), 4 deletions(-)

diff --git a/src/libs/memsink.c b/src/libs/memsink.c
index 0f1bd05..5282728 100644
--- a/src/libs/memsink.c
+++ b/src/libs/memsink.c
@@ -102,7 +102,8 @@ int memsink_server_put(memsink_s *sink, const frame_s *frame) {
 		LOG_VERBOSE("%s-sink: >>>>> Exposing new frame ...", sink->name);
 
 #		define COPY(_field) sink->mem->_field = frame->_field
-		sink->mem->id = get_now_id();
+		sink->last_id = get_now_id();
+		sink->mem->id = sink->last_id;
 		COPY(used);
 		COPY(width);
 		COPY(height);
@@ -145,11 +146,11 @@ int memsink_client_get(memsink_s *sink, frame_s *frame) { // cppcheck-suppress u
 
 	bool same = false;
 
-	if (sink->mem->id == sink->consumed_id) {
+	if (sink->mem->id == sink->last_id) {
 		same = true;
 	} else {
 #		define COPY(_field) frame->_field = sink->mem->_field
-		sink->consumed_id = sink->mem->id;
+		sink->last_id = sink->mem->id;
 		COPY(width);
 		COPY(height);
 		COPY(format);
diff --git a/src/libs/memsink.h b/src/libs/memsink.h
index 8dca2ef..9cf49dd 100644
--- a/src/libs/memsink.h
+++ b/src/libs/memsink.h
@@ -68,7 +68,7 @@ typedef struct {
 
 	int					fd;
 	memsink_shared_s	*mem;
-	uint64_t			consumed_id; // Client only
+	uint64_t			last_id;
 } memsink_s;