mirror of
https://github.com/postgresml/pgcat.git
synced 2026-03-27 10:46:30 +00:00
Ensure data makes it to the client (#446)
* Ensure data makes it to the client * flush all buffers
This commit is contained in:
@@ -1313,7 +1313,7 @@ where
|
|||||||
.receive_server_message(server, &address, &pool, &self.stats.clone())
|
.receive_server_message(server, &address, &pool, &self.stats.clone())
|
||||||
.await?;
|
.await?;
|
||||||
|
|
||||||
match write_all_half(&mut self.write, &response).await {
|
match write_all_flush(&mut self.write, &response).await {
|
||||||
Ok(_) => (),
|
Ok(_) => (),
|
||||||
Err(err) => {
|
Err(err) => {
|
||||||
server.mark_bad();
|
server.mark_bad();
|
||||||
@@ -1408,7 +1408,7 @@ where
|
|||||||
.receive_server_message(server, address, pool, client_stats)
|
.receive_server_message(server, address, pool, client_stats)
|
||||||
.await?;
|
.await?;
|
||||||
|
|
||||||
match write_all_half(&mut self.write, &response).await {
|
match write_all_flush(&mut self.write, &response).await {
|
||||||
Ok(_) => (),
|
Ok(_) => (),
|
||||||
Err(err) => {
|
Err(err) => {
|
||||||
server.mark_bad();
|
server.mark_bad();
|
||||||
|
|||||||
Reference in New Issue
Block a user