diff options
| author | Alex Auvolat <alex@adnab.me> | 2021-03-15 22:36:41 +0100 |
|---|---|---|
| committer | Alex Auvolat <alex@adnab.me> | 2021-03-15 22:36:41 +0100 |
| commit | 0cd5b2ae19965b8c1f3176afeb8f678c4d8366dd (patch) | |
| tree | a3f57c18da5377a618c38f3e4bba002c9eed1358 /src/table/data.rs | |
| parent | 4d4117f2b4eb69b63e2329f6e0b8929e6a8b5b31 (diff) | |
| download | garage-0cd5b2ae19965b8c1f3176afeb8f678c4d8366dd.tar.gz garage-0cd5b2ae19965b8c1f3176afeb8f678c4d8366dd.zip | |
WIP migrate to tokio 1
Diffstat (limited to 'src/table/data.rs')
| -rw-r--r-- | src/table/data.rs | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/src/table/data.rs b/src/table/data.rs index 0a7b2cec..0029b936 100644 --- a/src/table/data.rs +++ b/src/table/data.rs @@ -159,7 +159,7 @@ where if let Some((old_entry, new_entry, new_bytes_hash)) = changed { let is_tombstone = new_entry.is_tombstone(); self.instance.updated(old_entry, Some(new_entry)); - self.merkle_updater.todo_notify.notify(); + self.merkle_updater.todo_notify.notify_one(); if is_tombstone { self.gc_todo.insert(&tree_key, new_bytes_hash.as_slice())?; } @@ -184,7 +184,7 @@ where if removed { let old_entry = self.decode_entry(v)?; self.instance.updated(Some(old_entry), None); - self.merkle_updater.todo_notify.notify(); + self.merkle_updater.todo_notify.notify_one(); } Ok(removed) } @@ -209,7 +209,7 @@ where if let Some(old_v) = removed { let old_entry = self.decode_entry(&old_v[..])?; self.instance.updated(Some(old_entry), None); - self.merkle_updater.todo_notify.notify(); + self.merkle_updater.todo_notify.notify_one(); Ok(true) } else { Ok(false) |