#include "db_config.h"
#include "db_int.h"
#include "dbinc/mutex_int.h"
int
__mutex_alloc_pp(dbenv, flags, indxp)
DB_ENV *dbenv;
u_int32_t flags;
db_mutex_t *indxp;
{
DB_THREAD_INFO *ip;
ENV *env;
int ret;
env = dbenv->env;
switch (flags) {
case 0:
case DB_MUTEX_PROCESS_ONLY:
case DB_MUTEX_SELF_BLOCK:
break;
default:
return (__db_ferr(env, "DB_ENV->mutex_alloc", 0));
}
ENV_ENTER(env, ip);
ret = __mutex_alloc(env, MTX_APPLICATION, flags, indxp);
ENV_LEAVE(env, ip);
return (ret);
}
int
__mutex_free_pp(dbenv, indx)
DB_ENV *dbenv;
db_mutex_t indx;
{
DB_THREAD_INFO *ip;
ENV *env;
int ret;
env = dbenv->env;
if (indx == MUTEX_INVALID)
return (EINVAL);
ENV_ENTER(env, ip);
ret = __mutex_free(env, &indx);
ENV_LEAVE(env, ip);
return (ret);
}
int
__mutex_lock_pp(dbenv, indx)
DB_ENV *dbenv;
db_mutex_t indx;
{
DB_THREAD_INFO *ip;
ENV *env;
int ret;
env = dbenv->env;
if (indx == MUTEX_INVALID)
return (EINVAL);
ENV_ENTER(env, ip);
ret = __mutex_lock(env, indx);
ENV_LEAVE(env, ip);
return (ret);
}
int
__mutex_unlock_pp(dbenv, indx)
DB_ENV *dbenv;
db_mutex_t indx;
{
DB_THREAD_INFO *ip;
ENV *env;
int ret;
env = dbenv->env;
if (indx == MUTEX_INVALID)
return (EINVAL);
ENV_ENTER(env, ip);
ret = __mutex_unlock(env, indx);
ENV_LEAVE(env, ip);
return (ret);
}
int
__mutex_get_align(dbenv, alignp)
DB_ENV *dbenv;
u_int32_t *alignp;
{
ENV *env;
env = dbenv->env;
if (MUTEX_ON(env)) {
*alignp = ((DB_MUTEXREGION *)
env->mutex_handle->reginfo.primary)->stat.st_mutex_align;
} else
*alignp = dbenv->mutex_align;
return (0);
}
int
__mutex_set_align(dbenv, align)
DB_ENV *dbenv;
u_int32_t align;
{
ENV *env;
env = dbenv->env;
ENV_ILLEGAL_AFTER_OPEN(env, "DB_ENV->set_mutex_align");
if (align == 0 || !POWER_OF_TWO(align)) {
__db_errx(env,
"DB_ENV->mutex_set_align: alignment value must be a non-zero power-of-two");
return (EINVAL);
}
dbenv->mutex_align = align;
return (0);
}
int
__mutex_get_increment(dbenv, incrementp)
DB_ENV *dbenv;
u_int32_t *incrementp;
{
*incrementp = dbenv->mutex_inc;
return (0);
}
int
__mutex_set_increment(dbenv, increment)
DB_ENV *dbenv;
u_int32_t increment;
{
ENV *env;
env = dbenv->env;
ENV_ILLEGAL_AFTER_OPEN(env, "DB_ENV->set_mutex_increment");
dbenv->mutex_cnt = 0;
dbenv->mutex_inc = increment;
return (0);
}
int
__mutex_get_max(dbenv, maxp)
DB_ENV *dbenv;
u_int32_t *maxp;
{
ENV *env;
env = dbenv->env;
if (MUTEX_ON(env)) {
*maxp = ((DB_MUTEXREGION *)
env->mutex_handle->reginfo.primary)->stat.st_mutex_cnt;
} else
*maxp = dbenv->mutex_cnt;
return (0);
}
int
__mutex_set_max(dbenv, max)
DB_ENV *dbenv;
u_int32_t max;
{
ENV *env;
env = dbenv->env;
ENV_ILLEGAL_AFTER_OPEN(env, "DB_ENV->set_mutex_max");
dbenv->mutex_cnt = max;
dbenv->mutex_inc = 0;
return (0);
}
int
__mutex_get_tas_spins(dbenv, tas_spinsp)
DB_ENV *dbenv;
u_int32_t *tas_spinsp;
{
ENV *env;
env = dbenv->env;
if (MUTEX_ON(env)) {
*tas_spinsp = ((DB_MUTEXREGION *)env->
mutex_handle->reginfo.primary)->stat.st_mutex_tas_spins;
} else
*tas_spinsp = dbenv->mutex_tas_spins;
return (0);
}
int
__mutex_set_tas_spins(dbenv, tas_spins)
DB_ENV *dbenv;
u_int32_t tas_spins;
{
ENV *env;
env = dbenv->env;
if (tas_spins == 0)
tas_spins = 1;
else if (tas_spins > 1000000)
tas_spins = 1000000;
if (MUTEX_ON(env))
((DB_MUTEXREGION *)env->mutex_handle
->reginfo.primary)->stat.st_mutex_tas_spins = tas_spins;
else
dbenv->mutex_tas_spins = tas_spins;
return (0);
}