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

IoCompletion: Removed !wait_ticks check

This commit is contained in:
Gliniak 2021-01-25 08:49:48 +01:00
parent 0035720a84
commit 049da82036
2 changed files with 11 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -449,7 +449,8 @@ dword_result_t NtSetIoCompletion(dword_t handle, dword_t key_context,
port->QueueNotification(notification);
return X_STATUS_SUCCESS;
}
DECLARE_XBOXKRNL_EXPORT1(NtSetIoCompletion, kFileSystem, kImplemented);
DECLARE_XBOXKRNL_EXPORT2(NtSetIoCompletion, kFileSystem, kImplemented,
kHighFrequency);
// Dequeues a packet from the completion port.
dword_result_t NtRemoveIoCompletion(
@ -479,12 +480,18 @@ dword_result_t NtRemoveIoCompletion(
io_status_block->information = notification.num_bytes;
}
} else {
status = X_STATUS_TIMEOUT;
// TODO(Gliniak): We're returning X_STATUS_SUCCESS here instead of
// X_STATUS_TIMEOUT due to timing issues between threads when subthread
// execute NtRemoveIoCompletion before mainthread execute NtSetIoCompletion
// Returning X_STATUS_SUCCESS suprisingly doesn't bother titles that uses
// this function, but X_STATUS_TIMEOUT causes them to lock
status = X_STATUS_SUCCESS;
}
return status;
}
DECLARE_XBOXKRNL_EXPORT1(NtRemoveIoCompletion, kFileSystem, kImplemented);
DECLARE_XBOXKRNL_EXPORT2(NtRemoveIoCompletion, kFileSystem, kImplemented,
kHighFrequency);
dword_result_t NtQueryFullAttributesFile(
pointer_t<X_OBJECT_ATTRIBUTES> obj_attribs,

2
src/xenia/kernel/xiocompletion.cc
View File

@ -30,7 +30,7 @@ bool XIOCompletion::WaitForNotification(uint64_t wait_ticks,
IONotification* notify) {
auto ms = std::chrono::milliseconds(TimeoutTicksToMs(wait_ticks));
auto res = threading::Wait(notification_semaphore_.get(), false, ms);
if (res == threading::WaitResult::kSuccess || !wait_ticks) {
if (res == threading::WaitResult::kSuccess) {
std::unique_lock<std::mutex> lock(notification_lock_);
assert_false(notifications_.empty());