From c33d2a2ff174ecc75a4072d2823808d90038b21b Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Ren=C3=A9=20Canna=C3=B2?= <rene.cannao@gmail.com>
Date: Tue, 11 Oct 2016 02:21:14 +0000
Subject: [PATCH] Sessions were incorrectly always processed

---
 lib/MySQL_Thread.cpp | 8 ++++++++
 1 file changed, 8 insertions(+)

diff --git a/lib/MySQL_Thread.cpp b/lib/MySQL_Thread.cpp
index def2f5719..ccfc53857 100644
--- a/lib/MySQL_Thread.cpp
+++ b/lib/MySQL_Thread.cpp
@@ -2175,6 +2175,13 @@ bool MySQL_Thread::process_data_on_data_stream(MySQL_Data_Stream *myds, unsigned
 						// timeout
 						myds->sess->to_process=1;
 						assert(myds->sess->status!=NONE);
+					} else {
+						if (myds->pause_until && curtime > myds->pause_until) {
+							// timeout
+							myds->sess->to_process=1;
+						} else {
+							to_process=0;
+						}
 					}
 				}
 				if (myds->myds_type==MYDS_BACKEND && myds->sess->status!=FAST_FORWARD) {
@@ -2262,6 +2269,7 @@ void MySQL_Thread::process_all_sessions() {
 		if (maintenance_loop) {
 			unsigned int numTrx=0;
 			unsigned long long sess_time = sess->IdleTime();
+			sess->to_process=1;
 			if ( (sess_time/1000 > (unsigned long long)mysql_thread___max_transaction_time) || (sess_time/1000 > (unsigned long long)mysql_thread___wait_timeout) ) {
 				numTrx = sess->NumActiveTransactions();
 				if (numTrx) {