diff --git a/lib/mysql_connection.cpp b/lib/mysql_connection.cpp index edadbe044..8810e0152 100644 --- 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) {