From ea059eadbfb76062103059eddb3fd8a78e3ee254 Mon Sep 17 00:00:00 2001
From: Rahim Kanji <rahim.kanji@outlook.com>
Date: Tue, 26 Nov 2024 02:16:21 +0500
Subject: [PATCH] Added SESSION_FORWARD_TYPE enum to define the type of session
 forwarding

---
 lib/MySQL_Thread.cpp      | 2 +-
 lib/PgSQL_Data_Stream.cpp | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git a/lib/MySQL_Thread.cpp b/lib/MySQL_Thread.cpp
index 5fca5cf23..f9e3465c2 100644
--- a/lib/MySQL_Thread.cpp
+++ b/lib/MySQL_Thread.cpp
@@ -3872,7 +3872,7 @@ void MySQL_Thread::ProcessAllSessions_Healthy0(MySQL_Session *sess, unsigned int
 	char _buf[1024];
 	if (sess->client_myds) {
 		if (mysql_thread___log_unhealthy_connections) {
-			if (sess->session_fast_forward == false) {
+			if (sess->session_fast_forward == SESSION_FORWARD_TYPE_NONE) {
 				proxy_warning(
 					"Closing unhealthy client connection %s:%d\n", sess->client_myds->addr.addr,
 					sess->client_myds->addr.port
diff --git a/lib/PgSQL_Data_Stream.cpp b/lib/PgSQL_Data_Stream.cpp
index fa754eb6f..c5fa8efb6 100644
--- a/lib/PgSQL_Data_Stream.cpp
+++ b/lib/PgSQL_Data_Stream.cpp
@@ -1244,7 +1244,7 @@ void PgSQL_Data_Stream::reset_connection() {
 			myconn->last_time_used = sess->thread->curtime;
 			return_MySQL_Connection_To_Pool();
 		} else {
-			if (sess && sess->session_fast_forward == false) {
+			if (sess && sess->session_fast_forward == SESSION_FORWARD_TYPE_NONE) {
 				destroy_MySQL_Connection_From_Pool(true);
 			} else {
 				destroy_MySQL_Connection_From_Pool(false);