#include "db_config.h"
#include "db_int.h"
#include "dbinc/db_page.h"
#include "dbinc/db_am.h"
#include "dbinc/log.h"
static int __rep_egen_init __P((ENV *, REP *));
static int __rep_gen_init __P((ENV *, REP *));
int
__rep_open(env)
ENV *env;
{
DB_REP *db_rep;
REGENV *renv;
REGINFO *infop;
REP *rep;
int ret;
db_rep = env->rep_handle;
infop = env->reginfo;
renv = infop->primary;
ret = 0;
if (renv->rep_off == INVALID_ROFF) {
if ((ret = __env_alloc(infop, sizeof(REP), &rep)) != 0)
return (ret);
memset(rep, 0, sizeof(*rep));
if ((ret = __mutex_alloc(
env, MTX_REP_REGION, 0, &rep->mtx_region)) != 0)
return (ret);
if ((ret = __mutex_alloc(
env, MTX_REP_DATABASE, 0, &rep->mtx_clientdb)) != 0)
return (ret);
if ((ret = __mutex_alloc(
env, MTX_REP_CHKPT, 0, &rep->mtx_ckp)) != 0)
return (ret);
if ((ret = __mutex_alloc(
env, MTX_REP_EVENT, 0, &rep->mtx_event)) != 0)
return (ret);
rep->newmaster_event_gen = 0;
rep->notified_egen = 0;
rep->lease_off = INVALID_ROFF;
rep->tally_off = INVALID_ROFF;
rep->v2tally_off = INVALID_ROFF;
rep->eid = db_rep->eid;
rep->master_id = DB_EID_INVALID;
rep->gen = 0;
rep->version = DB_REPVERSION;
if ((ret = __rep_gen_init(env, rep)) != 0)
return (ret);
if ((ret = __rep_egen_init(env, rep)) != 0)
return (ret);
rep->gbytes = db_rep->gbytes;
rep->bytes = db_rep->bytes;
rep->request_gap = db_rep->request_gap;
rep->max_gap = db_rep->max_gap;
rep->config_nsites = db_rep->config_nsites;
rep->config = db_rep->config;
rep->elect_timeout = db_rep->elect_timeout;
rep->full_elect_timeout = db_rep->full_elect_timeout;
rep->lease_timeout = db_rep->lease_timeout;
rep->clock_skew = db_rep->clock_skew;
rep->clock_base = db_rep->clock_base;
timespecclear(&rep->lease_duration);
timespecclear(&rep->grant_expire);
rep->chkpt_delay = db_rep->chkpt_delay;
rep->priority = db_rep->my_priority;
F_SET(rep, REP_F_NOARCHIVE);
renv->rep_off = R_OFFSET(infop, rep);
(void)time(&renv->rep_timestamp);
renv->op_timestamp = 0;
F_CLR(renv, DB_REGENV_REPLOCKED);
} else
rep = R_ADDR(infop, renv->rep_off);
db_rep->region = rep;
return (0);
}
int
__rep_env_refresh(env)
ENV *env;
{
DB_REP *db_rep;
REGENV *renv;
REGINFO *infop;
REP *rep;
int ret, t_ret;
db_rep = env->rep_handle;
rep = db_rep->region;
infop = env->reginfo;
renv = infop->primary;
ret = 0;
if (renv->refcnt == 1) {
F_CLR(rep, REP_F_GROUP_ESTD);
F_CLR(rep, REP_F_START_CALLED);
}
if (F_ISSET(env, ENV_PRIVATE)) {
db_rep = env->rep_handle;
if (db_rep->region != NULL) {
ret = __mutex_free(env, &db_rep->region->mtx_region);
if ((t_ret = __mutex_free(env,
&db_rep->region->mtx_clientdb)) != 0 && ret == 0)
ret = t_ret;
if ((t_ret = __mutex_free(env,
&db_rep->region->mtx_ckp)) != 0 && ret == 0)
ret = t_ret;
if ((t_ret = __mutex_free(env,
&db_rep->region->mtx_event)) != 0 && ret == 0)
ret = t_ret;
}
if (renv->rep_off != INVALID_ROFF)
__env_alloc_free(infop, R_ADDR(infop, renv->rep_off));
}
env->rep_handle->region = NULL;
return (ret);
}
int
__rep_env_close(env)
ENV *env;
{
int ret, t_ret;
ret = __rep_preclose(env);
if ((t_ret = __rep_closefiles(env, 0)) != 0 && ret == 0)
ret = t_ret;
return (ret);
}
int
__rep_preclose(env)
ENV *env;
{
DB_LOG *dblp;
DB_REP *db_rep;
LOG *lp;
REP_BULK bulk;
int ret;
ret = 0;
db_rep = env->rep_handle;
dblp = env->lg_handle;
if (db_rep == NULL || db_rep->region == NULL)
return (ret);
MUTEX_LOCK(env, db_rep->region->mtx_clientdb);
if (db_rep->rep_db != NULL) {
ret = __db_close(db_rep->rep_db, NULL, DB_NOSYNC);
db_rep->rep_db = NULL;
}
if (dblp == NULL)
goto out;
lp = dblp->reginfo.primary;
if (lp->bulk_off != 0 && db_rep->send != NULL) {
memset(&bulk, 0, sizeof(bulk));
bulk.addr = R_ADDR(&dblp->reginfo, lp->bulk_buf);
bulk.offp = &lp->bulk_off;
bulk.len = lp->bulk_len;
bulk.type = REP_BULK_LOG;
bulk.eid = DB_EID_BROADCAST;
bulk.flagsp = &lp->bulk_flags;
(void)__rep_send_bulk(env, &bulk, 0);
}
out: MUTEX_UNLOCK(env, db_rep->region->mtx_clientdb);
return (ret);
}
int
__rep_closefiles(env, do_restored)
ENV *env;
int do_restored;
{
DB_LOG *dblp;
DB_REP *db_rep;
int ret;
ret = 0;
db_rep = env->rep_handle;
dblp = env->lg_handle;
if (db_rep == NULL || db_rep->region == NULL)
return (ret);
if (dblp == NULL)
return (ret);
if ((ret = __dbreg_close_files(env, do_restored)) == 0)
F_CLR(db_rep, DBREP_OPENFILES);
return (ret);
}
static int
__rep_egen_init(env, rep)
ENV *env;
REP *rep;
{
DB_FH *fhp;
int ret;
size_t cnt;
char *p;
if ((ret =
__db_appname(env, DB_APP_NONE, REP_EGENNAME, 0, NULL, &p)) != 0)
return (ret);
if (__os_exists(env, p, NULL) != 0) {
rep->egen = rep->gen + 1;
if ((ret = __rep_write_egen(env, rep->egen)) != 0)
goto err;
} else {
if ((ret = __os_open(env, p, 0,
DB_OSO_RDONLY, DB_MODE_600, &fhp)) != 0)
goto err;
if ((ret = __os_read(env, fhp, &rep->egen, sizeof(u_int32_t),
&cnt)) != 0 || cnt != sizeof(u_int32_t))
goto err1;
RPRINT(env, DB_VERB_REP_MISC,
(env, "Read in egen %lu", (u_long)rep->egen));
err1: (void)__os_closehandle(env, fhp);
}
err: __os_free(env, p);
return (ret);
}
int
__rep_write_egen(env, egen)
ENV *env;
u_int32_t egen;
{
DB_FH *fhp;
int ret;
size_t cnt;
char *p;
if ((ret =
__db_appname(env, DB_APP_NONE, REP_EGENNAME, 0, NULL, &p)) != 0)
return (ret);
if ((ret = __os_open(
env, p, 0, DB_OSO_CREATE | DB_OSO_TRUNC, DB_MODE_600, &fhp)) == 0) {
if ((ret = __os_write(env, fhp, &egen, sizeof(u_int32_t),
&cnt)) != 0 || ((ret = __os_fsync(env, fhp)) != 0))
__db_err(env, ret, "%s", p);
(void)__os_closehandle(env, fhp);
}
__os_free(env, p);
return (ret);
}
static int
__rep_gen_init(env, rep)
ENV *env;
REP *rep;
{
DB_FH *fhp;
int ret;
size_t cnt;
char *p;
if ((ret =
__db_appname(env, DB_APP_NONE, REP_GENNAME, 0, NULL, &p)) != 0)
return (ret);
if (__os_exists(env, p, NULL) != 0) {
rep->gen = 0;
if ((ret = __rep_write_gen(env, rep->gen)) != 0)
goto err;
} else {
if ((ret = __os_open(env, p, 0,
DB_OSO_RDONLY, DB_MODE_600, &fhp)) != 0)
goto err;
if ((ret = __os_read(env, fhp, &rep->gen, sizeof(u_int32_t),
&cnt)) < 0 || cnt == 0)
goto err1;
RPRINT(env, DB_VERB_REP_MISC, (env, "Read in gen %lu",
(u_long)rep->gen));
err1: (void)__os_closehandle(env, fhp);
}
err: __os_free(env, p);
return (ret);
}
int
__rep_write_gen(env, gen)
ENV *env;
u_int32_t gen;
{
DB_FH *fhp;
int ret;
size_t cnt;
char *p;
if ((ret =
__db_appname(env, DB_APP_NONE, REP_GENNAME, 0, NULL, &p)) != 0)
return (ret);
if ((ret = __os_open(
env, p, 0, DB_OSO_CREATE | DB_OSO_TRUNC, DB_MODE_600, &fhp)) == 0) {
if ((ret = __os_write(env, fhp, &gen, sizeof(u_int32_t),
&cnt)) != 0 || ((ret = __os_fsync(env, fhp)) != 0))
__db_err(env, ret, "%s", p);
(void)__os_closehandle(env, fhp);
}
__os_free(env, p);
return (ret);
}