Fix clippy linting (#115)
* Fix clippy (This was fixed via `cargo clippy --fix`) * Fmt
This commit is contained in:
@@ -156,7 +156,7 @@ impl<'a> Compressor<'a> {
|
|||||||
) -> Compressor<'a> {
|
) -> Compressor<'a> {
|
||||||
let levels = level_info
|
let levels = level_info
|
||||||
.iter()
|
.iter()
|
||||||
.map(|l| Level::restore((*l).max_length, (*l).current_chain_length, (*l).head))
|
.map(|l| Level::restore(l.max_length, l.current_chain_length, l.head))
|
||||||
.collect();
|
.collect();
|
||||||
|
|
||||||
let mut compressor = Compressor {
|
let mut compressor = Compressor {
|
||||||
|
|||||||
@@ -237,15 +237,9 @@ fn load_map_from_db(
|
|||||||
let mut missing_sgs: Vec<_> = state_group_map
|
let mut missing_sgs: Vec<_> = state_group_map
|
||||||
.iter()
|
.iter()
|
||||||
.filter_map(|(_sg, entry)| {
|
.filter_map(|(_sg, entry)| {
|
||||||
if let Some(prev_sg) = entry.prev_state_group {
|
entry
|
||||||
if state_group_map.contains_key(&prev_sg) {
|
.prev_state_group
|
||||||
None
|
.filter(|&prev_sg| !state_group_map.contains_key(&prev_sg))
|
||||||
} else {
|
|
||||||
Some(prev_sg)
|
|
||||||
}
|
|
||||||
} else {
|
|
||||||
None
|
|
||||||
}
|
|
||||||
})
|
})
|
||||||
.collect();
|
.collect();
|
||||||
|
|
||||||
|
|||||||
@@ -563,7 +563,7 @@ pub fn continue_run(
|
|||||||
let (state_group_map, max_group_found) =
|
let (state_group_map, max_group_found) =
|
||||||
database::reload_data_from_db(db_url, room_id, start, Some(chunk_size), level_info)?;
|
database::reload_data_from_db(db_url, room_id, start, Some(chunk_size), level_info)?;
|
||||||
|
|
||||||
let original_num_rows = state_group_map.iter().map(|(_, v)| v.state_map.len()).sum();
|
let original_num_rows = state_group_map.values().map(|v| v.state_map.len()).sum();
|
||||||
|
|
||||||
// Now we actually call the compression algorithm.
|
// Now we actually call the compression algorithm.
|
||||||
let compressor = Compressor::compress_from_save(&state_group_map, level_info);
|
let compressor = Compressor::compress_from_save(&state_group_map, level_info);
|
||||||
|
|||||||
Reference in New Issue
Block a user