summaryrefslogtreecommitdiff
path: root/game_server/src
diff options
context:
space:
mode:
authorDennis Kobert <d-kobert@web.de>2019-05-31 04:57:08 +0200
committerDennis Kobert <d-kobert@web.de>2019-05-31 04:57:08 +0200
commitcdb4799231837e1e1a07f484b0b8a944819e6e78 (patch)
treeabc1115d7b300d2fd5c5a421f6376dcc346fb95b /game_server/src
parent1b6b5acf63d5d78207dcd746d080cafcd1bfbd84 (diff)
Get rid of WarningGet rid of Warninss
Diffstat (limited to 'game_server/src')
-rw-r--r--game_server/src/lobby.rs4
-rw-r--r--game_server/src/scribble_group.rs2
-rw-r--r--game_server/src/server.rs14
3 files changed, 12 insertions, 8 deletions
diff --git a/game_server/src/lobby.rs b/game_server/src/lobby.rs
index d03bd45..ef164af 100644
--- a/game_server/src/lobby.rs
+++ b/game_server/src/lobby.rs
@@ -9,6 +9,7 @@ pub struct Lobby {
groups: HashMap<GroupId, Box<Group>>,
}
+#[allow(dead_code)]
impl Lobby {
pub fn new() -> Self {
Self {
@@ -21,7 +22,7 @@ impl Lobby {
"scribble" => {
Some(Box::new(ScribbleGroup::new(id, name.to_string())))
},
- other => None,
+ _ => None,
}
}
@@ -48,6 +49,7 @@ impl Lobby {
}
}
+#[allow(dead_code)]
pub struct GroupIterator<'a> {
groups: std::collections::hash_map::Values<'a, GroupId, Box<Group>>
}
diff --git a/game_server/src/scribble_group.rs b/game_server/src/scribble_group.rs
index 2eb16f2..0d2c0f1 100644
--- a/game_server/src/scribble_group.rs
+++ b/game_server/src/scribble_group.rs
@@ -29,7 +29,7 @@ impl Group for ScribbleGroup {
fn add_client(&mut self, id: UserId, client: GameClient) {
debug!("user {} joined the group {}:'{}'", id, self.id, self.name);
- let (sen, mut rec) = client.split();
+ let (sen, rec) = client.split();
self.senders.lock().unwrap().insert(id, sen);
let senders_mutex = self.senders.clone();
let self_uid = id;
diff --git a/game_server/src/server.rs b/game_server/src/server.rs
index ea33e2a..0b76f15 100644
--- a/game_server/src/server.rs
+++ b/game_server/src/server.rs
@@ -8,7 +8,6 @@ use websocket::{OwnedMessage,
use std::net::{SocketAddr, ToSocketAddrs, TcpStream};
use std::sync::{mpsc,
mpsc::{Sender, Receiver}};
-use std::collections::HashMap;
use super::lobby::Lobby;
use super::backend_connection::BackendConnection;
@@ -121,16 +120,19 @@ impl GameServer {
}
fn read_clients(&self) -> Receiver<ClientConnection> {
- let (s, r): (Sender<ClientConnection>, Receiver<ClientConnection>)
+ let (sen, rec): (Sender<ClientConnection>, Receiver<ClientConnection>)
= mpsc::channel();
let addr = self.addr;
std::thread::spawn(move || {
- let result = Self::handle_requests(addr, &s).or_else(|e| s.send(Err(e)));
+ match Self::handle_requests(addr, &sen) {
+ Err(e) => sen.send(Err(e)).unwrap(),
+ _ => (),
+ }
});
- r
+ rec
}
- fn handle_requests(addr: SocketAddr, s: &Sender<ClientConnection>) -> Result<(), GameServerError> {
+ fn handle_requests(addr: SocketAddr, sen: &Sender<ClientConnection>) -> Result<(), GameServerError> {
let server = match Server::<NoTlsAcceptor>::bind(addr) {
Ok(v) => v,
Err(e) => {
@@ -140,7 +142,7 @@ impl GameServer {
};
info!("webserver is being launched");
for req in server {
- s.send(Ok(Self::handle_request(req)?)).unwrap();
+ sen.send(Ok(Self::handle_request(req)?)).unwrap();
}
info!("webserver is being shut down");
Ok(())