Subversion Repositories HelenOS

Rev

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

Rev 2071 Rev 3186
Line 36... Line 36...
36 
 */
 36 
 */
37 
 
 37 
 
38 
#include <synch/mutex.h>
 38 
#include <synch/mutex.h>
39 
#include <synch/semaphore.h>
 39 
#include <synch/semaphore.h>
40 
#include <synch/synch.h>
 40 
#include <synch/synch.h>
- 
 
 41 
#include <debug.h>
41 
 
 42 
 
42 
/** Initialize mutex
 43 
/** Initialize mutex.
43 
 *
 44 
 *
44 
 * Initialize mutex.
 45 
 * @param mtx       Mutex.
45 
 *
 - 
 
46 
 * @param mtx Mutex.
 46 
 * @param type      Type of the mutex.
47 
 */
 47 
 */
48 
void mutex_initialize(mutex_t *mtx)
 48 
void mutex_initialize(mutex_t *mtx, mutex_type_t type)
49 
{
 49 
{
- 
 
 50 
    mtx->type = type;
50 
    semaphore_initialize(&mtx->sem, 1);
 51 
    semaphore_initialize(&mtx->sem, 1);
51 
}
 52 
}
52 
 
 53 
 
53 
/** Acquire mutex
 54 
/** Acquire mutex.
54 
 *
 55 
 *
55 
 * Acquire mutex.
 - 
 
56 
 * Timeout mode and non-blocking mode can be requested.
 56 
 * Timeout mode and non-blocking mode can be requested.
57 
 *
 57 
 *
58 
 * @param mtx Mutex.
 58 
 * @param mtx       Mutex.
59 
 * @param usec Timeout in microseconds.
 59 
 * @param usec      Timeout in microseconds.
60 
 * @param flags Specify mode of operation.
 60 
 * @param flags     Specify mode of operation.
61 
 *
 61 
 *
62 
 * For exact description of possible combinations of
 62 
 * For exact description of possible combinations of
63 
 * usec and flags, see comment for waitq_sleep_timeout().
 63 
 * usec and flags, see comment for waitq_sleep_timeout().
64 
 *
 64 
 *
65 
 * @return See comment for waitq_sleep_timeout().
 65 
 * @return      See comment for waitq_sleep_timeout().
66 
 */
 66 
 */
67 
int _mutex_lock_timeout(mutex_t *mtx, uint32_t usec, int flags)
 67 
int _mutex_lock_timeout(mutex_t *mtx, uint32_t usec, int flags)
68 
{
 68 
{
- 
 
 69 
    int rc;
- 
 
 70 
 
- 
 
 71 
    if (mtx->type == MUTEX_PASSIVE) {
69 
    return _semaphore_down_timeout(&mtx->sem, usec, flags);
 72 
        rc = _semaphore_down_timeout(&mtx->sem, usec, flags);
- 
 
 73 
    } else {
- 
 
 74 
        ASSERT(mtx->type == MUTEX_ACTIVE);
- 
 
 75 
        ASSERT(usec == SYNCH_NO_TIMEOUT);
- 
 
 76 
        ASSERT(!(flags & SYNCH_FLAGS_INTERRUPTIBLE));
- 
 
 77 
        do {
- 
 
 78 
            rc = semaphore_trydown(&mtx->sem);
- 
 
 79 
        } while (SYNCH_FAILED(rc) &&
- 
 
 80 
            !(flags & SYNCH_FLAGS_NON_BLOCKING));
- 
 
 81 
    }
- 
 
 82 
 
- 
 
 83 
    return rc;
70 
}
 84 
}
71 
 
 85 
 
72 
/** Release mutex
 86 
/** Release mutex.
73 
 *
 - 
 
74 
 * Release mutex.
 - 
 
75 
 *
 87 
 *
76 
 * @param mtx Mutex.
 88 
 * @param mtx       Mutex.
77 
 */
 89 
 */
78 
void mutex_unlock(mutex_t *mtx)
 90 
void mutex_unlock(mutex_t *mtx)
79 
{
 91 
{
80 
    semaphore_up(&mtx->sem);
 92 
    semaphore_up(&mtx->sem);
81 
}
 93 
}