haiku/src/kernel/core/lock.c
ejakowatz 52a3801208 It is accomplished ...
git-svn-id: file:///srv/svn/repos/haiku/trunk/current@10 a95241bf-73f2-0310-859d-f6bbb57e9c96
2002-07-09 12:24:59 +00:00

121 lines
2.0 KiB
C

/* Mutex and recursive_lock code */
/*
** Copyright 2001-2002, Travis Geiselbrecht. All rights reserved.
** Distributed under the terms of the NewOS License.
*/
#include <kernel.h>
#include <OS.h>
#include <lock.h>
#include <debug.h>
#include <arch/cpu.h>
#include <Errors.h>
#include <atomic.h>
#include <thread.h>
int recursive_lock_get_recursion(recursive_lock *lock)
{
thread_id thid = thread_get_current_thread_id();
if(lock->holder == thid) {
return lock->recursion;
} else {
return -1;
}
}
int recursive_lock_create(recursive_lock *lock)
{
if(lock == NULL)
return ERR_INVALID_ARGS;
lock->holder = -1;
lock->recursion = 0;
lock->sem = create_sem(1, "recursive_lock_sem");
// if(lock->sem < 0)
// return -1;
return B_NO_ERROR;
}
void recursive_lock_destroy(recursive_lock *lock)
{
if(lock == NULL)
return;
if(lock->sem > 0)
delete_sem(lock->sem);
lock->sem = -1;
}
bool recursive_lock_lock(recursive_lock *lock)
{
thread_id thid = thread_get_current_thread_id();
bool retval = false;
if(thid != lock->holder) {
acquire_sem(lock->sem);
lock->holder = thid;
retval = true;
}
lock->recursion++;
return retval;
}
bool recursive_lock_unlock(recursive_lock *lock)
{
thread_id thid = thread_get_current_thread_id();
bool retval = false;
if(thid != lock->holder)
panic("recursive_lock %p unlocked by non-holder thread!\n", lock);
if(--lock->recursion == 0) {
lock->holder = -1;
release_sem(lock->sem);
retval = true;
}
return retval;
}
int mutex_init(mutex *m, const char *in_name)
{
const char *name;
if(m == NULL)
return ERR_INVALID_ARGS;
if(in_name == NULL)
name = "mutex_sem";
else
name = in_name;
m->count = 0;
m->sem = create_sem(0, name);
if(m->sem < 0)
return m->sem;
return 0;
}
void mutex_destroy(mutex *m)
{
if(m == NULL)
return;
if(m->sem >= 0) {
delete_sem(m->sem);
}
}
void mutex_lock(mutex *m)
{
if(atomic_add(&m->count, 1) >= 1)
acquire_sem(m->sem);
}
void mutex_unlock(mutex *m)
{
if(atomic_add(&m->count, -1) > 1)
release_sem(m->sem);
}