Lines Matching refs:egen
110 u_int32_t ack, ctlflags, egen, nsites, orig_tally, priority, realpri;
115 COMPQUIET(egen, 0);
222 ret = __rep_wait(env, &to, 0, rep->egen, REP_F_EPHASE0);
311 * We are about to participate at this egen. We must
312 * write out the next egen before participating in this one
313 * so that if we crash we can never participate in this egen
316 if ((ret = __rep_write_egen(env, rep, rep->egen + 1)) != 0)
320 if (__rep_tally(env, rep, rep->eid, &rep->sites, rep->egen, 1) != 0) {
331 egen = rep->egen;
334 __rep_send_vote(env, &lsn, nsites, ack, priority, tiebreaker, egen,
342 ret = __rep_wait(env, &to, full_elect, egen, REP_F_EPHASE1);
362 (u_long)rep->egen, (u_long)to, (u_long)timeout));
364 * If the egen changed while we were sleeping, that
395 * If our egen changed while we were waiting. We need to
398 if (egen != rep->egen) {
402 (u_long)egen, (u_long)rep->egen));
416 egen, 2);
444 __rep_send_vote(env, NULL, 0, 0, 0, 0, egen,
470 * it above. If egen changes we want to pick up reducing the
473 ret = __rep_wait(env, &to, full_elect, egen, REP_F_EPHASE2);
484 "While waiting egen changed to %lu. Phase 2 New timeout %lu, orig timeout %lu",
485 (u_long)rep->egen,
505 if (egen != rep->egen) {
509 (u_long)egen, (u_long)rep->egen));
558 ret = __rep_fire_elected(env, rep, egen);
561 "Ended election with %d, sites %d, egen %lu, flags 0x%lx",
562 ret, rep->sites, (u_long)rep->egen, (u_long)rep->flags));
591 u_int32_t egen;
596 COMPQUIET(egen, 0);
620 tmpvi.egen = ovi->egen;
639 (env, "Received vote1 egen %lu, egen %lu",
640 (u_long)vi->egen, (u_long)rep->egen));
641 if (vi->egen < rep->egen) {
643 "Received old vote %lu, egen %lu, ignoring vote1",
644 (u_long)vi->egen, (u_long)rep->egen));
645 egen_arg.egen = rep->egen;
648 DB_INIT_DBT(data_dbt, &egen_arg.egen,
649 sizeof(egen_arg.egen));
661 if (vi->egen > rep->egen) {
663 "Received VOTE1 from egen %lu, my egen %lu; reset",
664 (u_long)vi->egen, (u_long)rep->egen));
670 * election and it would not see this change in egen.
673 rep->egen = vi->egen;
712 if ((ret = __rep_tally(env, rep, eid, &rep->sites, vi->egen, 1)) != 0) {
719 "Incoming vote: (eid)%d (pri)%lu %s (gen)%lu (egen)%lu [%lu,%lu]",
722 (u_long)rp->gen, (u_long)vi->egen,
760 egen = rep->egen;
765 &rep->votes, egen, 2);
778 __rep_send_vote(env, NULL, 0, 0, 0, 0, egen,
783 ret = __rep_fire_elected(env, rep, egen);
807 u_int32_t egen;
831 egen = rep->egen;
847 tmpvi.egen = ovi->egen;
857 if (!IN_ELECTION_TALLY(rep) && vi->egen >= rep->egen) {
860 (u_long)vi->egen, (u_long)rep->egen));
885 if (vi->egen != rep->egen) {
887 (env, "Bad vote egen %lu. Mine %lu",
888 (u_long)vi->egen, (u_long)rep->egen));
896 if ((ret = __rep_tally(env, rep, eid, &rep->votes, vi->egen, 2)) != 0) {
909 ret = __rep_fire_elected(env, rep, egen);
922 __rep_tally(env, rep, eid, countp, egen, phase)
927 u_int32_t egen;
966 i, vtp->eid, (u_long)vtp->egen,
967 eid, (u_long)egen));
968 if (vtp->egen >= egen)
971 vtp->egen = egen;
984 phase, i, eid, (u_long)egen));
987 vtp->egen = egen;
1165 __rep_fire_elected(env, rep, egen)
1168 u_int32_t egen;
1171 if (rep->notified_egen < egen) {
1173 rep->notified_egen = egen;
1187 __rep_wait(env, timeoutp, full_elect, egen, flags)
1191 u_int32_t egen, flags;
1228 * found a group and found a new egen, we
1229 * override this return with the egen information.
1240 echg = egen != rep->egen;
1246 * a new master getting elected and egen changing,
1252 * If my phase was over, egen has changed but
1254 * told our egen was out of date and updated
1257 * Phase 0 doesn't care about egen, only the phase over.