omedusyo/minisql
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

clippy

Browse source
This commit is contained in:
Yuriy Dupyn 2024-02-05 23:44:33 +01:00
parent 588db169f8
commit ae03d52c0c
3 changed files with 6 additions and 6 deletions
Download patch file Download diff file Expand all files Collapse all files

2
storage_engine/src/segments/entry_header.rs
View file

@ -57,7 +57,7 @@ impl EntryHeaderWithDataSize {
} }
pub fn decode(bytes: &mut [u8], number_of_columns: usize) -> Result<Self> { pub fn decode(bytes: &mut [u8], number_of_columns: usize) -> Result<Self> {
let (is_deleted, _) = decode::<bool>(&bytes) let (is_deleted, _) = decode::<bool>(bytes)
.map_err(|e| Error::DecodeError(DecodeErrorKind::EntryIsDeleted, e))?; .map_err(|e| Error::DecodeError(DecodeErrorKind::EntryIsDeleted, e))?;
let data_sizes = let data_sizes =

2
storage_engine/src/segments/store_header.rs
View file

@ -108,7 +108,7 @@ impl StoreHeader {
.map_err(|e| Error::DecodeError(DecodeErrorKind::StoreHeaderIndexedColumns, e))?; .map_err(|e| Error::DecodeError(DecodeErrorKind::StoreHeaderIndexedColumns, e))?;
Ok(StoreHeader { Ok(StoreHeader {
table_folder: header.table_folder.into(), table_folder: header.table_folder,
number_of_columns: header.number_of_columns, number_of_columns: header.number_of_columns,
deleted_count: header.deleted_count, deleted_count: header.deleted_count,
total_count: header.total_count, total_count: header.total_count,

8
storage_engine/src/store.rs
View file

@ -71,7 +71,7 @@ impl<T> Store<T> {
pub fn path_to_index_file(header: &StoreHeader, column: Column) -> PathBuf { pub fn path_to_index_file(header: &StoreHeader, column: Column) -> PathBuf {
let path_to_table = Path::new(&header.table_folder); let path_to_table = Path::new(&header.table_folder);
let path_to_index = let path_to_index =
path_to_table.join(&format!("{}_{}", ROWS_FILE_NAME, column.to_string())); path_to_table.join(&format!("{}_{}", ROWS_FILE_NAME, column));
path_to_index path_to_index
} }
@ -82,7 +82,7 @@ impl<T> Store<T> {
where where
T: Encode + Decode + Ord, T: Encode + Decode + Ord,
{ {
let path_to_index = Self::path_to_index_file(&header, column); let path_to_index = Self::path_to_index_file(header, column);
let index = Index::new(path_to_index).await?; let index = Index::new(path_to_index).await?;
Ok(index) Ok(index)
@ -98,7 +98,7 @@ impl<T> Store<T> {
} }
result[header.primary_column as usize] = result[header.primary_column as usize] =
Some(Self::create_empty_index_at(&header, header.primary_column).await?); Some(Self::create_empty_index_at(header, header.primary_column).await?);
Ok(result) Ok(result)
} }
@ -110,7 +110,7 @@ impl<T> Store<T> {
where where
T: Encode + Decode + Ord, T: Encode + Decode + Ord,
{ {
let path_to_index = Self::path_to_index_file(&header, column); let path_to_index = Self::path_to_index_file(header, column);
let index: Index<T, FilePosition> = Index::connect(path_to_index).await?; let index: Index<T, FilePosition> = Index::connect(path_to_index).await?;
Ok(index) Ok(index)
} }