YGGverse/aquatic
1
0
Fork 0
mirror of https://github.com/YGGverse/aquatic.git synced 2026-03-31 17:55:36 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

http: small socket worker fixes

Browse source
This commit is contained in:
Joakim Frostegård 2022-04-10 03:18:57 +02:00
parent f083cac9e0
commit 94b4e4a935
1 changed files with 4 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

6
aquatic_http/src/workers/socket.rs
View file

@ -327,7 +327,7 @@ impl Connection {
}
let pending_worker_responses = info_hashes_by_worker.len();
let mut response_receivers = Vec::new();
let mut response_receivers = Vec::with_capacity(pending_worker_responses);
for (consumer_index, info_hashes) in info_hashes_by_worker {
let (response_sender, response_receiver) = shared_channel::new_bounded(1);
@ -374,7 +374,9 @@ impl Connection {
let response = responses
.next()
.await
.ok_or_else(|| anyhow::anyhow!("wait_for_scrape_response: all messages received"))?
.ok_or_else(|| {
anyhow::anyhow!("stream ended before all partial scrape responses received")
})?
.ok_or_else(|| {
anyhow::anyhow!(
"wait_for_scrape_response: can't receive response, sender is closed"