mika/Atmosphere
1
0
Fork 0
mirror of https://github.com/Atmosphere-NX/Atmosphere.git synced 2025-07-05 09:02:15 +02:00
Code Issues Packages Projects Releases Wiki Activity

same for multithreadedwaitablemanager

Browse Source
This commit is contained in:
Juan Antonio Hernández Cánovas 2018-08-21 22:13:04 +02:00
parent 6dbe3cf4f1
commit 46cd7e8847
1 changed files with 20 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
stratosphere/libstratosphere/source/multithreadedwaitablemanager.cpp
View File

@ -42,6 +42,12 @@ IWaitable *MultiThreadedWaitableManager::get_waitable() {
handles.resize(this->waitables.size()); handles.resize(this->waitables.size());
std::transform(this->waitables.begin(), this->waitables.end(), handles.begin(), [](IWaitable *w) { return w->get_handle(); }); std::transform(this->waitables.begin(), this->waitables.end(), handles.begin(), [](IWaitable *w) { return w->get_handle(); });
if(this->waitables.size() == 0) {
continue;
}
if(this->waitables.size() > 0x40) {
/* TODO: panic. Too many waitables */
}
rc = svcWaitSynchronization(&handle_index, handles.data(), this->waitables.size(), this->timeout); rc = svcWaitSynchronization(&handle_index, handles.data(), this->waitables.size(), this->timeout);
IWaitable *w = this->waitables[handle_index]; IWaitable *w = this->waitables[handle_index];
if (R_SUCCEEDED(rc)) { if (R_SUCCEEDED(rc)) {
@ -50,7 +56,20 @@ IWaitable *MultiThreadedWaitableManager::get_waitable() {
} else if (rc == 0xEA01) { } else if (rc == 0xEA01) {
/* Timeout. */ /* Timeout. */
std::for_each(waitables.begin(), waitables.end(), std::mem_fn(&IWaitable::update_priority)); std::for_each(waitables.begin(), waitables.end(), std::mem_fn(&IWaitable::update_priority));
} else if (rc != 0xF601 && rc != 0xE401) { } else if (rc == 0xE401) {
/* Invalid handle */
/* handle_index does not get updated when this happens
so we don't know which waitable is the problem.
However switchbrew says that svcWaitSynchronization
does not accept 0xFFFF8001 or 0xFFFF8000 as handles
so we could at least remove them if any exists */
for(auto it = waitables.begin(); it != waitables.end(); it++) {
if((*it)->get_handle() == 0xFFFF8000 || (*it)->get_handle() == 0xFFFF8001) {
waitables.erase(it);
}
}
} else if (rc != 0xF601) {
/* TODO: Panic. When can this happen? */ /* TODO: Panic. When can this happen? */
} else { } else {
std::for_each(waitables.begin(), waitables.begin() + handle_index, std::mem_fn(&IWaitable::update_priority)); std::for_each(waitables.begin(), waitables.begin() + handle_index, std::mem_fn(&IWaitable::update_priority));