blockworks-foundation
/
solana-with-rpc-optimizations
mirror of https://github.com/blockworks-foundation/solana-with-rpc-optimizations.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Refactors TieredStorageFile read/write methods (#34147)

This commit is contained in:
Brooks 2023-11-17 14:17:49 -05:00 committed by GitHub
parent 9bb82a3901
commit e23bfb5167
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 5 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
accounts-db/src/tiered_storage/file.rs
View File

@ -36,18 +36,14 @@ impl TieredStorageFile {
pub fn write_type<T>(&self, value: &T) -> IoResult<usize> { pub fn write_type<T>(&self, value: &T) -> IoResult<usize> {
let ptr = value as *const _ as *const u8; let ptr = value as *const _ as *const u8;
let slice = unsafe { std::slice::from_raw_parts(ptr, mem::size_of::<T>()) }; let bytes = unsafe { std::slice::from_raw_parts(ptr, mem::size_of::<T>()) };
(&self.0).write_all(slice)?; self.write_bytes(bytes)
Ok(std::mem::size_of::<T>())
} }
pub fn read_type<T>(&self, value: &mut T) -> IoResult<()> { pub fn read_type<T>(&self, value: &mut T) -> IoResult<()> {
let ptr = value as *mut _ as *mut u8; let ptr = value as *mut _ as *mut u8;
let slice = unsafe { std::slice::from_raw_parts_mut(ptr, mem::size_of::<T>()) }; let bytes = unsafe { std::slice::from_raw_parts_mut(ptr, mem::size_of::<T>()) };
(&self.0).read_exact(slice)?; self.read_bytes(bytes)
Ok(())
} }
pub fn seek(&self, offset: u64) -> IoResult<u64> { pub fn seek(&self, offset: u64) -> IoResult<u64> {
@ -65,8 +61,6 @@ impl TieredStorageFile {
} }
pub fn read_bytes(&self, buffer: &mut [u8]) -> IoResult<()> { pub fn read_bytes(&self, buffer: &mut [u8]) -> IoResult<()> {
(&self.0).read_exact(buffer)?; (&self.0).read_exact(buffer)
Ok(())
} }
} }