+1 -1

constellation/src/bin/main.rs

reviewed

··· 123 123 let rocks = rocks.clone(); 124 124 let stay_alive = stay_alive.clone(); 125 125 s.spawn(move || { 126 126 - let rep = rocks.run_repair(time::Duration::from_millis(1), stay_alive); 126 126 + let rep = rocks.run_repair(time::Duration::from_millis(0), stay_alive); 127 127 eprintln!("repair finished: {rep:?}"); 128 128 rep 129 129 });

+5 -1

constellation/src/storage/rocks_store.rs

reviewed

··· 358 358 359 359 let mut maybe_done = false; 360 360 361 361 + let mut write_fast = rocksdb::WriteOptions::default(); 362 362 + write_fast.set_sync(false); 363 363 + write_fast.disable_wal(true); 364 364 + 361 365 while !stay_alive.is_cancelled() && !maybe_done { 362 366 // let mut batch = WriteBatch::default(); 363 367 ··· 386 390 let target_id: TargetId = _vr(iter.value().unwrap())?; 387 391 388 392 self.db 389 389 - .put_cf(&cf, target_id.id().to_be_bytes(), _rv(&target))?; 393 393 + .put_cf_opt(&cf, target_id.id().to_be_bytes(), _rv(&target), &write_fast)?; 390 394 any_written = true; 391 395 iter.next(); 392 396 }