ed/raddebugger
1
0
Fork 0
mirror of https://github.com/Ed94/raddebugger.git synced 2026-08-14 17:28:07 +00:00
Code Issues Packages Projects Releases Wiki Activity

make os file read an atomic operation

Browse Source
This commit is contained in:
Nikita Smith
2026-02-24 18:05:38 -08:00
parent eb8fd11b20
commit 03445022d5
1 changed files with 14 additions and 24 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/os/core/win32/os_core_win32.c
+13 -23
View File
@@ -368,35 +368,25 @@ internal U64
os_file_read(OS_Handle file, Rng1U64 rng, void *out_data) os_file_read(OS_Handle file, Rng1U64 rng, void *out_data)
{ {
if(os_handle_match(file, os_handle_zero())) { return 0; } if(os_handle_match(file, os_handle_zero())) { return 0; }
HANDLE handle = (HANDLE)file.u64[0];
// rjf: clamp range by file size HANDLE handle = (HANDLE)file.u64[0];
U64 size = 0; U8 *ptr = out_data;
GetFileSizeEx(handle, (LARGE_INTEGER *)&size); U64 off = rng.min;
Rng1U64 rng_clamped = r1u64(ClampTop(rng.min, size), ClampTop(rng.max, size)); while(off != rng.max)
U64 total_read_size = 0;
// rjf: read loop
{ {
U64 to_read = dim_1u64(rng_clamped); U64 amt64 = rng.max - off;
for(U64 off = rng.min; total_read_size < to_read;) U32 amt32 = (U32)Min(MB(32), amt64);
DWORD read_size = 0;
OVERLAPPED overlapped = { .Offset = (U32)off, .OffsetHigh = (U32)(off >> 32) };
if( ! ReadFile(handle, ptr, amt32, &read_size, &overlapped))
{ {
U64 amt64 = to_read - total_read_size; break;
U32 amt32 = u32_from_u64_saturate(amt64);
DWORD read_size = 0;
OVERLAPPED overlapped = {0};
overlapped.Offset = (off&0x00000000ffffffffull);
overlapped.OffsetHigh = (off&0xffffffff00000000ull) >> 32;
ReadFile(handle, (U8 *)out_data + total_read_size, amt32, &read_size, &overlapped);
off += read_size;
total_read_size += read_size;
if(read_size != amt32)
{
break;
}
} }
ptr += read_size;
off += read_size;
} }
U64 total_read_size = off - rng.min;
return total_read_size; return total_read_size;
} }