improve scoping of unsafe blocks

This commit is contained in:
2025-12-03 11:50:15 +00:00
parent 2138464fec
commit bd51e3e2e2
3 changed files with 55 additions and 69 deletions
+10 -14
View File
@@ -21,25 +21,21 @@ impl Deref for Handle {
impl Drop for Handle { impl Drop for Handle {
fn drop(&mut self) { fn drop(&mut self) {
unsafe { if let Err(why) = unsafe { CloseHandle(**self) } {
if let Err(why) = CloseHandle(**self) { log::error!("failed to close handle: {why}");
log::error!("failed to close handle: {why}"); };
};
}
} }
} }
impl Handle { impl Handle {
pub fn from_pid(pid: u32) -> Result<Self, crate::Error> { pub fn from_pid(pid: u32) -> Result<Self, crate::Error> {
let handle = unsafe { let handle = unsafe { OpenProcess(PROCESS_ALL_ACCESS, false, pid) }
OpenProcess(PROCESS_ALL_ACCESS, false, pid) .or_else(|_| unsafe { OpenProcess(PROCESS_VM_READ | PROCESS_VM_WRITE, false, pid) })
.or_else(|_| OpenProcess(PROCESS_VM_READ | PROCESS_VM_WRITE, false, pid)) .map_err(|why| {
.map_err(|why| { crate::Error::ObtainHandleError(format!(
crate::Error::ObtainHandleError(format!( "failed to open process with needed access: {why}",
"failed to open process with needed access: {why}", ))
)) })?;
})?
};
if handle == INVALID_HANDLE_VALUE { if handle == INVALID_HANDLE_VALUE {
return Err(crate::Error::ObtainHandleError( return Err(crate::Error::ObtainHandleError(
"failed to get a valid handle".to_string(), "failed to get a valid handle".to_string(),
+16 -16
View File
@@ -5,35 +5,35 @@ use std::{ffi::c_void, ptr};
use windows::Win32::System::Diagnostics::Debug::{ReadProcessMemory, WriteProcessMemory}; use windows::Win32::System::Diagnostics::Debug::{ReadProcessMemory, WriteProcessMemory};
pub fn read<T>(handle: &Handle, address: usize, value: &mut T) -> Result<(), crate::Error> { pub fn read<T>(handle: &Handle, address: usize, value: &mut T) -> Result<(), crate::Error> {
unsafe { match unsafe {
match ReadProcessMemory( ReadProcessMemory(
handle.0, handle.0,
address as *const c_void, address as *const c_void,
(ptr::from_mut::<T>(value)).cast::<c_void>(), (ptr::from_mut::<T>(value)).cast::<c_void>(),
size_of::<T>(), size_of::<T>(),
None, None,
) { )
Ok(()) => Ok(()), } {
Err(why) => Err(crate::Error::AccessMemoryError(format!( Ok(()) => Ok(()),
"failed to read memory: {why}" Err(why) => Err(crate::Error::AccessMemoryError(format!(
))), "failed to read memory: {why}"
} ))),
} }
} }
pub fn write<T>(handle: &Handle, address: usize, value: &mut T) -> Result<(), crate::Error> { pub fn write<T>(handle: &Handle, address: usize, value: &mut T) -> Result<(), crate::Error> {
unsafe { match unsafe {
match WriteProcessMemory( WriteProcessMemory(
handle.0, handle.0,
address as *const c_void, address as *const c_void,
(ptr::from_mut::<T>(value)).cast::<c_void>(), (ptr::from_mut::<T>(value)).cast::<c_void>(),
size_of::<T>(), size_of::<T>(),
None, None,
) { )
Ok(()) => Ok(()), } {
Err(why) => Err(crate::Error::AccessMemoryError(format!( Ok(()) => Ok(()),
"failed to write memory: {why}" Err(why) => Err(crate::Error::AccessMemoryError(format!(
))), "failed to write memory: {why}"
} ))),
} }
} }
+29 -39
View File
@@ -13,30 +13,26 @@ pub struct ProcessSnapshot {
impl ProcessSnapshot { impl ProcessSnapshot {
pub fn get_processes() -> Result<Vec<Self>, crate::Error> { pub fn get_processes() -> Result<Vec<Self>, crate::Error> {
let snapshot = unsafe { let snapshot = match unsafe { CreateToolhelp32Snapshot(TH32CS_SNAPPROCESS, 0) } {
match CreateToolhelp32Snapshot(TH32CS_SNAPPROCESS, 0) { Ok(snapshot) => snapshot,
Ok(snapshot) => snapshot, Err(why) => {
Err(why) => { return Err(crate::Error::CreateSnapshotError(format!(
return Err(crate::Error::CreateSnapshotError(format!( "failed to create process snapshot: {why}"
"failed to create process snapshot: {why}" )))
)))
}
} }
}; };
let mut process_entry_32_w = PROCESSENTRY32W { let mut process_entry_32_w = PROCESSENTRY32W {
dwSize: u32::try_from(size_of::<PROCESSENTRY32W>())?, dwSize: u32::try_from(size_of::<PROCESSENTRY32W>())?,
..Default::default() ..Default::default()
}; };
unsafe { match unsafe { Process32FirstW(snapshot, &mut process_entry_32_w) } {
match Process32FirstW(snapshot, &mut process_entry_32_w) { Ok(()) => {}
Ok(()) => {} Err(why) => {
Err(why) => { return Err(crate::Error::CreateSnapshotError(format!(
return Err(crate::Error::CreateSnapshotError(format!( "failed to get first process from snapshot: {why}"
"failed to get first process from snapshot: {why}" )))
))) }
} };
};
}
let mut processes = Vec::new(); let mut processes = Vec::new();
loop { loop {
let name = String::from_utf16_lossy(&process_entry_32_w.szExeFile) let name = String::from_utf16_lossy(&process_entry_32_w.szExeFile)
@@ -47,11 +43,9 @@ impl ProcessSnapshot {
name, name,
}; };
processes.push(process); processes.push(process);
unsafe { if unsafe { Process32NextW(snapshot, &mut process_entry_32_w) }.is_err() {
if Process32NextW(snapshot, &mut process_entry_32_w).is_err() { break;
break; };
};
}
} }
Ok(processes) Ok(processes)
} }
@@ -67,28 +61,26 @@ pub struct ModuleSnapshot {
impl ModuleSnapshot { impl ModuleSnapshot {
pub fn get_modules(pid: u32) -> Result<Vec<Self>, crate::Error> { pub fn get_modules(pid: u32) -> Result<Vec<Self>, crate::Error> {
let snapshot = unsafe { let snapshot =
match CreateToolhelp32Snapshot(TH32CS_SNAPMODULE | TH32CS_SNAPMODULE32, pid) { match unsafe { CreateToolhelp32Snapshot(TH32CS_SNAPMODULE | TH32CS_SNAPMODULE32, pid) }
{
Ok(snapshot) => snapshot, Ok(snapshot) => snapshot,
Err(why) => { Err(why) => {
return Err(crate::Error::CreateSnapshotError(format!( return Err(crate::Error::CreateSnapshotError(format!(
"failed to create module snapshot: {why}" "failed to create module snapshot: {why}"
))) )))
} }
} };
};
let mut module_entry_32_w = MODULEENTRY32W { let mut module_entry_32_w = MODULEENTRY32W {
dwSize: u32::try_from(size_of::<MODULEENTRY32W>())?, dwSize: u32::try_from(size_of::<MODULEENTRY32W>())?,
..Default::default() ..Default::default()
}; };
unsafe { match unsafe { Module32FirstW(snapshot, &mut module_entry_32_w) } {
match Module32FirstW(snapshot, &mut module_entry_32_w) { Ok(()) => {}
Ok(()) => {} Err(why) => {
Err(why) => { return Err(crate::Error::CreateSnapshotError(format!(
return Err(crate::Error::CreateSnapshotError(format!( "failed to get first module from snapshot: {why}"
"failed to get first module from snapshot: {why}" )))
)))
}
} }
} }
let mut modules = Vec::new(); let mut modules = Vec::new();
@@ -106,10 +98,8 @@ impl ModuleSnapshot {
base_size: module_entry_32_w.modBaseSize as usize, base_size: module_entry_32_w.modBaseSize as usize,
}; };
modules.push(module); modules.push(module);
unsafe { if unsafe { Module32NextW(snapshot, &mut module_entry_32_w).is_err() } {
if Module32NextW(snapshot, &mut module_entry_32_w).is_err() { break;
break;
}
} }
} }
Ok(modules) Ok(modules)