aboutsummaryrefslogtreecommitdiff
path: root/src/bayou.rs
diff options
context:
space:
mode:
authorQuentin Dufour <quentin@deuxfleurs.fr>2024-01-18 18:03:21 +0100
committerQuentin Dufour <quentin@deuxfleurs.fr>2024-01-18 18:03:21 +0100
commit2c5adc8f166c6117ece353376b9071f5e30857b1 (patch)
tree1590c1277342734ee6f06b1a388c0fc63ecd8acf /src/bayou.rs
parent43b668531f060a2c0f950da96b363b2ea7cf4e06 (diff)
downloadaerogramme-2c5adc8f166c6117ece353376b9071f5e30857b1.tar.gz
aerogramme-2c5adc8f166c6117ece353376b9071f5e30857b1.zip
reformat code
Diffstat (limited to 'src/bayou.rs')
-rw-r--r--src/bayou.rs10
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,