chore: replace read_to_end()

Signed-off-by: xiaguan <[email protected]>
risinglightdb · Oct 17, 2023 · cedf9a2 · cedf9a2
1 parent 58c42c5
commit cedf9a2
Showing 1 changed file with 2 additions and 10 deletions.
diff --git a/src/storage/secondary/rowset/disk_rowset.rs b/src/storage/secondary/rowset/disk_rowset.rs
@@ -6,8 +6,7 @@ use std::sync::{Arc, Mutex};
 use bytes::Bytes;
 use itertools::Itertools;
 use moka::future::Cache;
-use tokio::fs::OpenOptions;
-use tokio::io::AsyncReadExt;
+use tokio::fs::{read, OpenOptions};
 
 use super::super::{Block, BlockCacheKey, Column, ColumnIndex, ColumnSeekPosition, IOBackend};
 use super::{path_of_data_column, path_of_index_column, RowSetIterator};
@@ -42,15 +41,8 @@ impl DiskRowset {
 
             let index_content = match &io_backend {
                 IOBackend::NormalRead | IOBackend::PositionedRead => {
-                    let mut index = OpenOptions::default()
-                        .read(true)
-                        .write(false)
-                        .open(path_of_index_column)
-                        .await?;
-
                     // TODO(chi): add an index cache later
-                    let mut index_content = vec![];
-                    index.read_to_end(&mut index_content).await?;
+                    let index_content = read(&path_of_index_column).await?;
                     Bytes::from(index_content)
                 }
                 IOBackend::InMemory(map) => {