From 9f13a348379791c79b206e675abf811d4647cd22 Mon Sep 17 00:00:00 2001 From: Kosntantin Knizhnik Date: Thu, 26 Jun 2025 16:13:22 +0300 Subject: [PATCH] Reset prefetch ring state in case of propagated error --- pgxn/neon/communicator.c | 1 + 1 file changed, 1 insertion(+) diff --git a/pgxn/neon/communicator.c b/pgxn/neon/communicator.c index 10fe139960..70e28f7f4f 100644 --- a/pgxn/neon/communicator.c +++ b/pgxn/neon/communicator.c @@ -1453,6 +1453,7 @@ page_server_request(void const *req) * Cancellation in this code needs to be handled better at some * point, but this currently seems fine for now. */ + prefetch_on_ps_disconnect(); page_server->disconnect(shard_no); MyNeonCounters->pageserver_open_requests = 0;