From 7e13e5fc4a8074892002c4c0863e159c9f9bf3e4 Mon Sep 17 00:00:00 2001 From: Christian Schwarz Date: Thu, 16 Jan 2025 16:41:47 +0100 Subject: [PATCH] experiment: buffered socket with 128k buffer size; not super needle-moving --- pageserver/src/page_service.rs | 2 ++ 1 file changed, 2 insertions(+) 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,