aboutsummaryrefslogtreecommitdiff
path: root/src/table/sync.rs
diff options
context:
space:
mode:
Diffstat (limited to 'src/table/sync.rs')
-rw-r--r--src/table/sync.rs13
1 files changed, 10 insertions, 3 deletions
diff --git a/src/table/sync.rs b/src/table/sync.rs
index 20066d73..4c83e991 100644
--- a/src/table/sync.rs
+++ b/src/table/sync.rs
@@ -603,9 +603,16 @@ impl SyncTodo {
let retain = nodes.contains(&my_id);
if !retain {
// Check if we have some data to send, otherwise skip
- if data.store.range(begin..end).unwrap().next().is_none() {
- // TODO fix unwrap
- continue;
+ match data.store.range(begin..end) {
+ Ok(mut iter) => {
+ if iter.next().is_none() {
+ continue;
+ }
+ }
+ Err(e) => {
+ warn!("DB error in add_full_sync: {}", e);
+ continue;
+ }
}
}