lby/lk
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

[kernel][sem] have sem_post return the number of threads woken up

Browse Source 
Change-Id: I69dca1de1bcf211eb2a5a5a861d47ff84e731d78
This commit is contained in:
Travis Geiselbrecht
2015-04-29 15:48:21 -07:00
parent e3834e4601
commit f536b1fc15
2 changed files with 8 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
include/kernel/semaphore.h
View File

@@ -37,7 +37,7 @@ typedef struct semaphore {
void sem_init(semaphore_t *, unsigned int);
void sem_destroy(semaphore_t *);
status_t sem_post(semaphore_t *, bool resched);
int sem_post(semaphore_t *, bool resched);
status_t sem_wait(semaphore_t *);
status_t sem_trywait(semaphore_t *);
status_t sem_timedwait(semaphore_t *, lk_time_t);

10
kernel/semaphore.c
View File

@@ -32,9 +32,10 @@ void sem_destroy(semaphore_t *sem)
exit_critical_section();
}
status_t sem_post(semaphore_t *sem, bool resched)
int sem_post(semaphore_t *sem, bool resched)
{
status_t ret = NO_ERROR;
int ret = 0;
enter_critical_section();
/*
@@ -42,9 +43,10 @@ status_t sem_post(semaphore_t *sem, bool resched)
* it's safe to just increase the count available with no downsides
*/
if (unlikely(++sem->count <= 0))
wait_queue_wake_one(&sem->wait, resched, NO_ERROR);
ret = wait_queue_wake_one(&sem->wait, resched, NO_ERROR);
exit_critical_section();
return ret;
}
@@ -95,3 +97,5 @@ status_t sem_timedwait(semaphore_t *sem, lk_time_t timeout)
exit_critical_section();
return ret;
}
/* vim: set noexpandtab: */