Skip to content

Commit

Permalink
Don't emit set-gen messages if gbl_create_mode is set
Browse files Browse the repository at this point in the history
Signed-off-by: Mark Hannum <[email protected]>
  • Loading branch information
markhannum committed Jan 22, 2025
1 parent fff8855 commit 3089477
Show file tree
Hide file tree
Showing 2 changed files with 14 additions and 13 deletions.
21 changes: 14 additions & 7 deletions berkdb/rep/rep_util.c
Original file line number Diff line number Diff line change
Expand Up @@ -46,6 +46,7 @@ int bdb_num_connected_nodes(struct bdb_state_tag *);

int gbl_verbose_master_req = 0;
int gbl_trace_repmore_reqs = 0;
extern int gbl_create_mode;

/*
* rep_util.c:
Expand Down Expand Up @@ -407,9 +408,11 @@ __rep_set_gen(dbenv, func, line, gen)
egen = rep->egen;
if (rep->egen <= gen)
egen = gen + 1;
logmsg(LOGMSG_USER,
"%s line %d setting rep->gen from %d to %d, egen from %d to %d\n",
func, line, rep->gen, gen, rep->egen, egen);
if (!gbl_create_mode) {
logmsg(LOGMSG_USER,
"%s line %d setting rep->gen from %d to %d, egen from %d to %d\n",
func, line, rep->gen, gen, rep->egen, egen);
}
rep->gen = gen;
rep->egen = egen;
}
Expand Down Expand Up @@ -447,8 +450,10 @@ __rep_set_egen(dbenv, func, line, egen)
REP *rep;
db_rep = dbenv->rep_handle;
rep = db_rep->region;
logmsg(LOGMSG_USER, "%s line %d setting rep->egen from %d to %d\n",
func, line, rep->egen, egen);
if (!gbl_create_mode) {
logmsg(LOGMSG_USER, "%s line %d setting rep->egen from %d to %d\n",
func, line, rep->egen, egen);
}
rep->egen = egen;
}

Expand All @@ -471,8 +476,10 @@ __rep_set_log_gen(dbenv, func, line, log_gen)
REP *rep;
db_rep = dbenv->rep_handle;
rep = db_rep->region;
logmsg(LOGMSG_USER, "%s line %d setting rep->log_gen from %d to %d\n",
func, line, rep->log_gen, log_gen);
if (!gbl_create_mode) {
logmsg(LOGMSG_USER, "%s line %d setting rep->log_gen from %d to %d\n",
func, line, rep->log_gen, log_gen);
}
rep->log_gen = log_gen;
}
/*
Expand Down
6 changes: 0 additions & 6 deletions berkdb/txn/txn_rec.c
Original file line number Diff line number Diff line change
Expand Up @@ -475,8 +475,6 @@ __txn_regop_gen_recover(dbenv, dbtp, lsnp, op, info)
__rep_set_gen(dbenv, __func__, __LINE__, argp->generation);
__rep_set_log_gen(dbenv, __func__, __LINE__, rep->gen);
gbl_recovery_gen = rep->gen;
} else {
logmsg(LOGMSG_USER, "%s line %d: rep->gen is %u, not setting to %u\n", __func__, __LINE__, rep->gen, argp->generation);
}
MUTEX_UNLOCK(dbenv, db_rep->rep_mutexp);
} else if ((dbenv->tx_timestamp != 0 &&
Expand Down Expand Up @@ -806,8 +804,6 @@ __txn_regop_rowlocks_recover(dbenv, dbtp, lsnp, op, info)
__rep_set_gen(dbenv, __func__, __LINE__, argp->generation);
__rep_set_log_gen(dbenv, __func__, __LINE__, rep->gen);
gbl_recovery_gen = rep->gen;
} else {
logmsg(LOGMSG_USER, "%s line %d: rep->gen is %u, not setting to %u\n", __func__, __LINE__, rep->gen, argp->generation);
}
MUTEX_UNLOCK(dbenv, db_rep->rep_mutexp);
}
Expand Down Expand Up @@ -1101,8 +1097,6 @@ __txn_ckp_recover(dbenv, dbtp, lsnp, op, info)
__rep_set_log_gen(dbenv, __func__, __LINE__, rep->gen);
gbl_recovery_gen = rep->gen;
}
} else {
logmsg(LOGMSG_USER, "%s line %d: rep->gen is %u, not setting to %u\n", __func__, __LINE__, rep->gen, argp->rep_gen);
}

if (argp->rep_gen > rep->recover_gen)
Expand Down

0 comments on commit 3089477

Please sign in to comment.