caleb/protohackers-rs
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

spawn threads per listener and listen on all addresses

Browse source
This commit is contained in:
Caleb Webber 2024-03-01 19:39:18 -05:00
parent 2bdee1320a
commit 1d5a1aa2b1
1 changed files with 17 additions and 13 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

30
src/bin/smoke.rs
View file

@ -2,25 +2,29 @@ use std::{io::{Read, Write}, net::TcpListener};
const PORT: usize = 10000;
const BUFF_SIZE: usize = 1;
fn main() -> std::io::Result<()> {
let listener = TcpListener::bind(format!("127.0.0.1:{PORT}"))?;
let listener = TcpListener::bind(format!("0.0.0.0:{PORT}"))?;
for stream in listener.incoming() {
match stream {
Ok(mut stream) => {
loop {
let mut buf: [u8; BUFF_SIZE] = [0; BUFF_SIZE];
std::thread::spawn(move || {
match stream {
Ok(mut stream) => {
loop {
let mut buf: [u8; BUFF_SIZE] = [0; BUFF_SIZE];
if let Ok(_) = stream.read_exact(&mut buf) {
stream.write(&buf)?;
} else {
break;
if let Ok(_) = stream.read_exact(&mut buf) {
println!("{:?}", &buf);
let _ = stream.write(&buf);
} else {
break;
}
}
}
},
Err(e) => panic!("{:?}", e)
}
},
Err(e) => panic!("{:?}", e)
}
});
}
Ok(())