rust/neon
1
0
Fork 0
mirror of https://github.com/neondatabase/neon.git synced 2026-01-04 03:52:56 +00:00
Code Issues Packages Projects Releases Wiki Activity

cargo fmt

Browse Source
This commit is contained in:
Heikki Linnakangas
2025-07-29 16:46:54 +03:00
parent e0db31456b
commit aad301e083
1 changed files with 6 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
pgxn/neon/communicator/src/worker_process/control_socket.rs
View File

@@ -30,8 +30,8 @@ use std::sync::Arc;
use tokio::net::UnixListener;
use crate::NEON_COMMUNICATOR_SOCKET_NAME;
use crate::worker_process::main_loop::CommunicatorWorkerProcessStruct;
use crate::worker_process::lfc_metrics::LfcMetricsCollector;
use crate::worker_process::main_loop::CommunicatorWorkerProcessStruct;
enum ControlSocketState<'a> {
Full(&'a CommunicatorWorkerProcessStruct<'a>),
@@ -147,12 +147,10 @@ async fn dump_cache_map(State(state): State<Arc<ControlSocketState<'_>>>) -> Res
.body(Body::from(buf))
.unwrap()
}
ControlSocketState::Legacy(_) => {
Response::builder()
.status(StatusCode::NOT_FOUND)
.header(CONTENT_TYPE, "application/text")
.body(Body::from(Vec::new()))
.unwrap()
}
ControlSocketState::Legacy(_) => Response::builder()
.status(StatusCode::NOT_FOUND)
.header(CONTENT_TYPE, "application/text")
.body(Body::from(Vec::new()))
.unwrap(),
}
}