From 6212dc5e2f4ee3b6b172af17d7b8b0e49a201711 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Fran=C3=A7ois=20Michel?= Date: Sat, 15 Jul 2023 11:21:18 +0000 Subject: [PATCH] restore tokio version and remove unneeded comments fin moq-demo-quinn --- moq-demo-quinn/Cargo.toml | 2 +- moq-demo-quinn/src/server/mod.rs | 22 ---------------------- 2 files changed, 1 insertion(+), 23 deletions(-) diff --git a/moq-demo-quinn/Cargo.toml b/moq-demo-quinn/Cargo.toml index eeca77d..2d9aee4 100644 --- a/moq-demo-quinn/Cargo.toml +++ b/moq-demo-quinn/Cargo.toml @@ -25,7 +25,7 @@ rustls = "0.21.2" rustls-pemfile = "1.0.2" # Async stuff -tokio = { version = "1.29.1", features = ["full"] } +tokio = { version = "1.27", features = ["full"] } # Web server to serve the fingerprint warp = { version = "0.3.3", features = ["tls"] } diff --git a/moq-demo-quinn/src/server/mod.rs b/moq-demo-quinn/src/server/mod.rs index b2a831a..0cb2b35 100644 --- a/moq-demo-quinn/src/server/mod.rs +++ b/moq-demo-quinn/src/server/mod.rs @@ -120,28 +120,6 @@ impl Server { } } - // pub async fn run(mut self) -> anyhow::Result<()> { - // loop { - // tokio::select! { - // res = self.server.accept() => { - // let session = res.context("failed to accept connection")?; - // let broker = self.broker.clone(); - - // self.tasks.spawn(async move { - // let session: Session = Session::accept(session, broker).await?; - // session.run().await - // }); - // }, - // res = self.tasks.join_next(), if !self.tasks.is_empty() => { - // let res = res.expect("no tasks").expect("task aborted"); - - // if let Err(err) = res { - // log::error!("session terminated: {:?}", err); - // } - // }, - // } - // } - // } } // The WebTransport CONNECT has arrived, and we need to decide if we accept it.