nik/chorus
1
0
Fork 0
mirror of https://github.com/mikedilger/chorus.git synced 2026-05-03 06:51:42 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

Maybe fix the zeroes?

Browse Source
This commit is contained in:
Mike Dilger 2024-07-13 12:48:13 +12:00
parent 7ad5fb3e15
commit 051a81febd
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/lib.rs
View File

@ -141,7 +141,7 @@ async fn handle_http_request_outer(
.or_insert(1);
// Get the response, but do not throw error at this point
let response = handle_http_request_inner(peer, request);
let response = handle_http_request_inner(peer, request).await;
// Decrement connection counts
match GLOBALS.num_connections_per_ip.get_mut(&peer.ip()) {
@ -157,7 +157,7 @@ async fn handle_http_request_outer(
let _ = GLOBALS.num_connections.fetch_sub(1, Ordering::SeqCst);
// Now we return after the counts have gone up and down
response.await
response
}
async fn handle_http_request_inner(
@ -220,7 +220,7 @@ async fn handle_http_request_inner(
target: "Server",
"{}: TOTAL={}, New Connection: {}, {}",
peer,
GLOBALS.num_connections.load(Ordering::Relaxed),
GLOBALS.num_connections.load(Ordering::Acquire),
origin,
ua,
);
@ -289,7 +289,7 @@ async fn handle_http_request_inner(
target: "Server",
"{}: TOTAL={}, {}, ban={}s",
peer,
GLOBALS.num_connections.load(Ordering::Relaxed),
GLOBALS.num_connections.load(Ordering::Acquire),
msg,
ban_seconds
);