Subversion Repositories HelenOS-historic

Rev

Rev 1264 | Rev 1416 | Go to most recent revision | Show entire file | Ignore whitespace | Details | Blame | Last modification | View Log | RSS feed

Rev 1264 Rev 1375
Line 33... Line 33...
33 
 
 33 
 
34 
#include <synch/condvar.h>
 34 
#include <synch/condvar.h>
35 
#include <synch/mutex.h>
 35 
#include <synch/mutex.h>
36 
#include <synch/waitq.h>
 36 
#include <synch/waitq.h>
37 
#include <synch/synch.h>
 37 
#include <synch/synch.h>
- 
 
 38 
#include <arch.h>
- 
 
 39 
#include <typedefs.h>
38 
 
 40 
 
39 
/** Initialize condition variable
 41 
/** Initialize condition variable.
40 
 *
 - 
 
41 
 * Initialize condition variable.
 - 
 
42 
 *
 42 
 *
43 
 * @param cv Condition variable.
 43 
 * @param cv Condition variable.
44 
 */
 44 
 */
45 
void condvar_initialize(condvar_t *cv)
 45 
void condvar_initialize(condvar_t *cv)
46 
{
 46 
{
47 
    waitq_initialize(&cv->wq);
 47 
    waitq_initialize(&cv->wq);
48 
}
 48 
}
49 
 
 49 
 
50 
/** Signal the condition has become true
 - 
 
51 
 *
 50 
/**
52 
 * Signal the condition has become true
 51 
 * Signal the condition has become true
53 
 * to the first waiting thread by waking it up.
 52 
 * to the first waiting thread by waking it up.
54 
 *
 53 
 *
55 
 * @param cv Condition variable.
 54 
 * @param cv Condition variable.
56 
 */
 55 
 */
57 
void condvar_signal(condvar_t *cv)
 56 
void condvar_signal(condvar_t *cv)
58 
{
 57 
{
59 
    waitq_wakeup(&cv->wq, WAKEUP_FIRST);
 58 
    waitq_wakeup(&cv->wq, WAKEUP_FIRST);
60 
}
 59 
}
61 
 
 60 
 
62 
/** Signal the condition has become true
 - 
 
63 
 *
 61 
/**
64 
 * Signal the condition has become true
 62 
 * Signal the condition has become true
65 
 * to all waiting threads by waking them up.
 63 
 * to all waiting threads by waking them up.
66 
 *
 64 
 *
67 
 * @param cv Condition variable.
 65 
 * @param cv Condition variable.
68 
 */
 66 
 */
69 
void condvar_broadcast(condvar_t *cv)
 67 
void condvar_broadcast(condvar_t *cv)
70 
{
 68 
{
71 
    waitq_wakeup(&cv->wq, WAKEUP_ALL);
 69 
    waitq_wakeup(&cv->wq, WAKEUP_ALL);
72 
}
 70 
}
73 
 
 71 
 
74 
/** Wait for the condition becoming true
 72 
/** Wait for the condition becoming true.
75 
 *
 - 
 
76 
 * Wait for the condition becoming true.
 - 
 
77 
 *
 73 
 *
78 
 * @param cv Condition variable.
 74 
 * @param cv Condition variable.
79 
 * @param mtx Mutex.
 75 
 * @param mtx Mutex.
80 
 * @param usec Timeout value in microseconds.
 76 
 * @param usec Timeout value in microseconds.
81 
 * @param trywait Blocking versus non-blocking operation mode switch.
 77 
 * @param trywait Blocking versus non-blocking operation mode switch.
Line 86... Line 82...
86 
 * @return See comment for waitq_sleep_timeout().
 82 
 * @return See comment for waitq_sleep_timeout().
87 
 */
 83 
 */
88 
int _condvar_wait_timeout(condvar_t *cv, mutex_t *mtx, __u32 usec, int trywait)
 84 
int _condvar_wait_timeout(condvar_t *cv, mutex_t *mtx, __u32 usec, int trywait)
89 
{
 85 
{
90 
    int rc;
 86 
    int rc;
- 
 
 87 
    ipl_t ipl;
91 
 
 88 
 
- 
 
 89 
    ipl = waitq_sleep_prepare(&cv->wq);
92 
    mutex_unlock(mtx);
 90 
    mutex_unlock(mtx);
- 
 
 91 
   
93 
    rc = waitq_sleep_timeout(&cv->wq, usec, trywait);
 92 
    rc = waitq_sleep_timeout_unsafe(&cv->wq, usec, trywait);
- 
 
 93 
 
94 
    mutex_lock(mtx);
 94 
    mutex_lock(mtx);
- 
 
 95 
    waitq_sleep_finish(&cv->wq, rc, ipl);
- 
 
 96 
 
95 
    return rc;
 97 
    return rc;
96 
}
 98 
}