| /netgear-WNDR4500-V1.0.1.40_1.0.68/ap/gpl/timemachine/db-4.7.25.NC/rep/ |
| H A D | rep_elect.c | 60 u_int32_t ack, ctlflags, egen, nsites, orig_tally, priority, realpri; local
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,
512 u_int32_t egen; local
722 u_int32_t egen; local
1105 u_int32_t egen, sleeptime, sleeptotal, timeout; local
[all...] |
| H A D | rep_region.c | 293 * Initialize the value of egen in the region. Called only from
295 * as we create the rep region. We set the rep->egen field which
315 rep->egen = rep->gen + 1;
316 if ((ret = __rep_write_egen(env, rep->egen)) != 0)
320 * File exists, open it and read in our egen.
325 if ((ret = __os_read(env, fhp, &rep->egen, sizeof(u_int32_t),
329 (env, "Read in egen %lu", (u_long)rep->egen));
338 * Write out the egen into the env file.
343 __rep_write_egen(env, egen)
[all...] |
| H A D | rep_record.c | 411 * Updating of egen will happen when we process the
464 egen_arg.egen = *(u_int32_t *)rec->data;
470 "Received ALIVE egen of %lu, mine %lu",
471 (u_long)egen_arg.egen, (u_long)rep->egen));
472 if (egen_arg.egen > rep->egen) {
474 * We're changing egen, need to clear out any old
480 * the egen getting incremented on that path.
483 rep->egen
[all...] |
| H A D | rep_auto.c | 162 DB_HTONL_COPYOUT(env, bp, argp->egen);
182 DB_NTOHL_COPYIN(env, argp->egen, bp);
640 DB_HTONL_COPYOUT(env, bp, argp->egen);
664 DB_NTOHL_COPYIN(env, argp->egen, bp);
|
| H A D | rep_util.c | 685 if (rep->egen <= rep->gen)
686 rep->egen = rep->gen + 1;
693 "egen: %lu. rep version %lu",
694 (u_long)rep->egen, (u_long)rep->version));
948 __rep_send_vote(env, lsnp, nsites, nvotes, pri, tie, egen, eid, vtype, flags)
953 u_int32_t flags, egen, tie, vtype;
975 ovi.egen = egen;
983 vi.egen = egen;
[all...] |
| H A D | rep_method.c | 440 if (rep->egen > rep->gen)
441 rep->gen = rep->egen;
453 if (rep->egen <= rep->gen)
454 rep->egen = rep->gen + 1;
456 "New master gen %lu, egen %lu",
457 (u_long)rep->gen, (u_long)rep->egen));
|
| H A D | rep_stat.c | 111 stats->st_egen = rep->egen;
466 STAT_ULONG("Election generation", rep->egen);
|
| /netgear-WNDR4500-V1.0.1.40_1.0.68/ap/gpl/timemachine/db-4.7.25.NC/dbinc_auto/ |
| H A D | rep_auto.h | 32 u_int32_t egen; member in struct:___rep_egen_args
73 u_int32_t egen; member in struct:___rep_vote_info_args
|
| /netgear-WNDR4500-V1.0.1.40_1.0.68/ap/gpl/timemachine/db-4.7.25.NC/test/ |
| H A D | rep020.tcl | 123 puts "\t$msg: Run elections to increment egen."
139 puts "\t$msg: Updating egen when getting an old vote."
148 set egen($i) \
179 # process messages to get the egen updated.
188 error_check_bad egen_changed $newegen($i) $egen($i)
196 # caught up to the others for egen.
211 set egen($i) [stat_field \
214 error_check_good egen_catchup $egen(4) $egen(3)
226 set fid [open $clientdir($i)/__db.rep.egen
[all...] |
| H A D | rep026.tcl | 164 set egen($i) [stat_field \
214 egen+1 $newegen($i) [expr $egen($i) + 1]
217 egen_unchanged $newegen($i) $egen($i)
248 set mingen [expr $egen($i) + 2]
249 error_check_good egen+more($i) \
|
| H A D | rep022.tcl | 200 set egen($i) [stat_field \
214 set egen($i) [stat_field \
283 set egen_diff [expr $newegen($i) - $egen($i)]
|
| /netgear-WNDR4500-V1.0.1.40_1.0.68/ap/gpl/timemachine/db-4.7.25.NC/dbinc/ |
| H A D | rep.h | 130 * The file contains an egen number for an election this client has NOT
133 * and initialize egen to 1. If it does exist, we read it when we create
139 #define REP_EGENNAME "__db.rep.egen"
200 u_int32_t egen; /* Replication election generation. */ member in struct:__rep
621 u_int32_t egen; /* Election generation. */ member in struct:__anon2064
630 u_int32_t egen; /* Voter's election generation. */ member in struct:__anon2065
|