diff options
author | Quentin Dufour <quentin@deuxfleurs.fr> | 2024-01-18 18:03:21 +0100 |
---|---|---|
committer | Quentin Dufour <quentin@deuxfleurs.fr> | 2024-01-18 18:03:21 +0100 |
commit | 2c5adc8f166c6117ece353376b9071f5e30857b1 (patch) | |
tree | 1590c1277342734ee6f06b1a388c0fc63ecd8acf /src/bayou.rs | |
parent | 43b668531f060a2c0f950da96b363b2ea7cf4e06 (diff) | |
download | aerogramme-2c5adc8f166c6117ece353376b9071f5e30857b1.tar.gz aerogramme-2c5adc8f166c6117ece353376b9071f5e30857b1.zip |
reformat code
Diffstat (limited to 'src/bayou.rs')
-rw-r--r-- | src/bayou.rs | 10 |
1 files changed, 8 insertions, 2 deletions
diff --git a/src/bayou.rs b/src/bayou.rs index 1c157e6..9faff5a 100644 --- a/src/bayou.rs +++ b/src/bayou.rs @@ -442,7 +442,12 @@ impl K2vWatch { let propagate_local_update = Notify::new(); let learnt_remote_update = Arc::new(Notify::new()); - let watch = Arc::new(K2vWatch { target, rx, propagate_local_update, learnt_remote_update }); + let watch = Arc::new(K2vWatch { + target, + rx, + propagate_local_update, + learnt_remote_update, + }); tokio::spawn(Self::background_task(Arc::downgrade(&watch), storage, tx)); @@ -462,7 +467,8 @@ impl K2vWatch { while let Some(this) = Weak::upgrade(&self_weak) { tracing::debug!( "bayou k2v watch bg loop iter ({}, {})", - this.target.uid.shard, this.target.uid.sort + this.target.uid.shard, + this.target.uid.sort ); tokio::select!( // Needed to exit: will force a loop iteration every minutes, |