using background writes

db/src/block_stapler.rs

@@ -49,4 +49,8 @@ pub trait BlockStapler {
 
 	/// insert pre-processed block in the storage
 	fn insert_indexed_block(&self, block: &IndexedBlock) -> Result<BlockInsertedChain, Error>;
+
+	/// flushes the underlined store (if applicable)
+	fn flush(&self);
+
 }

db/src/storage.rs

@@ -464,6 +464,7 @@ impl Storage {
 			.map(|header| header.bits.to_f64())
 			.unwrap_or(1.0f64)
 	}
+
 }
 
 impl BlockHeaderProvider for Storage {
@@ -680,6 +681,10 @@ impl BlockStapler for Storage {
 			}
 		}
 	}
+
+	fn flush(&self) {
+		self.database.flush().expect("Failed to flush database. Out of disk space?");
+	}
 }
 
 impl TransactionProvider for Storage {

db/src/test_storage.rs

@@ -170,6 +170,9 @@ impl BlockStapler for TestStorage {
 			_ => None
 		}
 	}
+
+	fn flush(&self) {
+	}
 }
 
 impl TransactionProvider for TestStorage {

db/src/update_context.rs

@@ -28,7 +28,7 @@ impl UpdateContext {
 			self.db_transaction.put(Some(COL_TRANSACTIONS_META), &*hash, &meta.into_bytes());
 		}
 
-		try!(db.write(self.db_transaction));
+		db.write_buffered(self.db_transaction);
 
 		trace!("Applied transaction for block {:?}", &self.target.to_reversed_str());
 		Ok(())

verification/src/chain_verifier.rs

@@ -318,6 +318,7 @@ impl ChainVerifier {
 				for task in transaction_tasks.iter_mut() {
 					scope.execute(move || task.progress(self))
 				}
+				self.store.flush();
 			});