diff --git a/moq-api/src/server.rs b/moq-api/src/server.rs index d3cf398..8a05c16 100644 --- a/moq-api/src/server.rs +++ b/moq-api/src/server.rs @@ -71,8 +71,6 @@ async fn get_origin( ) -> Result, AppError> { let key = origin_key(&id); - log::debug!("get_origin: id={}", id); - let payload: Option = redis.get(&key).await?; let payload = payload.ok_or(AppError::NotFound)?; let origin: Origin = serde_json::from_str(&payload)?; diff --git a/moq-relay/src/origin.rs b/moq-relay/src/origin.rs index 9c7535c..7a665c9 100644 --- a/moq-relay/src/origin.rs +++ b/moq-relay/src/origin.rs @@ -94,10 +94,7 @@ impl Origin { if let Some(broadcast) = cache.get(id) { if let Some(broadcast) = broadcast.upgrade() { - log::debug!("returned broadcast from cache: id={}", id); return broadcast; - } else { - log::debug!("stale broadcast in cache somehow: id={}", id); } } @@ -109,8 +106,6 @@ impl Origin { cache.insert(id.to_string(), Arc::downgrade(&subscriber)); - log::debug!("fetching into cache: id={}", id); - let mut this = self.clone(); let id = id.to_string(); @@ -160,7 +155,6 @@ pub struct Subscriber { impl Drop for Subscriber { fn drop(&mut self) { - log::debug!("subscriber: removing from cache: id={}", self.id); self.origin.cache.lock().unwrap().remove(&self.broadcast.id); } } @@ -190,7 +184,6 @@ impl Publisher { loop { if let Some((api, origin)) = self.api.as_mut() { - log::debug!("refreshing origin: id={}", self.broadcast.id); api.patch_origin(&self.broadcast.id, origin).await?; } diff --git a/moq-transport/src/session/subscriber.rs b/moq-transport/src/session/subscriber.rs index 700cfa8..c7fdde4 100644 --- a/moq-transport/src/session/subscriber.rs +++ b/moq-transport/src/session/subscriber.rs @@ -111,7 +111,7 @@ impl Subscriber { .await .map_err(|e| SessionError::Unknown(e.to_string()))?; - log::debug!("received object: {:?}", object); + log::trace!("received object: {:?}", object); // A new scope is needed because the async compiler is dumb let mut publisher = {