diff options
Diffstat (limited to '')
| -rw-r--r-- | src/bin/server/args.rs (renamed from src/bin/server.rs) | 37 |
1 files changed, 6 insertions, 31 deletions
diff --git a/src/bin/server.rs b/src/bin/server/args.rs index 215d2ae..31c0acc 100644 --- a/src/bin/server.rs +++ b/src/bin/server/args.rs | |||
| @@ -1,24 +1,12 @@ | |||
| 1 | use std::io::{BufRead, BufReader, Write}; | 1 | pub struct Args { |
| 2 | use std::net::TcpListener; | 2 | pub ip: String, |
| 3 | use std::thread; | 3 | pub port: u16, |
| 4 | |||
| 5 | fn handle_client(stream: std::net::TcpStream) { | ||
| 6 | println!("Client connected"); | ||
| 7 | let reader_stream = stream.try_clone().unwrap(); | ||
| 8 | let reader = BufReader::new(reader_stream); | ||
| 9 | let mut writer = stream; | ||
| 10 | for line in reader.lines() { | ||
| 11 | let line = line.unwrap(); | ||
| 12 | println!("Received: {}", line); | ||
| 13 | writeln!(writer, "{}", line).unwrap(); | ||
| 14 | } | ||
| 15 | println!("Client disconnected"); | ||
| 16 | } | 4 | } |
| 17 | 5 | ||
| 18 | fn main() { | 6 | pub fn parse_args() -> Args { |
| 19 | let args: Vec<String> = std::env::args().collect(); | 7 | let args: Vec<String> = std::env::args().collect(); |
| 20 | let mut ip = "127.0.0.1".to_string(); | 8 | let mut ip = "127.0.0.1".to_string(); |
| 21 | let mut port = 8080; | 9 | let mut port = 11525; |
| 22 | let mut i = 1; | 10 | let mut i = 1; |
| 23 | while i < args.len() { | 11 | while i < args.len() { |
| 24 | if args[i] == "-p" { | 12 | if args[i] == "-p" { |
| @@ -49,18 +37,5 @@ fn main() { | |||
| 49 | std::process::exit(1); | 37 | std::process::exit(1); |
| 50 | } | 38 | } |
| 51 | } | 39 | } |
| 52 | let listener = match TcpListener::bind(format!("{}:{}", ip, port)) { | 40 | Args { ip, port } |
| 53 | Ok(l) => l, | ||
| 54 | Err(e) => { | ||
| 55 | eprintln!("Failed to bind to {}:{}: {}", ip, port, e); | ||
| 56 | std::process::exit(1); | ||
| 57 | } | ||
| 58 | }; | ||
| 59 | println!("Server listening on {}", listener.local_addr().unwrap()); | ||
| 60 | for stream in listener.incoming() { | ||
| 61 | let stream = stream.unwrap(); | ||
| 62 | thread::spawn(move || { | ||
| 63 | handle_client(stream); | ||
| 64 | }); | ||
| 65 | } | ||
| 66 | } | 41 | } |
