summaryrefslogtreecommitdiffstats
path: root/src/bin/server/args.rs
diff options
context:
space:
mode:
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 @@
1use std::io::{BufRead, BufReader, Write}; 1pub struct Args {
2use std::net::TcpListener; 2 pub ip: String,
3use std::thread; 3 pub port: u16,
4
5fn 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
18fn main() { 6pub 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}