From: Marius Vlad <marius.vlad@collabora.com>
Date: Tue, 6 Feb 2024 17:50:21 +0000 (+0200)
Subject: app: Listen for activation events
X-Git-Url: https://gerrit.automotivelinux.org/gerrit/gitweb?a=commitdiff_plain;h=0c12d910cb51f35b1efdd4613ac641790a5b72f9;p=apps%2Fcamera-gstreamer.git

app: Listen for activation events

Signed-off-by: Marius Vlad <marius.vlad@collabora.com>
Change-Id: I7e624e9e5973f5b3281b9450da47e97486631b2f
---

diff --git a/app/main.cpp b/app/main.cpp
index 64a435b..d3013b7 100644
--- a/app/main.cpp
+++ b/app/main.cpp
@@ -13,6 +13,7 @@
 #include <unistd.h>
 #include <fcntl.h>
 #include <assert.h>
+#include <thread>
 
 #include "utils.h"
 #include "xdg-shell-client-protocol.h"
@@ -42,6 +43,8 @@
 
 #define MAX_BUFFER_ALLOC	2
 
+const char* my_app_id = "camera-gstreamer";
+
 // C++ requires a cast and we in wayland we do the cast implictly
 #define WL_ARRAY_FOR_EACH(pos, array, type) \
 	for (pos = (type)(array)->data; \
@@ -750,6 +753,30 @@ GstElement* create_pipeline(int* argc, char** argv[])
 	return pipeline;
 }
 
+static void
+run_in_thread(GrpcClient *client)
+{
+        grpc::Status status = client->Wait();
+}
+
+static void
+app_status_callback(::agl_shell_ipc::AppStateResponse app_response, void *data)
+{
+	(void) data;
+
+	std::cout << " >> AppStateResponse app_id " <<
+		app_response.app_id() << ", with state " <<
+		app_response.state() << std::endl;
+
+	// there's no implicit deactivation for an activation of another app so
+	// assume that another application got activate we are also deactived
+	if (app_response.state() == 2 && app_response.app_id() != my_app_id) {
+		// suspend pipeline
+		std::cout << "Suspending gstreamer pipeline" << std::endl;
+	}
+}
+
+
 int main(int argc, char* argv[])
 {
 	int ret = 0;
@@ -757,13 +784,19 @@ int main(int argc, char* argv[])
 	struct receiver_data receiver_data = {};
 	struct display* display;
 	struct window* window;
-	const char* app_id = "camera-gstreamer";
+
+	// always start the grpc client
+	GrpcClient *client = new GrpcClient();
+
+	// subscribe to events to be able to suspend/pause the video
+	// feed
+	std::thread th = std::thread(run_in_thread, client);
+	client->AppStatusState(app_status_callback, &receiver_data);
 
 	// for starting the application from the beginning, with a diffrent
 	// role we need to handle that creating the main window
 	if (argc >= 2 && strcmp(argv[1], "float") == 0) {
-		GrpcClient *client = new GrpcClient();
-		client->SetAppFloat(std::string(app_id), 30, 400);
+		client->SetAppFloat(std::string(my_app_id), 30, 400);
 	}
 
 	sa.sa_sigaction = signal_int;
@@ -793,7 +826,7 @@ int main(int argc, char* argv[])
 	// we use the role to set a correspondence between the top level
 	// surface and our application, with the previous call letting the
 	// compositor know that we're one and the same
-	window = create_window(display, WINDOW_WIDTH_SIZE, WINDOW_HEIGHT_SIZE, app_id);
+	window = create_window(display, WINDOW_WIDTH_SIZE, WINDOW_HEIGHT_SIZE, my_app_id);
 
 	if (!window) {
 		free(gargv);