ShuriZma
/
xenia
mirror of https://github.com/xenia-project/xenia.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

[Kernel] Add APC support to NtWriteFile

This commit is contained in:
emoose 2021-06-28 21:27:29 +01:00 committed by Rick Gibbed
parent a3535be416
commit e23a9b7608
1 changed files with 17 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

31
src/xenia/kernel/xboxkrnl/xboxkrnl_io.cc
View File

@ -357,11 +357,7 @@ dword_result_t NtWriteFile(dword_t file_handle, dword_t event_handle,
pointer_t<X_IO_STATUS_BLOCK> io_status_block, pointer_t<X_IO_STATUS_BLOCK> io_status_block,
lpvoid_t buffer, dword_t buffer_length, lpvoid_t buffer, dword_t buffer_length,
lpqword_t byte_offset_ptr) { lpqword_t byte_offset_ptr) {
// Async not supported yet.
assert_zero(apc_routine);
X_STATUS result = X_STATUS_SUCCESS; X_STATUS result = X_STATUS_SUCCESS;
uint32_t info = 0;
// Grab event to signal. // Grab event to signal.
bool signal_event = false; bool signal_event = false;
@ -386,30 +382,37 @@ dword_result_t NtWriteFile(dword_t file_handle, dword_t event_handle,
buffer.guest_address(), buffer_length, buffer.guest_address(), buffer_length,
byte_offset_ptr ? static_cast<uint64_t>(*byte_offset_ptr) : -1, byte_offset_ptr ? static_cast<uint64_t>(*byte_offset_ptr) : -1,
&bytes_written, apc_context); &bytes_written, apc_context);
if (XSUCCEEDED(result)) {
info = bytes_written; if (io_status_block) {
io_status_block->status = result;
io_status_block->information = static_cast<uint32_t>(bytes_written);
}
// Queue the APC callback. It must be delivered via the APC mechanism even
// though were are completing immediately.
// Low bit probably means do not queue to IO ports.
if ((uint32_t)apc_routine & ~1) {
if (apc_context) {
auto thread = XThread::GetCurrentThread();
thread->EnqueueApc(static_cast<uint32_t>(apc_routine) & ~1u,
apc_context, io_status_block, 0);
}
} }
if (!file->is_synchronous()) { if (!file->is_synchronous()) {
result = X_STATUS_PENDING; result = X_STATUS_PENDING;
} }
if (io_status_block) {
io_status_block->status = X_STATUS_SUCCESS;
io_status_block->information = info;
}
// Mark that we should signal the event now. We do this after // Mark that we should signal the event now. We do this after
// we have written the info out. // we have written the info out.
signal_event = true; signal_event = true;
} else { } else {
// X_STATUS_PENDING if not returning immediately. // X_STATUS_PENDING if not returning immediately.
result = X_STATUS_PENDING; result = X_STATUS_PENDING;
info = 0;
if (io_status_block) { if (io_status_block) {
io_status_block->status = X_STATUS_SUCCESS; io_status_block->status = X_STATUS_PENDING;
io_status_block->information = info; io_status_block->information = 0;
} }
} }
} }