test/acl
1
0
Fork 0
mirror of https://gitee.com/acl-dev/acl.git synced 2024-11-30 02:47:56 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

fixed bug in fiber_sem.c

Browse Source
This commit is contained in:
zhengshuxin 2019-07-17 09:32:20 +08:00
parent b3ab894e6d
commit 3b1053652f
1 changed files with 12 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
lib_fiber/c/src/fiber_sem.c
View File

@ -52,11 +52,14 @@ int acl_fiber_sem_wait(ACL_FIBER_SEM *sem)
if (sem->tid == 0) {
sem->tid = __pthread_self();
} else if (sem->tid != __pthread_self()) {
}
#if 0
else if (sem->tid != __pthread_self()) {
msg_error("%s(%d): current tid=%lu, sem tid=%lu",
__FUNCTION__, __LINE__, __pthread_self(), sem->tid);
return -1;
}
#endif
if (sem->num > 0) {
sem->num--;
@ -84,11 +87,14 @@ int acl_fiber_sem_trywait(ACL_FIBER_SEM *sem)
{
if (sem->tid == 0) {
sem->tid = __pthread_self();
} else if (sem->tid != __pthread_self()) {
}
#if 0
else if (sem->tid != __pthread_self()) {
msg_error("%s(%d): current tid=%lu, sem tid=%lu",
__FUNCTION__, __LINE__, __pthread_self(), sem->tid);
return -1;
}
#endif
if (sem->num > 0) {
sem->num--;
@ -110,11 +116,14 @@ int acl_fiber_sem_post(ACL_FIBER_SEM *sem)
if (sem->tid == 0) {
sem->tid = __pthread_self();
} else if (sem->tid != __pthread_self()) {
}
#if 0
else if (sem->tid != __pthread_self()) {
msg_error("%s(%d): current tid=%lu, sem tid=%lu",
__FUNCTION__, __LINE__, __pthread_self(), sem->tid);
return -1;
}
#endif
if ((ready = FIRST_FIBER(&sem->waiting)) == NULL) {
sem->num++;