Crash on mirroring #1305

8 years ago · c28e555284
parent ff473b3a2a
commit c28e555284
1 changed files with 8 additions and 6 deletions
--- a/lib/mysql_connection.cpp
+++ b/lib/mysql_connection.cpp
@ -914,12 +914,14 @@ handler_again:
 			break;
 		case ASYNC_USE_RESULT_CONT:
 			{
-				unsigned int buffered_data=0;
-				buffered_data = myds->sess->client_myds->PSarrayOUT->len * RESULTSET_BUFLEN;
-				buffered_data += myds->sess->client_myds->resultset->len * RESULTSET_BUFLEN;
-				if (buffered_data > (unsigned int)mysql_thread___threshold_resultset_size*8) {
-					next_event(ASYNC_USE_RESULT_CONT); // we temporarily pause . See #1232
-					break;
+				if (myds->sess && myds->sess->client_myds && myds->sess->mirror==false) {
+					unsigned int buffered_data=0;
+					buffered_data = myds->sess->client_myds->PSarrayOUT->len * RESULTSET_BUFLEN;
+					buffered_data += myds->sess->client_myds->resultset->len * RESULTSET_BUFLEN;
+					if (buffered_data > (unsigned int)mysql_thread___threshold_resultset_size*8) {
+						next_event(ASYNC_USE_RESULT_CONT); // we temporarily pause . See #1232
+						break;
+					}
 				}
 			}
 			if (async_fetch_row_start==false) {