Fast forward

11 years ago · aa37e3938a
parent 84e6a104d1
commit aa37e3938a
1 changed files with 1 additions and 1 deletions
--- 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) {