diff --git a/noq-proto/src/connection/mod.rs b/noq-proto/src/connection/mod.rs index 7ea97e69b..cd62c95fc 100644 --- a/noq-proto/src/connection/mod.rs +++ b/noq-proto/src/connection/mod.rs @@ -664,6 +664,8 @@ impl Connection { } } + trace!(%path_id, ?reason, "closing path"); + // Send PATH_ABANDON self.spaces[SpaceId::Data] .pending @@ -986,8 +988,8 @@ impl Connection { return None; } StateType::Draining | StateType::Closed => { - // self.close is only reset once the associated packet had been - // encoded successfully + // self.connection_close_pending is only reset once the associated packet + // had been encoded successfully if !self.connection_close_pending { self.app_limited = true; return None;