use crate::block_io::BlockDevice;
use crate::checksum::Checksummer;
use crate::error::{Error, Result};
use crate::superblock::Superblock;
#[derive(Debug, Clone, Copy)]
pub struct BlockGroupDescriptor {
pub block_bitmap: u64,
pub inode_bitmap: u64,
pub inode_table: u64,
pub free_blocks_count: u32,
pub free_inodes_count: u32,
pub used_dirs_count: u32,
pub flags: u16,
pub itable_unused: u32,
pub block_bitmap_csum: u32,
pub inode_bitmap_csum: u32,
pub checksum: u16,
}
pub(crate) const OFF_FREE_BLOCKS_LO: usize = 0x0C;
pub(crate) const OFF_FREE_INODES_LO: usize = 0x0E;
pub(crate) const OFF_USED_DIRS_LO: usize = 0x10;
pub(crate) const OFF_FREE_BLOCKS_HI: usize = 0x2C;
pub(crate) const OFF_FREE_INODES_HI: usize = 0x2E;
pub(crate) const OFF_USED_DIRS_HI: usize = 0x30;
fn u16_at(buf: &[u8], off: usize) -> u16 {
u16::from_le_bytes(buf[off..off + 2].try_into().unwrap())
}
bitflags::bitflags! {
#[derive(Debug, Clone, Copy)]
pub struct BgdFlags: u16 {
const INODE_UNINIT = 0x0001;
const BLOCK_UNINIT = 0x0002;
const ITABLE_ZEROED = 0x0004;
}
}
impl BlockGroupDescriptor {
pub fn parse(buf: &[u8], desc_size: u16) -> Result<Self> {
if buf.len() < desc_size as usize {
return Err(Error::Corrupt("bgd buffer too small"));
}
let block_bitmap_lo = u32::from_le_bytes(buf[0x00..0x04].try_into().unwrap());
let inode_bitmap_lo = u32::from_le_bytes(buf[0x04..0x08].try_into().unwrap());
let inode_table_lo = u32::from_le_bytes(buf[0x08..0x0C].try_into().unwrap());
let free_blocks_lo = u16_at(buf, OFF_FREE_BLOCKS_LO);
let free_inodes_lo = u16_at(buf, OFF_FREE_INODES_LO);
let used_dirs_lo = u16_at(buf, OFF_USED_DIRS_LO);
let flags = u16::from_le_bytes(buf[0x12..0x14].try_into().unwrap());
let block_bitmap_csum_lo = u16::from_le_bytes(buf[0x18..0x1A].try_into().unwrap());
let inode_bitmap_csum_lo = u16::from_le_bytes(buf[0x1A..0x1C].try_into().unwrap());
let itable_unused_lo = u16::from_le_bytes(buf[0x1C..0x1E].try_into().unwrap());
let checksum = u16::from_le_bytes(buf[0x1E..0x20].try_into().unwrap());
let (
block_bitmap_hi,
inode_bitmap_hi,
inode_table_hi,
free_blocks_hi,
free_inodes_hi,
used_dirs_hi,
itable_unused_hi,
block_bitmap_csum_hi,
inode_bitmap_csum_hi,
) = if desc_size >= 64 {
(
u32::from_le_bytes(buf[0x20..0x24].try_into().unwrap()),
u32::from_le_bytes(buf[0x24..0x28].try_into().unwrap()),
u32::from_le_bytes(buf[0x28..0x2C].try_into().unwrap()),
u16_at(buf, OFF_FREE_BLOCKS_HI),
u16_at(buf, OFF_FREE_INODES_HI),
u16_at(buf, OFF_USED_DIRS_HI),
u16::from_le_bytes(buf[0x32..0x34].try_into().unwrap()),
u16::from_le_bytes(buf[0x38..0x3A].try_into().unwrap()),
u16::from_le_bytes(buf[0x3A..0x3C].try_into().unwrap()),
)
} else {
(0, 0, 0, 0, 0, 0, 0, 0, 0)
};
Ok(Self {
block_bitmap: ((block_bitmap_hi as u64) << 32) | block_bitmap_lo as u64,
inode_bitmap: ((inode_bitmap_hi as u64) << 32) | inode_bitmap_lo as u64,
inode_table: ((inode_table_hi as u64) << 32) | inode_table_lo as u64,
free_blocks_count: ((free_blocks_hi as u32) << 16) | free_blocks_lo as u32,
free_inodes_count: ((free_inodes_hi as u32) << 16) | free_inodes_lo as u32,
used_dirs_count: ((used_dirs_hi as u32) << 16) | used_dirs_lo as u32,
flags,
itable_unused: ((itable_unused_hi as u32) << 16) | itable_unused_lo as u32,
block_bitmap_csum: ((block_bitmap_csum_hi as u32) << 16) | block_bitmap_csum_lo as u32,
inode_bitmap_csum: ((inode_bitmap_csum_hi as u32) << 16) | inode_bitmap_csum_lo as u32,
checksum,
})
}
pub fn flags(&self) -> BgdFlags {
BgdFlags::from_bits_truncate(self.flags)
}
}
pub fn read_all<D: BlockDevice + ?Sized>(
dev: &D,
sb: &Superblock,
csum: &Checksummer,
) -> Result<Vec<BlockGroupDescriptor>> {
let block_size = sb.block_size() as u64;
let group_count = sb.block_group_count();
let total_bytes = group_count
.checked_mul(sb.desc_size as u64)
.ok_or(Error::Corrupt(
"superblock: the group descriptor table's size overflows",
))?;
if total_bytes > dev.size_bytes() {
return Err(Error::Corrupt(
"superblock: the group descriptor table reaches past the end of the device",
));
}
let mut table_block: Option<(u64, Vec<u8>)> = None;
let group_count: usize = table_len(group_count)?;
let mut groups = Vec::with_capacity(group_count);
for i in 0..group_count {
let (block, off) = sb.descriptor_location(i as u64);
if table_block.as_ref().map(|(b, _)| *b) != Some(block) {
let end = block
.checked_add(1)
.and_then(|b| b.checked_mul(block_size))
.ok_or(Error::Corrupt(
"superblock: the group descriptor table's extent overflows",
))?;
if end > dev.size_bytes() {
return Err(Error::Corrupt(
"superblock: the group descriptor table reaches past the end of the device",
));
}
let mut bytes = vec![0u8; block_size as usize];
dev.read_at(block * block_size, &mut bytes)?;
table_block = Some((block, bytes));
}
let bytes = &table_block.as_ref().unwrap().1;
let raw = &bytes[off..off + sb.desc_size as usize];
let stored = u16::from_le_bytes([raw[0x1E], raw[0x1F]]);
if crate::checksum::group_desc_csum(sb, csum, i as u32, raw)
.is_some_and(|want| want != stored)
{
return Err(Error::BadChecksum {
what: "block group descriptor",
});
}
let bgd = BlockGroupDescriptor::parse(raw, sb.desc_size)?;
let table_blocks = (u64::from(sb.inodes_per_group) * u64::from(sb.inode_size))
.div_ceil(u64::from(sb.block_size()));
let past_the_end = bgd.block_bitmap >= sb.blocks_count
|| bgd.inode_bitmap >= sb.blocks_count
|| bgd
.inode_table
.checked_add(table_blocks)
.is_none_or(|end| end > sb.blocks_count);
if past_the_end {
return Err(Error::Corrupt(
"a block group descriptor points outside the filesystem",
));
}
check_pointers_within(sb, i as u64, &bgd, table_blocks)?;
groups.push(bgd);
}
Ok(groups)
}
fn check_pointers_within(
sb: &Superblock,
group: u64,
bgd: &BlockGroupDescriptor,
table_blocks: u64,
) -> Result<()> {
let superblock_block = crate::superblock::SUPERBLOCK_OFFSET / u64::from(sb.block_size());
let group0_metadata_end = superblock_block + sb.group_head_metadata_blocks(0);
let table_last = bgd.inode_table + table_blocks.max(1) - 1;
if bgd.block_bitmap < group0_metadata_end
|| bgd.inode_bitmap < group0_metadata_end
|| bgd.inode_table < group0_metadata_end
{
return Err(Error::Corrupt(
"a block group descriptor points into group 0's superblock or descriptor table",
));
}
if sb.feature_incompat & crate::features::Incompat::FLEX_BG.bits() != 0 {
return Ok(());
}
let first = u64::from(sb.first_data_block) + group * u64::from(sb.blocks_per_group);
let last = first
.saturating_add(u64::from(sb.blocks_per_group))
.min(sb.blocks_count)
- 1;
let within = |b: u64| (first..=last).contains(&b);
if !(within(bgd.block_bitmap) && within(bgd.inode_bitmap) && within(bgd.inode_table))
|| table_last > last
{
return Err(Error::Corrupt(
"a block group descriptor points outside its own group, without flex_bg",
));
}
Ok(())
}
fn table_len<T: TryFrom<u64>>(group_count: u64) -> Result<T> {
T::try_from(group_count).map_err(|_| {
Error::Corrupt("superblock: the group count does not fit in this target's address space")
})
}
pub fn locate_inode(
sb: &Superblock,
groups: &[BlockGroupDescriptor],
ino: u32,
) -> Result<(u64, u32)> {
if ino == 0 || ino > sb.inodes_count {
return Err(Error::InvalidInode(ino));
}
if sb.inodes_per_group == 0 || sb.inode_size == 0 {
return Err(Error::Corrupt(
"superblock: zero inodes_per_group or inode_size",
));
}
let group_idx = ((ino - 1) / sb.inodes_per_group) as usize;
let local_idx = ((ino - 1) % sb.inodes_per_group) as u64;
let bgd = groups.get(group_idx).ok_or(Error::InvalidInode(ino))?;
let block_size = sb.block_size() as u64;
let inode_size = sb.inode_size as u64;
if inode_size > block_size {
return Err(Error::Corrupt(
"superblock: inode_size larger than block_size",
));
}
let inodes_per_block = block_size / inode_size;
if inodes_per_block == 0 {
return Err(Error::Corrupt("superblock: inode_size exceeds block_size"));
}
let block = bgd
.inode_table
.checked_add(local_idx / inodes_per_block)
.ok_or(Error::Corrupt("inode table block number overflow"))?;
let off_bytes = (local_idx % inodes_per_block) * inode_size;
let offset_in_block: u32 = off_bytes
.try_into()
.map_err(|_| Error::Corrupt("inode offset exceeds u32"))?;
Ok((block, offset_in_block))
}
#[cfg(test)]
mod tests {
use super::*;
#[test]
fn a_group_count_past_the_target_width_is_refused() {
assert!(table_len::<u32>(u64::from(u32::MAX) + 1).is_err());
assert!(table_len::<u32>(u64::MAX).is_err());
assert_eq!(table_len::<u32>(u64::from(u32::MAX)).unwrap(), u32::MAX);
assert_eq!(table_len::<usize>(3).unwrap(), 3);
}
}