aboutsummaryrefslogtreecommitdiff
path: root/src/table
diff options
context:
space:
mode:
authorAlex Auvolat <alex@adnab.me>2022-06-21 18:04:03 +0200
committerAlex Auvolat <alex@adnab.me>2022-06-21 18:04:03 +0200
commit8fb8569912745ea90e8d0dd8313b431774780ad2 (patch)
treed5fdeb6efcfe50819b596c0333842989ac6a0abf /src/table
parent708dab6e0ff8c2dab5cac39a1f64a5e391c32137 (diff)
downloadgarage-8fb8569912745ea90e8d0dd8313b431774780ad2.tar.gz
garage-8fb8569912745ea90e8d0dd8313b431774780ad2.zip
fix clippy
Diffstat (limited to 'src/table')
-rw-r--r--src/table/sync.rs5
1 files changed, 2 insertions, 3 deletions
diff --git a/src/table/sync.rs b/src/table/sync.rs
index bdf88782..a331ec75 100644
--- a/src/table/sync.rs
+++ b/src/table/sync.rs
@@ -597,11 +597,10 @@ impl<F: TableSchema + 'static, R: TableReplication + 'static> Worker for SyncWor
async fn wait_for_work(&mut self, _must_exit: &watch::Receiver<bool>) -> WorkerStatus {
select! {
- s = self.add_full_sync_rx.recv() => match s {
- Some(()) => {
+ s = self.add_full_sync_rx.recv() => {
+ if let Some(()) = s {
self.add_full_sync();
}
- None => (),
},
_ = self.ring_recv.changed() => {
let new_ring = self.ring_recv.borrow();