rust/sat-rs
rust/sat-rs
5
1
Fork 0
Code Issues 9 Pull Requests Projects Releases 22 Wiki Activity

finished basic implementation

Browse Source
This commit is contained in:
Robin Müller 2022-06-11 18:25:13 +02:00
parent 50612bf807
commit 7ed3555489
No known key found for this signature in database
GPG Key ID: 71B58F8A3CDFA9AC
1 changed files with 14 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
src/core/pool.rs
View File

@ -83,25 +83,32 @@ impl LocalPool {
} }
let addr = self.reserve(len)?; let addr = self.reserve(len)?;
let raw_pos = self.raw_pos(&addr).unwrap(); let raw_pos = self.raw_pos(&addr).unwrap();
let pool = &mut self.pool.get_mut(addr.pool_idx as usize).unwrap()[raw_pos..len]; let block = &mut self.pool.get_mut(addr.pool_idx as usize).unwrap()[raw_pos..len];
Ok((addr, pool)) Ok((addr, block))
} }
pub fn modify(&mut self, addr: StoreAddr) -> Result<&mut [u8], StoreError> { pub fn modify(&mut self, addr: StoreAddr) -> Result<&mut [u8], StoreError> {
let curr_size = self.addr_check(&addr)?; let curr_size = self.addr_check(&addr)?;
let raw_pos = self.raw_pos(&addr).unwrap(); let raw_pos = self.raw_pos(&addr).unwrap();
let pool = &mut self.pool.get_mut(addr.pool_idx as usize).unwrap()[raw_pos..curr_size]; let block = &mut self.pool.get_mut(addr.pool_idx as usize).unwrap()[raw_pos..curr_size];
Ok(pool) Ok(block)
} }
pub fn get(&self, addr: StoreAddr) -> Result<&[u8], StoreError> { pub fn get(&self, addr: StoreAddr) -> Result<&[u8], StoreError> {
let curr_size = self.addr_check(&addr)?; let curr_size = self.addr_check(&addr)?;
let raw_pos = self.raw_pos(&addr).unwrap(); let raw_pos = self.raw_pos(&addr).unwrap();
let pool = &self.pool.get(addr.pool_idx as usize).unwrap()[raw_pos..curr_size]; let block = &self.pool.get(addr.pool_idx as usize).unwrap()[raw_pos..curr_size];
Ok(pool) Ok(block)
} }
pub fn delete(&mut self, _addr: StoreAddr) -> Result<(), StoreError> { pub fn delete(&mut self, addr: StoreAddr) -> Result<(), StoreError> {
self.addr_check(&addr)?;
let block_size = self.pool_cfg.cfg.get(addr.pool_idx as usize).unwrap().1;
let raw_pos = self.raw_pos(&addr).unwrap();
let block = &mut self.pool.get_mut(addr.pool_idx as usize).unwrap()[raw_pos..block_size];
let size_list = self.sizes_lists.get_mut(addr.pool_idx as usize).unwrap();
size_list[addr.packet_idx as usize] = Self::STORE_FREE;
block.fill(0);
Ok(()) Ok(())
} }