Move PageServerHandler process_query content

This commit is contained in:
Arpad Müller
2024-04-28 00:30:46 +02:00
parent bf369f4268
commit d1fb4a4a00

View File

@@ -1415,6 +1415,16 @@ where
&mut self,
pgb: &mut PostgresBackend<IO>,
query_string: &str,
) -> Result<(), QueryError> {
self.process_query_(pgb, &query_string).await
}
}
impl PageServerHandler {
async fn process_query_<IO: AsyncRead + AsyncWrite + Send + Sync + Unpin>(
&mut self,
pgb: &mut PostgresBackend<IO>,
query_string: &str,
) -> Result<(), QueryError> {
fail::fail_point!("simulated-bad-compute-connection", |_| {
info!("Hit failpoint for bad connection");