From 53262987ace90f879edab4d6613d02df311d025b Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Ren=C3=A9=20Canna=C3=B2?= <rene.cannao@gmail.com>
Date: Thu, 18 Jan 2024 04:34:00 +0000
Subject: [PATCH] Added new status variable mysql_listener_paused

New variable mysql_listener_paused added to table stats_mysql_global .
The variable is a boolean:
- true : listener is paused because PROXYSQL PAUSE was executed
- false : listener is not paused

The variable is also reported by Prometheus exporter as proxysql_mysql_listener_paused

Related to #4391
---
 include/proxysql_admin.h |  1 +
 lib/ProxySQL_Admin.cpp   | 20 +++++++++++++++++++-
 2 files changed, 20 insertions(+), 1 deletion(-)

diff --git a/include/proxysql_admin.h b/include/proxysql_admin.h
index 94fed715c4..d1a2741863 100644
--- a/include/proxysql_admin.h
+++ b/include/proxysql_admin.h
@@ -90,6 +90,7 @@ struct p_admin_gauge {
 		stmt_cached,
 		fds_in_use,
 		version_info,
+		mysql_listener_paused,
 		__size
 	};
 };
diff --git a/lib/ProxySQL_Admin.cpp b/lib/ProxySQL_Admin.cpp
index 8f95bf075b..f3d521776a 100644
--- a/lib/ProxySQL_Admin.cpp
+++ b/lib/ProxySQL_Admin.cpp
@@ -758,6 +758,12 @@ admin_metrics_map = std::make_tuple(
 		)
 	},
 	admin_gauge_vector {
+		std::make_tuple (
+			p_admin_gauge::mysql_listener_paused,
+			"proxysql_mysql_listener_paused",
+			"MySQL listener paused because of PROXYSQL PAUSE.",
+			metric_tags {}
+		),
 		// memory metrics
 		std::make_tuple (
 			p_admin_gauge::connpool_memory_bytes,
@@ -9421,6 +9427,11 @@ void ProxySQL_Admin::p_update_metrics() {
 	this->p_stats___memory_metrics();
 	// Update stmt metrics
 	this->p_update_stmt_metrics();
+
+	// updated mysql_listener_paused
+	int st = ( proxysql_mysql_paused == true ? 1 : 0);
+	this->metrics.p_gauge_array[p_admin_gauge::mysql_listener_paused]->Set(st);
+
 }
 
 /**
@@ -9915,7 +9926,14 @@ void ProxySQL_Admin::stats___mysql_global() {
 		statsdb->execute(query);
 		free(query);
 	}
-
+	{
+		vn=(char *)"mysql_listener_paused";
+		sprintf(bu, "%s", ( proxysql_mysql_paused==true ? "true" : "false") );
+		query=(char *)malloc(strlen(a)+strlen(vn)+strlen(bu)+16);
+		sprintf(query,a,vn,bu);
+		statsdb->execute(query);
+		free(query);
+	}
 	statsdb->execute("COMMIT");
 }