diff --git a/pageserver/src/page_service.rs b/pageserver/src/page_service.rs index 96056f060a..61e21a1cd5 100644 --- a/pageserver/src/page_service.rs +++ b/pageserver/src/page_service.rs @@ -284,6 +284,8 @@ async fn page_service_conn_main( socket.set_timeout(Some(std::time::Duration::from_millis(socket_timeout_ms))); let socket = Box::pin(socket); + let socket = tokio::io::BufStream::with_capacity(128<<10, 128<<10, socket); + fail::fail_point!("ps::connection-start::pre-login"); // XXX: pgbackend.run() should take the connection_ctx,