From aa37e3938a0beba939194c62be182b0c3f74025e Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Ren=C3=A9=20Canna=C3=B2?= <rene.cannao@gmail.com>
Date: Thu, 16 Jul 2015 20:47:39 +0000
Subject: [PATCH] Fast forward

---
 lib/MySQL_Thread.cpp | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/lib/MySQL_Thread.cpp b/lib/MySQL_Thread.cpp
index f44bfbadb..d14e1eeaa 100644
--- a/lib/MySQL_Thread.cpp
+++ b/lib/MySQL_Thread.cpp
@@ -1112,7 +1112,7 @@ void MySQL_Thread::process_data_on_data_stream(MySQL_Data_Stream *myds, unsigned
 				mypolls.last_recv[n]=curtime;
 				myds->revents=mypolls.fds[n].revents;
 				myds->sess->to_process=1;
-				if (myds->myds_type!=MYDS_FRONTEND) {
+				if (myds->myds_type==MYDS_BACKEND && myds->sess->fast_forward==false) {
 					return;
 				}
 				if (mypolls.myds[n]->DSS < STATE_MARIADB_BEGIN || mypolls.myds[n]->DSS > STATE_MARIADB_END) {