Code cleanup

pull/4703/head
Rahim Kanji 2 years ago
parent 9b36d63d3d
commit c7f7705cde

@ -377,9 +377,7 @@ bool Base_Thread::set_backend_to_be_skipped_if_frontend_is_slow(DS * myds, unsig
// but assuming that client isn't completely blocked, we will stop checking for data
// only at mysql_thread___threshold_resultset_size * 4
if constexpr (std::is_same_v<T, PgSQL_Thread>) {
unsigned int buffered_data = 0;
buffered_data = myds->sess->client_myds->PSarrayOUT->len * PGSQL_RESULTSET_BUFLEN;
//buffered_data += myds->sess->client_myds->resultset->len * PGSQL_RESULTSET_BUFLEN;
const unsigned int buffered_data = myds->sess->client_myds->PSarrayOUT->len * PGSQL_RESULTSET_BUFLEN;
if (buffered_data > (unsigned int)pgsql_thread___threshold_resultset_size * 4) {
thr->mypolls.fds[n].events = 0;
return true;

@ -1757,9 +1757,7 @@ handler_again:
{
if (myds->sess && myds->sess->client_myds && myds->sess->mirror == false /* &&
myds->sess->status != SHOW_WARNINGS*/) { // see issue#4072
unsigned int buffered_data = 0;
buffered_data = myds->sess->client_myds->PSarrayOUT->len * PGSQL_RESULTSET_BUFLEN;
//buffered_data += myds->sess->client_myds->resultset->len * PGSQL_RESULTSET_BUFLEN;
const unsigned int buffered_data = myds->sess->client_myds->PSarrayOUT->len * PGSQL_RESULTSET_BUFLEN;
if (buffered_data > (unsigned int)pgsql_thread___threshold_resultset_size * 8) {
next_event(ASYNC_USE_RESULT_CONT); // we temporarily pause . See #1232
break;

Loading…
Cancel
Save