diff options
author | Katharina Fey <kookie@spacekookie.de> | 2021-02-14 00:06:14 +0100 |
---|---|---|
committer | Katharina Fey <kookie@spacekookie.de> | 2021-02-14 00:06:14 +0100 |
commit | effbdeed66e8de8e769b8ac069926ad1a9110e62 (patch) | |
tree | e4522354e53266204aa9962caccde55d8c815092 /games/rstnode/rst-server/src/net/mod.rs | |
parent | 5dab336049dbc6817e9ff212998690f59f6bbfa8 (diff) |
* Add an inbox/ outbox system to server components
* Define a data flow from Request -> computation -> Update
* Create simple handlers to call server or client code for requests
Diffstat (limited to 'games/rstnode/rst-server/src/net/mod.rs')
-rw-r--r-- | games/rstnode/rst-server/src/net/mod.rs | 43 |
1 files changed, 0 insertions, 43 deletions
diff --git a/games/rstnode/rst-server/src/net/mod.rs b/games/rstnode/rst-server/src/net/mod.rs deleted file mode 100644 index deb35f7f89b9..000000000000 --- a/games/rstnode/rst-server/src/net/mod.rs +++ /dev/null @@ -1,43 +0,0 @@ -#![allow(unused)] - -mod parser; - -use async_std::{ - net::UdpSocket, - sync::{Arc, RwLock}, - task, -}; -use rst_core::Id; -use std::{collections::BTreeMap, net::SocketAddr}; - -pub struct ServerEndpoint { - socket: UdpSocket, - bind: String, - clients: RwLock<BTreeMap<Id, Client>>, -} - -impl ServerEndpoint { - pub async fn new(bind: &str) -> Arc<Self> { - let socket = UdpSocket::bind(bind).await.unwrap(); - Arc::new(Self { - socket, - bind: bind.into(), - clients: Default::default(), - }) - } - - pub async fn listen(self: &Arc<Self>) { - let mut buf = vec![0; 1024]; - - info!("Listening for connections on {}", self.bind); - - loop { - let (_, peer) = self.socket.recv_from(&mut buf).await.unwrap(); - } - } -} - -pub struct Client { - addr: SocketAddr, -} - |