Skip to content

Commit

Permalink
used namedtuple
Browse files Browse the repository at this point in the history
(cherry picked from commit d7d9d88)
  • Loading branch information
yocalebo authored and bugclerk committed Jun 28, 2024
1 parent 61d02bd commit 61e21f4
Show file tree
Hide file tree
Showing 2 changed files with 56 additions and 25 deletions.
14 changes: 6 additions & 8 deletions src/middlewared/middlewared/plugins/device_/device_info.py
Original file line number Diff line number Diff line change
Expand Up @@ -101,9 +101,7 @@ def get_disk_partitions(self, dev):
for i in filter(lambda x: all(x.get(k) for k in keys), dev.children):
part_num = int(i['ID_PART_ENTRY_NUMBER'])
part_name = self.middleware.call_sync('disk.get_partition_for_disk', parent, part_num)
lbs, start_sector, end_sector, sect_size = get_partition_size_info(
parent, int(i['ID_PART_ENTRY_OFFSET']), int(i['ID_PART_ENTRY_SIZE'])
)
pinfo = get_partition_size_info(parent, int(i['ID_PART_ENTRY_OFFSET']), int(i['ID_PART_ENTRY_SIZE']))
part = {
'name': part_name,
'id': part_name,
Expand All @@ -113,13 +111,13 @@ def get_disk_partitions(self, dev):
'partition_type': i['ID_PART_ENTRY_TYPE'],
'partition_number': part_num,
'partition_uuid': i['ID_PART_ENTRY_UUID'],
'start_sector': start_sector,
'end_sector': end_sector,
'start_sector': pinfo.start_sector,
'end_sector': pinfo.end_sector,
'start': pinfo.start_byte,
'end': pinfo.end_byte,
'size': pinfo.total_bytes,
'encrypted_provider': None,
}
part['start'] = start_sector * lbs # bytes
part['end'] = end_sector * lbs # bytes
part['size'] = sect_size * lbs # bytes

for attr in filter(lambda x: x.startswith('holders/md'), i.attributes.available_attributes):
# looks like `holders/md123`
Expand Down
67 changes: 50 additions & 17 deletions src/middlewared/middlewared/plugins/disk_/disk_info.py
Original file line number Diff line number Diff line change
@@ -1,3 +1,4 @@
import collections
import contextlib
import glob
import os
Expand All @@ -8,29 +9,63 @@
from middlewared.service import CallError, private, Service


# The basic unit of a block I/O is a sector. A sector is
# 512 (2 ** 9) bytes. In sysfs, the files (sector_t type)
# `<disk>/<part>/start` and `<disk>/<part>/size` are
# shown as a multiple of 512 bytes. Most user-space
# tools (fdisk, parted, sfdisk, etc) treat the partition
# offsets in sectors.
BYTES_512 = 512
PART_INFO_FIELDS = (
# queue/logical_block_size (reported as a multiple of BYTES_512)
'lbs',
# starting offset of partition in sectors
'start_sector',
# ending offset of partition in sectors
'end_sector',
# total partition size in sectors
'total_sectors',
# starting offset of partition in bytes
'start_byte',
# ending offset of partition in bytes
'end_byte',
# total size of partition in bytes
'total_bytes',
)
PART_INFO = collections.namedtuple('part_info', PART_INFO_FIELDS, defaults=(0,) * len(PART_INFO_FIELDS))


def get_partition_size_info(disk_name, s_offset, s_size):
"""Kernel sysfs reports most disk files related to "size" in 512 bytes.
To properly calculate the starting SECTOR of partitions, you must
look at logical_block_size (again, reported in 512 bytes) and
do some calculations. It is _very_ important to do this properly
since almost all userspace tools that format disks expect partition
positions to be in sectors."""
lbs = start_sect = end_sect = sect_size = 0
lbs = 0
with contextlib.suppress(FileNotFoundError, ValueError):
with open(f'/sys/block/{disk_name}/queue/logical_block_size') as f:
lbs = int(f.read().strip())

if not lbs:
# this should never happen
return lbs, start_sect, end_sect, sect_size
return PART_INFO()

# important when dealing with 4kn drives
divisor = lbs // 512
start_sect = s_offset // divisor
sect_size = s_size // divisor
end_sect = sect_size + start_sect - 1

return lbs, start_sect, end_sect, sect_size
divisor = lbs // BYTES_512
# sectors
start_sector = s_offset // divisor
total_sectors = s_size // divisor
end_sector = total_sectors + start_sector - 1
# bytes
start_byte = start_sector * lbs
end_byte = end_sector * lbs
total_bytes = total_sectors * lbs

return PART_INFO(*(
lbs, start_sector, end_sector, total_sectors,
start_byte, end_byte, total_bytes,
))


class DiskService(Service):
Expand All @@ -45,7 +80,7 @@ def get_dev_size(self, device):
if dev.get('DEVTYPE') not in ('disk', 'partition'):
return

return dev.attributes.asint('size') * 512
return dev.attributes.asint('size') * BYTES_512

@private
def list_partitions(self, disk):
Expand All @@ -61,20 +96,18 @@ def list_partitions(self, disk):
req_keys = ('ID_PART_ENTRY_' + i for i in ('TYPE', 'UUID', 'NUMBER', 'SIZE'))
for p in filter(lambda p: all(p.get(k) for k in req_keys), bd.children):
part_name = self.get_partition_for_disk(disk, p['ID_PART_ENTRY_NUMBER'])
lbs, start_sector, end_sector, sect_size = get_partition_size_info(
disk, int(p['ID_PART_ENTRY_OFFSET']), int(p['ID_PART_ENTRY_SIZE'])
)
pinfo = get_partition_size_info(disk, int(p['ID_PART_ENTRY_OFFSET']), int(p['ID_PART_ENTRY_SIZE']))
part = {
'name': part_name,
'partition_type': p['ID_PART_ENTRY_TYPE'],
'partition_number': int(p['ID_PART_ENTRY_NUMBER']),
'partition_uuid': p['ID_PART_ENTRY_UUID'],
'disk': disk,
'start_sector': start_sector,
'start': start_sector * lbs, # bytes
'end_sector': end_sector,
'end': end_sector * lbs, # bytes
'size': sect_size * lbs, # bytes
'start_sector': pinfo.start_sector,
'start': pinfo.start_byte,
'end_sector': pinfo.end_sector,
'end': pinfo.end_byte,
'size': pinfo.total_bytes,
'id': part_name,
'path': os.path.join('/dev', part_name),
'encrypted_provider': None,
Expand Down

0 comments on commit 61e21f4

Please sign in to comment.