chore: clean up

This commit is contained in:
Yujia Qiao 2022-01-02 11:04:20 +08:00
parent 9f8a324d35
commit cca74fbc2a
No known key found for this signature in database
GPG Key ID: DC129173B148701B
2 changed files with 1 additions and 5 deletions

View File

@ -370,7 +370,7 @@ impl<T: 'static + Transport> ControlChannel<T> {
conn.write_all(&bincode::serialize(&hello_send).unwrap()) conn.write_all(&bincode::serialize(&hello_send).unwrap())
.await?; .await?;
// Read hello)) // Read hello
debug!("Reading hello"); debug!("Reading hello");
let nonce = match read_hello(&mut conn) let nonce = match read_hello(&mut conn)
.await .await

View File

@ -48,7 +48,6 @@ pub async fn run_server(
} }
}; };
//TODO: Maybe use a Box<dyn trait> here to reduce duplicated code
match config.transport.transport_type { match config.transport.transport_type {
TransportType::Tcp => { TransportType::Tcp => {
let mut server = Server::<TcpTransport>::from(config).await?; let mut server = Server::<TcpTransport>::from(config).await?;
@ -86,8 +85,6 @@ struct Server<'a, T: Transport> {
// `[server]` config // `[server]` config
config: &'a ServerConfig, config: &'a ServerConfig,
// TODO: Maybe the rwlock is unnecessary.
// Keep it until the hot reloading feature is implemented
// `[server.services]` config, indexed by ServiceDigest // `[server.services]` config, indexed by ServiceDigest
services: Arc<RwLock<HashMap<ServiceDigest, ServerServiceConfig>>>, services: Arc<RwLock<HashMap<ServiceDigest, ServerServiceConfig>>>,
// Collection of contorl channels // Collection of contorl channels
@ -332,7 +329,6 @@ async fn do_data_channel_handshake<T: 'static + Transport>(
handle.data_ch_tx.send(conn).await?; handle.data_ch_tx.send(conn).await?;
} }
None => { None => {
// TODO: Maybe print IP here
warn!("Data channel has incorrect nonce"); warn!("Data channel has incorrect nonce");
} }
} }