tyiu/notedeck
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

multi_subscriber: switch to debug statements

Browse Source 
info is not really the right level for this
This commit is contained in:
William Casarin
2025-07-16 16:36:26 -07:00
parent 5168d50257
commit a603685fac
1 changed files with 11 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

22
crates/notedeck_columns/src/multi_subscriber.rs
View File

@@ -79,7 +79,7 @@ impl ThreadSubs {
remote.dependers = remote.dependers.saturating_add_signed(new_subs); remote.dependers = remote.dependers.saturating_add_signed(new_subs);
let num_dependers = remote.dependers; let num_dependers = remote.dependers;
tracing::info!( tracing::debug!(
"Sub stats: num remotes: {}, num locals: {}, num remote dependers: {:?}", "Sub stats: num remotes: {}, num locals: {}, num remote dependers: {:?}",
self.remotes.len(), self.remotes.len(),
self.scopes.len(), self.scopes.len(),
@@ -153,11 +153,11 @@ impl ThreadSubs {
.remotes .remotes
.remove(&id.root_id.bytes()) .remove(&id.root_id.bytes())
.expect("code above should guarentee existence"); .expect("code above should guarentee existence");
tracing::info!("Remotely unsubscribed: {}", remote.subid); tracing::debug!("Remotely unsubscribed: {}", remote.subid);
pool.unsubscribe(remote.subid); pool.unsubscribe(remote.subid);
} }
tracing::info!( tracing::debug!(
"unsub stats: num remotes: {}, num locals: {}, num remote dependers: {:?}", "unsub stats: num remotes: {}, num locals: {}, num remote dependers: {:?}",
self.remotes.len(), self.remotes.len(),
self.scopes.len(), self.scopes.len(),
@@ -204,7 +204,7 @@ fn ndb_sub(ndb: &Ndb, filter: &[Filter], id: impl std::fmt::Debug) -> Option<Sub
match ndb.subscribe(filter) { match ndb.subscribe(filter) {
Ok(s) => Some(s), Ok(s) => Some(s),
Err(e) => { Err(e) => {
tracing::info!("Failed to get subscription for {:?}: {e}", id); tracing::error!("Failed to get subscription for {:?}: {e}", id);
None None
} }
} }
@@ -214,7 +214,7 @@ fn ndb_unsub(ndb: &mut Ndb, sub: Subscription, id: impl std::fmt::Debug) -> bool
match ndb.unsubscribe(sub) { match ndb.unsubscribe(sub) {
Ok(_) => true, Ok(_) => true,
Err(e) => { Err(e) => {
tracing::info!("Failed to unsub {:?}: {e}", id); tracing::error!("Failed to unsub {:?}: {e}", id);
false false
} }
} }
@@ -235,7 +235,7 @@ fn sub_remote(
dependers: 0, dependers: 0,
}; };
tracing::info!("Remote subscribe for {:?}", id); tracing::debug!("Remote subscribe for {:?}", id);
pool.subscribe(subid, filter); pool.subscribe(subid, filter);
@@ -334,7 +334,7 @@ impl TimelineSub {
dependers: _, dependers: _,
} => {} } => {}
} }
tracing::info!( tracing::debug!(
"TimelineSub::try_add_local: {:?} => {:?}", "TimelineSub::try_add_local: {:?} => {:?}",
before, before,
self.state self.state
@@ -368,7 +368,7 @@ impl TimelineSub {
dependers: _, dependers: _,
} => {} } => {}
} }
tracing::info!( tracing::debug!(
"TimelineSub::force_add_remote: {:?} => {:?}", "TimelineSub::force_add_remote: {:?} => {:?}",
before, before,
self.state self.state
@@ -408,7 +408,7 @@ impl TimelineSub {
dependers: _, dependers: _,
} => {} } => {}
} }
tracing::info!( tracing::debug!(
"TimelineSub::try_add_remote: {:?} => {:?}", "TimelineSub::try_add_remote: {:?} => {:?}",
before, before,
self.state self.state
@@ -441,7 +441,7 @@ impl TimelineSub {
} }
} }
tracing::info!("TimelineSub::increment: {:?} => {:?}", before, self.state); tracing::debug!("TimelineSub::increment: {:?} => {:?}", before, self.state);
} }
pub fn get_local(&self) -> Option<Subscription> { pub fn get_local(&self) -> Option<Subscription> {
@@ -512,7 +512,7 @@ impl TimelineSub {
} }
} }
} }
tracing::info!( tracing::debug!(
"TimelineSub::unsubscribe_or_decrement: {:?} => {:?}", "TimelineSub::unsubscribe_or_decrement: {:?} => {:?}",
before, before,
self.state self.state