Lines Matching defs:egen
60 u_int32_t ack, ctlflags, egen, nsites, orig_tally, priority, realpri;
67 COMPQUIET(egen, 0);
258 * We are about to participate at this egen. We must
259 * write out the next egen before participating in this one
260 * so that if we crash we can never participate in this egen
263 if ((ret = __rep_write_egen(env, rep->egen + 1)) != 0)
267 if (__rep_tally(env, rep, rep->eid, &rep->sites, rep->egen,
279 egen = rep->egen;
282 __rep_send_vote(env, &lsn, nsites, ack, priority, tiebreaker, egen,
305 (u_long)rep->egen, (u_long)to, (u_long)timeout));
307 * If the egen changed while we were sleeping, that
328 * If our egen changed while we were waiting. We need to
331 if (egen != rep->egen) {
335 (u_long)egen, (u_long)rep->egen));
349 egen, rep->v2tally_off);
377 __rep_send_vote(env, NULL, 0, 0, 0, 0, egen,
415 "While waiting egen changed to %lu. Phase 2 New timeout %lu, orig timeout %lu",
416 (u_long)rep->egen,
426 if (egen != rep->egen) {
430 (u_long)egen, (u_long)rep->egen));
479 ret = __rep_fire_elected(env, rep, egen);
482 "Ended election with %d, sites %d, egen %lu, flags 0x%lx",
483 ret, rep->sites, (u_long)rep->egen, (u_long)rep->flags));
512 u_int32_t egen;
517 COMPQUIET(egen, 0);
543 tmpvi.egen = ovi->egen;
562 (env, "Received vote1 egen %lu, egen %lu",
563 (u_long)vi->egen, (u_long)rep->egen));
564 if (vi->egen < rep->egen) {
566 "Received old vote %lu, egen %lu, ignoring vote1",
567 (u_long)vi->egen, (u_long)rep->egen));
568 egen_arg.egen = rep->egen;
571 DB_INIT_DBT(data_dbt, &egen_arg.egen,
572 sizeof(egen_arg.egen));
583 if (vi->egen > rep->egen) {
585 "Received VOTE1 from egen %lu, my egen %lu; reset",
586 (u_long)vi->egen, (u_long)rep->egen));
588 rep->egen = vi->egen;
635 vi->egen, rep->tally_off)) != 0) {
642 "Incoming vote: (eid)%d (pri)%lu %s (gen)%lu (egen)%lu [%lu,%lu]",
645 (u_long)rp->gen, (u_long)vi->egen,
675 egen = rep->egen;
680 &rep->votes, egen, rep->v2tally_off);
693 __rep_send_vote(env, NULL, 0, 0, 0, 0, egen,
698 ret = __rep_fire_elected(env, rep, egen);
722 u_int32_t egen;
746 egen = rep->egen;
765 tmpvi.egen = ovi->egen;
775 if (!IN_ELECTION_TALLY(rep) && vi->egen >= rep->egen) {
778 (u_long)vi->egen, (u_long)rep->egen));
803 if (vi->egen != rep->egen) {
805 (env, "Bad vote egen %lu. Mine %lu",
806 (u_long)vi->egen, (u_long)rep->egen));
815 vi->egen, rep->v2tally_off)) != 0) {
828 ret = __rep_fire_elected(env, rep, egen);
841 __rep_tally(env, rep, eid, countp, egen, vtoff)
846 u_int32_t egen;
868 i, vtp->eid, (u_long)vtp->egen,
869 eid, (u_long)egen));
870 if (vtp->egen >= egen)
873 vtp->egen = egen;
886 vtoff == rep->tally_off ? '1' : '2', i, eid, (u_long)egen));
889 vtp->egen = egen;
1074 __rep_fire_elected(env, rep, egen)
1077 u_int32_t egen;
1080 if (rep->notified_egen < egen) {
1082 rep->notified_egen = egen;
1105 u_int32_t egen, sleeptime, sleeptotal, timeout;
1109 egen = rep->egen;
1138 * found a group and found a new egen, we
1139 * override this return with the egen information.
1150 echg = egen != rep->egen;
1156 * a new master getting elected and egen changing,
1162 * If my phase was over, egen has changed but
1164 * told our egen was out of date and updated