chk
/
AppFlowy-Cloud
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

chore: add stream key info to stream length exceeded check

This commit is contained in:
Bartosz Sypytkowski 2024-11-06 07:49:25 +01:00
parent f328e96763
commit 9c428f1d89
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
libs/collab-stream/src/stream_group.rs
View File

@ -418,12 +418,12 @@ impl StreamGroup {
_ = interval.tick() => {
if let Ok(len) = get_stream_length(&mut connection_manager, &stream_key).await {
if len + 100 > max_len {
warn!("stream len is going to exceed the max len: {}, current: {}", max_len, len);
warn!("stream `{}` len is going to exceed the max len: {}, current: {}", stream_key, max_len, len);
}
}
}
_ = cancel_token.cancelled() => {
trace!("Stream length check task cancelled.");
trace!("Stream `{}` length check task cancelled.", stream_key);
break;
}
}