diff --git a/storage_engine/src/cursor.rs b/storage_engine/src/cursor.rs index 84077fa..0811bfe 100644 --- a/storage_engine/src/cursor.rs +++ b/storage_engine/src/cursor.rs @@ -356,10 +356,8 @@ pub trait CursorWithAccessToIndex: CursorWithStoreHeader { where T: Encode + Decode + Ord + Send + Sync { if self.header().is_column_indexed(column) { - println!("INDEXED LOOKUP"); self.index_lookup(column, value).await } else { - println!("BRUTE-FORCE LOOKUP"); self.find_all_eq_bruteforce(column, value).await } } @@ -577,7 +575,6 @@ impl <'cursor, T> WriteCursor<'cursor, T> pub async fn mark_deleted_at(&mut self, file_position: FilePosition, enable_garbage_collector: bool) -> Result<()> where T: Encode + Decode + Ord + Send + Sync + Clone + Ord { - println!("MARKING {} as DELETED", file_position); self.seek_to(file_position).await?; let mut entry_header = self.read_entry_header().await?; if entry_header.is_deleted { @@ -637,7 +634,6 @@ impl <'cursor, T> WriteCursor<'cursor, T> { let count = if self.header().is_column_indexed(column) { - println!("DELETION: INDEXED LOOKUP"); let entries = self.index_lookup(column, value).await?; let count = entries.len(); for entry in entries { @@ -645,7 +641,6 @@ impl <'cursor, T> WriteCursor<'cursor, T> } count } else { - println!("DELETION: BRUTE-FORCE LOOKUP"); let count = self.find_all_eq_bruteforce_and_delete(column, value).await?; count }; @@ -682,8 +677,9 @@ impl <'cursor, T> WriteCursor<'cursor, T> where T: Send + Sync + Decode + Encode + Clone + Ord { if self.header.deleted_count > GARBAGE_COLLECTION_TRIGGER { - println!("=======START GARBAGE COLLETOR===="); + println!("=======START GARBAGE COLLECTOR===="); self.initiate_garbage_collection().await?; + println!("=======GARBAGE COLLECTOR FINISHED===="); } Ok(()) }