YGGverse/aquatic
1
0
Fork 0
mirror of https://github.com/YGGverse/aquatic.git synced 2026-04-01 02:05:30 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

aquatic_http: glommio: fix channel join deadlock in network.rs

Browse source
This commit is contained in:
Joakim Frostegård 2021-10-27 01:52:49 +02:00
parent bbf781ddd6
commit 3e912bb379
1 changed files with 3 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

7
aquatic_http/src/lib/glommio/network.rs
View file

@ -54,13 +54,12 @@ pub async fn run_socket_worker(
let listener = TcpListener::bind(config.network.address).expect("bind socket");
num_bound_sockets.fetch_add(1, Ordering::SeqCst);
let (_, mut response_receivers) = response_mesh_builder.join(Role::Consumer).await.unwrap();
let response_consumer_id = ConsumerId(response_receivers.consumer_id().unwrap());
let (request_senders, _) = request_mesh_builder.join(Role::Producer).await.unwrap();
let request_senders = Rc::new(request_senders);
let (_, mut response_receivers) = response_mesh_builder.join(Role::Consumer).await.unwrap();
let response_consumer_id = ConsumerId(response_receivers.consumer_id().unwrap());
let connection_slab = Rc::new(RefCell::new(Slab::new()));
for (_, response_receiver) in response_receivers.streams() {