#include "db_config.h"
#ifndef lint
static const char revid[] = "$Id: rep_region.c,v 1.1.1.1 2003/02/15 04:56:12 zarzycki Exp $";
#endif
#ifndef NO_SYSTEM_INCLUDES
#endif
#include <string.h>
#include "db_int.h"
#include "dbinc/rep.h"
#include "dbinc/log.h"
int
__rep_region_init(dbenv)
DB_ENV *dbenv;
{
REGENV *renv;
REGINFO *infop;
DB_MUTEX *db_mutexp;
DB_REP *db_rep;
REP *rep;
int ret;
db_rep = dbenv->rep_handle;
infop = dbenv->reginfo;
renv = infop->primary;
ret = 0;
MUTEX_LOCK(dbenv, &renv->mutex);
if (renv->rep_off == INVALID_ROFF) {
if ((ret = __db_shalloc(infop->addr,
sizeof(REP), MUTEX_ALIGN, &rep)) != 0)
goto err;
memset(rep, 0, sizeof(*rep));
rep->tally_off = INVALID_ROFF;
renv->rep_off = R_OFFSET(infop, rep);
if ((ret = __db_mutex_setup(dbenv, infop, &rep->mutex,
MUTEX_NO_RECORD)) != 0)
goto err;
if ((ret = __db_shalloc(infop->addr, sizeof(DB_MUTEX),
MUTEX_ALIGN, &db_mutexp)) != 0)
goto err;
rep->db_mutex_off = R_OFFSET(infop, db_mutexp);
if ((ret = __db_mutex_setup(dbenv, infop, db_mutexp,
MUTEX_NO_RECORD)) != 0)
goto err;
rep->eid = DB_EID_INVALID;
rep->master_id = DB_EID_INVALID;
rep->gen = 0;
rep->request_gap = DB_REP_REQUEST_GAP;
rep->max_gap = DB_REP_MAX_GAP;
} else
rep = R_ADDR(infop, renv->rep_off);
MUTEX_UNLOCK(dbenv, &renv->mutex);
db_rep->mutexp = &rep->mutex;
db_rep->db_mutexp = R_ADDR(infop, rep->db_mutex_off);
db_rep->region = rep;
return (0);
err: MUTEX_UNLOCK(dbenv, &renv->mutex);
return (ret);
}
int
__rep_region_destroy(dbenv)
DB_ENV *dbenv;
{
DB_REP *db_rep;
int ret, t_ret;
ret = t_ret = 0;
db_rep = (DB_REP *)dbenv->rep_handle;
if (db_rep != NULL) {
if (db_rep->mutexp != NULL)
ret = __db_mutex_destroy(db_rep->mutexp);
if (db_rep->db_mutexp != NULL)
t_ret = __db_mutex_destroy(db_rep->db_mutexp);
}
return (ret == 0 ? t_ret : ret);
}
int
__rep_dbenv_close(dbenv)
DB_ENV *dbenv;
{
DB_REP *db_rep;
db_rep = (DB_REP *)dbenv->rep_handle;
if (db_rep != NULL) {
__os_free(dbenv, db_rep);
dbenv->rep_handle = NULL;
}
return (0);
}
int
__rep_preclose(dbenv, do_closefiles)
DB_ENV *dbenv;
int do_closefiles;
{
DB *dbp;
DB_REP *db_rep;
int ret, t_ret;
ret = t_ret = 0;
if ((db_rep = (DB_REP *)dbenv->rep_handle) == NULL)
return (0);
if ((dbp = db_rep->rep_db) != NULL) {
MUTEX_LOCK(dbenv, db_rep->db_mutexp);
ret = dbp->close(dbp, 0);
db_rep->rep_db = NULL;
MUTEX_UNLOCK(dbenv, db_rep->db_mutexp);
}
if (do_closefiles)
t_ret = __dbreg_close_files(dbenv);
return (ret == 0 ? t_ret : ret);
}