#include "db_config.h"
#include "db_int.h"
#include "dbinc/mutex_int.h"
int
__db_fcntl_mutex_init(env, mutex, flags)
ENV *env;
db_mutex_t mutex;
u_int32_t flags;
{
COMPQUIET(env, NULL);
COMPQUIET(mutex, MUTEX_INVALID);
COMPQUIET(flags, 0);
return (0);
}
int
__db_fcntl_mutex_lock(env, mutex)
ENV *env;
db_mutex_t mutex;
{
DB_ENV *dbenv;
DB_MUTEX *mutexp;
DB_MUTEXMGR *mtxmgr;
DB_MUTEXREGION *mtxregion;
struct flock k_lock;
int locked, ms, ret;
dbenv = env->dbenv;
if (!MUTEX_ON(env) || F_ISSET(dbenv, DB_ENV_NOLOCKING))
return (0);
mtxmgr = env->mutex_handle;
mtxregion = mtxmgr->reginfo.primary;
mutexp = MUTEXP_SET(mutex);
CHECK_MTX_THREAD(env, mutexp);
#ifdef HAVE_STATISTICS
if (F_ISSET(mutexp, DB_MUTEX_LOCKED))
++mutexp->mutex_set_wait;
else
++mutexp->mutex_set_nowait;
#endif
k_lock.l_whence = SEEK_SET;
k_lock.l_start = mutex;
k_lock.l_len = 1;
for (locked = 0;;) {
for (ms = 1; F_ISSET(mutexp, DB_MUTEX_LOCKED);) {
__os_yield(NULL, 0, ms * US_PER_MS);
if ((ms <<= 1) > MS_PER_SEC)
ms = MS_PER_SEC;
}
k_lock.l_type = F_WRLCK;
if (fcntl(env->lockfhp->fd, F_SETLKW, &k_lock))
goto err;
if (!F_ISSET(mutexp, DB_MUTEX_LOCKED)) {
locked = 1;
F_SET(mutexp, DB_MUTEX_LOCKED);
dbenv->thread_id(dbenv, &mutexp->pid, &mutexp->tid);
}
k_lock.l_type = F_UNLCK;
if (fcntl(env->lockfhp->fd, F_SETLK, &k_lock))
goto err;
if (locked)
break;
}
#ifdef DIAGNOSTIC
if (F_ISSET(dbenv, DB_ENV_YIELDCPU))
__os_yield(env, 0, 0);
#endif
return (0);
err: ret = __os_get_syserr();
__db_syserr(env, ret, "fcntl lock failed");
return (__env_panic(env, __os_posix_err(ret)));
}
int
__db_fcntl_mutex_unlock(env, mutex)
ENV *env;
db_mutex_t mutex;
{
DB_ENV *dbenv;
DB_MUTEX *mutexp;
DB_MUTEXMGR *mtxmgr;
DB_MUTEXREGION *mtxregion;
dbenv = env->dbenv;
if (!MUTEX_ON(env) || F_ISSET(dbenv, DB_ENV_NOLOCKING))
return (0);
mtxmgr = env->mutex_handle;
mtxregion = mtxmgr->reginfo.primary;
mutexp = MUTEXP_SET(mutex);
#ifdef DIAGNOSTIC
if (!F_ISSET(mutexp, DB_MUTEX_LOCKED)) {
__db_errx(env, "fcntl unlock failed: lock already unlocked");
return (__env_panic(env, EACCES));
}
#endif
F_CLR(mutexp, DB_MUTEX_LOCKED);
return (0);
}
int
__db_fcntl_mutex_destroy(env, mutex)
ENV *env;
db_mutex_t mutex;
{
COMPQUIET(env, NULL);
COMPQUIET(mutex, MUTEX_INVALID);
return (0);
}