From e98c5c58a5764aa6a9627f0acfa1908f513dd7d6 Mon Sep 17 00:00:00 2001 From: michael-bailey Date: Sun, 27 Sep 2020 16:50:09 +0100 Subject: [PATCH] Allowing dead code --- src/client_api/mod.rs | 6 ++++++ src/commands/mod.rs | 1 + src/lib.rs | 1 + src/server/client/client_v3.rs | 4 ++++ src/server/server_profile.rs | 2 ++ src/server/server_v3.rs | 7 +++++++ src/server/ui/control_panel.rs | 1 + 7 files changed, 22 insertions(+) diff --git a/src/client_api/mod.rs b/src/client_api/mod.rs index 3181ac2..28c9075 100644 --- a/src/client_api/mod.rs +++ b/src/client_api/mod.rs @@ -8,6 +8,7 @@ use crate::{ server::client::client_profile::Client, }; +#[allow(dead_code)] pub struct ClientApi { socket: TcpStream, addr: String, @@ -17,6 +18,8 @@ pub struct ClientApi { } impl ClientApi { + + #[allow(dead_code)] pub fn new(addr: &str) -> Result { let socket = TcpStream::connect(addr)?; @@ -31,14 +34,17 @@ impl ClientApi { Ok(a) } + #[allow(dead_code)] pub fn set_on_client_add(&mut self, func: fn(Client) -> ()) { self.on_client_add_handle = func; } + #[allow(dead_code)] pub fn set_on_client_removed(&mut self, func: fn(String) -> ()) { self.on_client_remove_handle = func; } + #[allow(dead_code)] pub fn get_info(host: &str) -> Result { let mut buffer: [u8; 1024] = [0; 1024]; let addr = host.parse().unwrap(); diff --git a/src/commands/mod.rs b/src/commands/mod.rs index c71fbc9..9d968e0 100644 --- a/src/commands/mod.rs +++ b/src/commands/mod.rs @@ -52,6 +52,7 @@ pub enum Commands { Error(Option>), } +#[allow(dead_code)] #[derive(Debug)] pub enum CommandParseError { UnknownCommand, diff --git a/src/lib.rs b/src/lib.rs index 95cbc5a..93a4a81 100644 --- a/src/lib.rs +++ b/src/lib.rs @@ -17,6 +17,7 @@ pub struct ThreadPool{ type Job = Box; +#[allow(dead_code)] impl ThreadPool{ /// Create a new ThreadPool. /// diff --git a/src/server/client/client_v3.rs b/src/server/client/client_v3.rs index d0688dd..d7b5047 100644 --- a/src/server/client/client_v3.rs +++ b/src/server/client/client_v3.rs @@ -43,6 +43,7 @@ pub struct Client { } impl Client { + #[allow(dead_code)] pub fn new(stream: TcpStream, server_sender: Sender, uuid: &str, username: &str, address: &str) -> Self { let (sender, receiver): (Sender, Receiver) = unbounded(); stream.set_read_timeout(Some(Duration::from_secs(1))).unwrap(); @@ -83,6 +84,7 @@ impl Client { } // TODO: - add heartbeat timer. + #[allow(dead_code)] pub fn handle_connection(&mut self) { let mut buffer = [0; 1024]; @@ -180,6 +182,7 @@ impl Client { self.stream.lock().unwrap().shutdown(Shutdown::Both).expect("shutdown call failed"); } + #[allow(dead_code)] pub fn send_data(&self, data: &str) { println!("Transmitting data: {}", data); @@ -195,6 +198,7 @@ impl Client { } } + #[allow(dead_code)] fn read_data(&mut self, buffer: &mut [u8; 1024]) -> Result { let _ = self.stream.lock().unwrap().read(buffer)?; let command = Commands::from(buffer); diff --git a/src/server/server_profile.rs b/src/server/server_profile.rs index 7a68729..4ad951f 100644 --- a/src/server/server_profile.rs +++ b/src/server/server_profile.rs @@ -30,6 +30,7 @@ pub enum ServerMessages { } // MARK: - server struct +#[allow(dead_code)] pub struct Server { pub name: String, pub address: String, @@ -213,6 +214,7 @@ impl Server { Ok(()) } + #[allow(dead_code)] pub fn stop(&mut self) { info!("server: sending stop message"); let _ = self.sender.send(ServerMessages::Shutdown); diff --git a/src/server/server_v3.rs b/src/server/server_v3.rs index bd47828..3f2b551 100644 --- a/src/server/server_v3.rs +++ b/src/server/server_v3.rs @@ -14,6 +14,7 @@ pub enum ServerMessages { Shutdown, } +#[allow(dead_code)] pub enum ServerState { starting, started, @@ -22,6 +23,7 @@ pub enum ServerState { } // MARK: - server struct +#[allow(dead_code)] pub struct Server { pub name: String, pub address: String, @@ -95,6 +97,7 @@ impl Server { self.owner.clone() } + #[allow(dead_code)] pub fn tick(&mut self) { // check to see if this server is ready to execute things. @@ -232,6 +235,7 @@ impl Server { } } + #[allow(dead_code)] pub fn start(&mut self) -> Result<(), io::Error> { let listener = TcpListener::bind(self.address)?; @@ -240,12 +244,14 @@ impl Server { self.listener = Some(listener); } + #[allow(dead_code)] pub fn stop(&mut self) { info!("server: sending stop message"); let _ = self.sender.send(ServerMessages::Shutdown); self.state = ServerState::stopping; } + #[allow(dead_code)] fn send_data(stream: &mut TcpStream, data: &str) -> Result<(), io::Error>{ println!("Transmitting..."); println!("data: {}", data); @@ -260,6 +266,7 @@ impl Server { Ok(()) } + #[allow(dead_code)] fn recv_data(stream: &mut TcpStream, buffer: &mut [u8; 1024]) -> Result { let _ = stream.read(buffer)?; let command = Commands::from(buffer); diff --git a/src/server/ui/control_panel.rs b/src/server/ui/control_panel.rs index 2e4a246..fa6d50d 100644 --- a/src/server/ui/control_panel.rs +++ b/src/server/ui/control_panel.rs @@ -3,6 +3,7 @@ use cursive::view::SizeConstraint; use cursive::views::{LinearLayout, ListView, Panel, ResizedView, TextView}; use crate::server::server_v3::Server; +#[allow(dead_code)] pub fn control_panel(s: &mut Cursive) -> Box { Box::new( ResizedView::new(