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

aquatic_ws: use unbounded local out message channel

Browse source
This commit is contained in:
Joakim Frostegård 2021-11-02 11:57:43 +01:00
parent 3e3acd5adf
commit 2f5e023fd7
1 changed files with 2 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

4
aquatic_ws/src/lib/network.rs
View file

@ -17,7 +17,7 @@ use futures_lite::StreamExt;
use futures_rustls::server::TlsStream; use futures_rustls::server::TlsStream;
use futures_rustls::TlsAcceptor; use futures_rustls::TlsAcceptor;
use glommio::channels::channel_mesh::{MeshBuilder, Partial, Role, Senders}; use glommio::channels::channel_mesh::{MeshBuilder, Partial, Role, Senders};
use glommio::channels::local_channel::{new_bounded, LocalReceiver, LocalSender}; use glommio::channels::local_channel::{LocalReceiver, LocalSender, new_unbounded};
use glommio::channels::shared_channel::ConnectedReceiver; use glommio::channels::shared_channel::ConnectedReceiver;
use glommio::net::{TcpListener, TcpStream}; use glommio::net::{TcpListener, TcpStream};
use glommio::timer::TimerActionRepeat; use glommio::timer::TimerActionRepeat;
@ -96,7 +96,7 @@ pub async fn run_socket_worker(
match stream { match stream {
Ok(stream) => { Ok(stream) => {
let (out_message_sender, out_message_receiver) = let (out_message_sender, out_message_receiver) =
new_bounded(config.request_workers + 1); new_unbounded();
let out_message_sender = Rc::new(out_message_sender); let out_message_sender = Rc::new(out_message_sender);
let key = RefCell::borrow_mut(&connection_slab).insert(ConnectionReference { let key = RefCell::borrow_mut(&connection_slab).insert(ConnectionReference {