Lines Matching refs:rep
68 REP *rep;
76 rep = db_rep->region;
88 MUTEX_LOCK(env, rep->mtx_clientdb);
90 MUTEX_UNLOCK(env, rep->mtx_clientdb);
92 MUTEX_LOCK(env, rep->mtx_clientdb);
105 STAT(rep->stat.st_bulk_overflows++);
110 MUTEX_UNLOCK(env, rep->mtx_clientdb);
124 STAT(rep->stat.st_bulk_fills++);
126 MUTEX_UNLOCK(env, rep->mtx_clientdb);
145 MUTEX_UNLOCK(env, rep->mtx_clientdb);
152 MUTEX_UNLOCK(env, rep->mtx_clientdb);
173 if (rep->version < DB_REPVERSION_47) {
185 STAT(rep->stat.st_bulk_records++);
195 MUTEX_UNLOCK(env, rep->mtx_clientdb);
216 REP *rep;
226 rep = db_rep->region;
233 MUTEX_UNLOCK(env, rep->mtx_clientdb);
240 STAT(rep->stat.st_bulk_transfers++);
245 MUTEX_LOCK(env, rep->mtx_clientdb);
331 REP *rep;
343 rep = db_rep->region;
364 if (rep->version == DB_REPVERSION)
366 else if (rep->version < DB_REPVERSION) {
367 cntrl.rectype = __rep_msg_to_old(rep->version, rtype);
370 (u_long)rtype, (u_long)rep->version,
376 "rep_send_message: Unknown rep version %lu, my version %lu",
377 (u_long)rep->version, (u_long)DB_REPVERSION);
381 cntrl.rep_version = rep->version;
383 cntrl.gen = rep->gen;
420 if (F_ISSET(rep, REP_F_GROUP_ESTD))
427 if (rep->version != DB_REPVERSION)
441 DB_ASSERT(env, rep->version == DB_REPVERSION);
464 if (rep->version <= DB_REPVERSION_45) {
465 if (rep->version == DB_REPVERSION_45 &&
478 } else if (rep->version == DB_REPVERSION_46) {
506 * We don't hold the rep lock, so this could miscount if we race.
514 rep->stat.st_msgs_send_failures++;
516 rep->stat.st_msgs_sent++;
584 REP *rep;
591 rep = db_rep->region;
598 change = rep->gen != cntrl->gen || rep->master_id != eid;
612 if (F_ISSET(rep, REP_F_READY_MSG))
615 if ((ret = __rep_lockout_msg(env, rep, 1)) != 0)
637 MUTEX_LOCK(env, rep->mtx_clientdb);
639 lp->wait_ts = rep->request_gap;
649 MUTEX_UNLOCK(env, rep->mtx_clientdb);
654 if (F_ISSET(rep, REP_F_READY_API | REP_F_READY_OP)) {
655 ret = __rep_init_cleanup(env, rep, DB_FORCE);
663 F_CLR(rep, REP_F_RECOVER_MASK);
665 MUTEX_UNLOCK(env, rep->mtx_clientdb);
679 __rep_elect_done(env, rep, 1);
682 (u_long)rep->gen, (u_long)cntrl->gen, eid));
683 rep->gen = cntrl->gen;
684 (void)__rep_write_gen(env, rep->gen);
685 if (rep->egen <= rep->gen)
686 rep->egen = rep->gen + 1;
687 rep->master_id = eid;
688 STAT(rep->stat.st_master_changes++);
689 rep->stat.st_startup_complete = 0;
691 rep->version = cntrl->rep_version;
693 "egen: %lu. rep version %lu",
694 (u_long)rep->egen, (u_long)rep->version));
701 if (FLD_ISSET(rep->config, REP_C_DELAYCLIENT))
702 F_SET(rep, REP_F_DELAY);
703 F_SET(rep, REP_F_NOARCHIVE | REP_F_RECOVER_VERIFY);
704 F_CLR(rep, REP_F_READY_MSG);
707 __rep_elect_done(env, rep, 1);
710 MUTEX_LOCK(env, rep->mtx_clientdb);
715 do_req = __rep_check_doreq(env, rep);
716 MUTEX_UNLOCK(env, rep->mtx_clientdb);
722 (F_ISSET(rep, REP_F_RECOVER_MASK) ||
735 if (!F_ISSET(rep, REP_F_RECOVER_MASK)) {
737 F_CLR(rep, REP_F_NOARCHIVE);
742 MUTEX_UNLOCK(env, rep->mtx_clientdb);
781 ret = __rep_log_backup(env, rep, logc, &lsn);
792 MUTEX_LOCK(env, rep->mtx_clientdb);
795 lp->wait_ts = rep->request_gap;
796 MUTEX_UNLOCK(env, rep->mtx_clientdb);
797 if (!F_ISSET(rep, REP_F_DELAY))
810 F_CLR(rep, REP_F_READY_MSG);
811 F_CLR(rep, REP_F_RECOVER_MASK | REP_F_DELAY);
859 REP *rep;
863 rep = db_rep->region;
867 MUTEX_LOCK(env, rep->mtx_clientdb);
869 lp->wait_ts = rep->request_gap;
872 F_CLR(rep, REP_F_RECOVER_VERIFY);
873 F_SET(rep, REP_F_RECOVER_UPDATE);
875 if (F_ISSET(rep, REP_F_DELAY)) {
880 } else if (FLD_ISSET(rep->config, REP_C_NOAUTOINIT)) {
881 F_CLR(rep, REP_F_NOARCHIVE | REP_F_RECOVER_MASK);
888 MUTEX_UNLOCK(env, rep->mtx_clientdb);
910 REP *rep;
936 rep = db_rep->region;
937 return (F_ISSET(rep, REP_F_NOARCHIVE) ? 1 : 0);
957 REP *rep;
964 rep = db_rep->region;
973 if (rep->version < DB_REPVERSION_47) {
1004 __rep_elect_done(env, rep, found_master)
1006 REP *rep;
1012 inelect = IN_ELECTION(rep);
1013 F_CLR(rep,
1019 F_CLR(rep, REP_F_EGENUPDATE);
1020 rep->sites = 0;
1021 rep->votes = 0;
1023 if (timespecisset(&rep->etime)) {
1025 timespecsub(&endtime, &rep->etime);
1027 rep->stat.st_election_sec = (u_int32_t)endtime.tv_sec;
1028 rep->stat.st_election_usec = (u_int32_t)
1034 timespecclear(&rep->etime);
1036 rep->egen++;
1039 (env, "Election done; egen %lu", (u_long)rep->egen));
1045 * Called with the rep mutex held. We need to call the region mutex, so
1058 REP *rep;
1062 rep = env->rep_handle->region;
1068 nalloc = 2 * rep->asites;
1083 if (rep->tally_off != INVALID_ROFF)
1085 infop, R_ADDR(infop, rep->tally_off));
1086 rep->tally_off = R_OFFSET(infop, tally);
1090 if (rep->v2tally_off != INVALID_ROFF)
1092 R_ADDR(infop, rep->v2tally_off));
1093 rep->v2tally_off = R_OFFSET(infop, tally);
1094 rep->asites = nalloc;
1095 rep->nsites = nsites;
1104 if (rep->v2tally_off != INVALID_ROFF)
1106 R_ADDR(infop, rep->v2tally_off));
1108 R_ADDR(infop, rep->tally_off));
1109 rep->v2tally_off = rep->tally_off = INVALID_ROFF;
1110 rep->asites = 0;
1111 rep->nsites = 0;
1136 REP *rep;
1145 rep = db_rep->region;
1161 for (cnt = 0; F_ISSET(rep, REP_F_READY_API);) {
1163 if (FLD_ISSET(rep->config, REP_C_NOWAIT)) {
1175 rep->handle_cnt++;
1193 REP *rep;
1200 rep = db_rep->region;
1203 rep->handle_cnt--;
1232 REP *rep;
1241 rep = db_rep->region;
1259 * incrementing rep->handle_cnt. That seems like a mismatch,
1267 if (F_ISSET(rep, REP_F_READY_OP)) {
1281 rep->handle_cnt++;
1303 REP *rep;
1311 rep = db_rep->region;
1314 for (cnt = 0; F_ISSET(rep, REP_F_READY_OP);) {
1316 if (FLD_ISSET(rep->config, REP_C_NOWAIT)) {
1329 rep->op_cnt++;
1348 REP *rep;
1355 rep = db_rep->region;
1358 DB_ASSERT(env, rep->op_cnt > 0);
1359 rep->op_cnt--;
1374 __rep_lockout_api(env, rep)
1376 REP *rep;
1386 if ((ret = __rep_lockout_int(env, rep, &rep->op_cnt, 0,
1389 return (__rep_lockout_int(env, rep, &rep->handle_cnt, 0,
1406 __rep_lockout_apply(env, rep, apply_th)
1408 REP *rep;
1411 return (__rep_lockout_int(env, rep, &rep->apply_th, apply_th,
1428 __rep_lockout_msg(env, rep, msg_th)
1430 REP *rep;
1433 return (__rep_lockout_int(env, rep, &rep->msg_th, msg_th,
1445 __rep_lockout_int(env, rep, fieldp, field_val, msg, lockout_flag)
1447 REP *rep;
1454 F_SET(rep, lockout_flag);
1498 REP *rep;
1511 rep = db_rep->region;
1535 * We don't hold the rep mutex,
1538 STAT(rep->stat.st_nthrottles++);
1835 REP *rep;
1844 rep = env->rep_handle->region;
1845 if (F_ISSET(rep, REP_F_CLIENT))
1847 else if (F_ISSET(rep, REP_F_MASTER))