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

cargo fmt

Browse Source
This commit is contained in:
Heikki Linnakangas
2025-07-05 14:09:06 +03:00
parent 17ec37aab2
commit f3a6c0d8ff
1 changed files with 6 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
pgxn/neon/communicator/src/worker_process/main_loop.rs
View File

@@ -219,7 +219,7 @@ impl<'t> CommunicatorWorkerProcessStruct<'t> {
"processing",
request_id = request_id,
slot_idx = slot_idx,
procno=owner_procno,
procno = owner_procno,
);
async {
// FIXME: as a temporary hack, abort the request if we don't get a response
@@ -233,11 +233,11 @@ impl<'t> CommunicatorWorkerProcessStruct<'t> {
tokio::time::Duration::from_secs(30),
self.handle_request(slot.get_request()),
)
.await
.unwrap_or_else(|_elapsed| {
info!("request {request_id} timed out");
NeonIOResult::Error(libc::ETIMEDOUT)
});
.await
.unwrap_or_else(|_elapsed| {
info!("request {request_id} timed out");
NeonIOResult::Error(libc::ETIMEDOUT)
});
trace!("request {request_id} at slot {slot_idx} completed");
// Ok, we have completed the IO. Mark the request as completed. After that,