ae/contego
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

increased mpsc buffer sizes, hopefully resolves #3

Browse Source
This commit is contained in:
17ms 2023-04-16 01:15:18 +03:00
parent b8e6f81338
commit 34cf303964
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
tests/sockets_integration.rs
View File

@ -33,10 +33,10 @@ fn filesync_signals() {
let output_path = PathBuf::from("./tests/output/"); let output_path = PathBuf::from("./tests/output/");
let server_addr = SocketAddr::from(([127, 0, 0, 1], 9191)); let server_addr = SocketAddr::from(([127, 0, 0, 1], 9191));
let (kill_server_tx, server_rx) = mpsc::channel::<Message>(2); let (kill_server_tx, server_rx) = mpsc::channel::<Message>(10);
let (server_tx, mut local_server_rx) = mpsc::channel::<Message>(2); let (server_tx, mut local_server_rx) = mpsc::channel::<Message>(10);
let (local_client_tx, client_rx) = mpsc::channel::<Message>(2); let (local_client_tx, client_rx) = mpsc::channel::<Message>(10);
let (client_tx, mut local_client_rx) = mpsc::channel::<Message>(2); let (client_tx, mut local_client_rx) = mpsc::channel::<Message>(10);
let server_handle = thread::spawn(move || { let server_handle = thread::spawn(move || {
let listener = Listener::new(server_addr, "xyz", 8192usize); let listener = Listener::new(server_addr, "xyz", 8192usize);