diff --git a/lib/PgSQL_Session.cpp b/lib/PgSQL_Session.cpp index 6f5a016b4..773358cb0 100644 --- a/lib/PgSQL_Session.cpp +++ b/lib/PgSQL_Session.cpp @@ -2299,7 +2299,6 @@ __implicit_sync: // if the previous message succeeded (it was not queried on backend server) // and there are more messages in the queue, sync needs to be executed again if (rc == 0 && extended_query_frame.empty() == false) { - writeout(); goto __run_sync_again; } } @@ -2708,7 +2707,6 @@ handler_again: // Extended query synchronization complete; clean up and prepare for next command if (rc == 0) { if (extended_query_frame.empty() == false) { - writeout(); NEXT_IMMEDIATE(PROCESSING_EXTENDED_QUERY_SYNC); } @@ -3082,8 +3080,7 @@ handler_again: } if (has_pending_messages) { // check if there are messages remaining in extended_query_frame, - // if yes, send response to client and process pending messages - writeout(); + // if yes, process pending messages NEXT_IMMEDIATE(PROCESSING_EXTENDED_QUERY_SYNC); } extended_query_phase = EXTQ_PHASE_IDLE;