AstralTransRocketries/ClassiCube
1
0
Fork 0
mirror of https://github.com/ClassiCube/ClassiCube.git synced 2025-09-14 01:55:19 -04:00
Code Issues Packages Projects Releases Wiki Activity

Fix rare case on non-Windows where Waitable_Wait would miss a signal

Browse Source 
pthread_cond_signal is documented to have no effect if no threads are blocked/waiting. As such, if another thread called pthread_cond_wait afterwards, it would not realise it was supposed to be signalled already, and then incorrectly proceed to block while waiting for another signal. This issue manifested in the http worker thread, which would rarely cause the launcher to get stuck 'checking for updates' until some other http request got queued, which would wake up the stuck worker thread. Fix this by adding a field that keeps track of whether the waitable is currently in the 'signalled' state.
This commit is contained in:
UnknownShadow200 2020-05-30 18:52:50 +10:00
parent 6665d736e9
commit e6a88393bf
1 changed files with 20 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

25
src/Platform.c
View File

@ -709,6 +709,7 @@ void Mutex_Unlock(void* handle) {
struct WaitData {
pthread_cond_t cond;
pthread_mutex_t mutex;
int signalled;
};
void* Waitable_Create(void) {
@ -719,6 +720,8 @@ void* Waitable_Create(void) {
if (res) Logger_Abort2(res, "Creating waitable");
res = pthread_mutex_init(&ptr->mutex, NULL);
if (res) Logger_Abort2(res, "Creating waitable mutex");
ptr->signalled = false;
return ptr;
}
@ -735,7 +738,13 @@ void Waitable_Free(void* handle) {
void Waitable_Signal(void* handle) {
struct WaitData* ptr = (struct WaitData*)handle;
int res = pthread_cond_signal(&ptr->cond);
int res;
Mutex_Lock(&ptr->mutex);
ptr->signalled = true;
Mutex_Unlock(&ptr->mutex);
res = pthread_cond_signal(&ptr->cond);
if (res) Logger_Abort2(res, "Signalling event");
}
@ -744,8 +753,11 @@ void Waitable_Wait(void* handle) {
int res;
Mutex_Lock(&ptr->mutex);
res = pthread_cond_wait(&ptr->cond, &ptr->mutex);
if (res) Logger_Abort2(res, "Waitable wait");
if (!ptr->signalled) {
res = pthread_cond_wait(&ptr->cond, &ptr->mutex);
if (res) Logger_Abort2(res, "Waitable wait");
}
ptr->signalled = false;
Mutex_Unlock(&ptr->mutex);
}
@ -763,8 +775,11 @@ void Waitable_WaitFor(void* handle, cc_uint32 milliseconds) {
ts.tv_nsec %= NS_PER_SEC;
Mutex_Lock(&ptr->mutex);
res = pthread_cond_timedwait(&ptr->cond, &ptr->mutex, &ts);
if (res && res != ETIMEDOUT) Logger_Abort2(res, "Waitable wait for");
if (!ptr->signalled) {
res = pthread_cond_timedwait(&ptr->cond, &ptr->mutex, &ts);
if (res && res != ETIMEDOUT) Logger_Abort2(res, "Waitable wait for");
}
ptr->signalled = false;
Mutex_Unlock(&ptr->mutex);
}
#endif