Fix crash on mirror of commit

9 years ago · 0def85ee4a
parent c09190b193
commit 0def85ee4a
1 changed files with 7 additions and 3 deletions
--- a/lib/MySQL_Session.cpp
+++ b/lib/MySQL_Session.cpp
@ -1801,9 +1801,13 @@ __get_pkts_from_client:
 									}
 									rc_break=handler_special_queries(&pkt);
 									if (rc_break==true) {
-										// track also special queries
-										RequestEnd(NULL);
-										break;
+										if (mirror==false) {
+											// track also special queries
+											RequestEnd(NULL);
+											break;
+										} else {
+											return -1;
+										}
 									}
 									{
 										timespec begint;