Lines Matching defs:rep
32 REP *rep;
42 if ((ret = __env_alloc(infop, sizeof(REP), &rep)) != 0)
44 memset(rep, 0, sizeof(*rep));
52 env, MTX_REP_REGION, 0, &rep->mtx_region)) != 0)
62 env, MTX_REP_DATABASE, 0, &rep->mtx_clientdb)) != 0)
66 env, MTX_REP_CHKPT, 0, &rep->mtx_ckp)) != 0)
70 env, MTX_REP_EVENT, 0, &rep->mtx_event)) != 0)
73 rep->newmaster_event_gen = 0;
74 rep->notified_egen = 0;
75 rep->lease_off = INVALID_ROFF;
76 rep->tally_off = INVALID_ROFF;
77 rep->v2tally_off = INVALID_ROFF;
78 rep->eid = db_rep->eid;
79 rep->master_id = DB_EID_INVALID;
80 rep->gen = 0;
81 rep->version = DB_REPVERSION;
82 if ((ret = __rep_gen_init(env, rep)) != 0)
84 if ((ret = __rep_egen_init(env, rep)) != 0)
86 rep->gbytes = db_rep->gbytes;
87 rep->bytes = db_rep->bytes;
88 rep->request_gap = db_rep->request_gap;
89 rep->max_gap = db_rep->max_gap;
90 rep->config_nsites = db_rep->config_nsites;
91 rep->config = db_rep->config;
92 rep->elect_timeout = db_rep->elect_timeout;
93 rep->full_elect_timeout = db_rep->full_elect_timeout;
94 rep->lease_timeout = db_rep->lease_timeout;
95 rep->clock_skew = db_rep->clock_skew;
96 rep->clock_base = db_rep->clock_base;
97 timespecclear(&rep->lease_duration);
98 timespecclear(&rep->grant_expire);
99 rep->chkpt_delay = db_rep->chkpt_delay;
100 rep->priority = db_rep->my_priority;
102 F_SET(rep, REP_F_NOARCHIVE);
105 renv->rep_off = R_OFFSET(infop, rep);
110 rep = R_ADDR(infop, renv->rep_off);
112 db_rep->region = rep;
130 REP *rep;
134 rep = db_rep->region;
145 F_CLR(rep, REP_F_GROUP_ESTD);
146 F_CLR(rep, REP_F_START_CALLED);
218 * If we have a rep region, we can preclose. Otherwise, return.
295 * as we create the rep region. We set the rep->egen field which
299 __rep_egen_init(env, rep)
301 REP *rep;
315 rep->egen = rep->gen + 1;
316 if ((ret = __rep_write_egen(env, rep->egen)) != 0)
325 if ((ret = __os_read(env, fhp, &rep->egen, sizeof(u_int32_t),
329 (env, "Read in egen %lu", (u_long)rep->egen));
370 * as we create the rep region. We set the rep->gen field which
374 __rep_gen_init(env, rep)
376 REP *rep;
390 rep->gen = 0;
391 if ((ret = __rep_write_gen(env, rep->gen)) != 0)
400 if ((ret = __os_read(env, fhp, &rep->gen, sizeof(u_int32_t),
404 (u_long)rep->gen));