}
void PGLog::proc_replica_log(ObjectStore::Transaction& t,
- pg_info_t &oinfo, pg_log_t &olog, pg_missing_t& omissing, int from)
+ pg_info_t &oinfo, const pg_log_t &olog, pg_missing_t& omissing, int from) const
{
dout(10) << "proc_replica_log for osd." << from << ": "
<< oinfo << " " << olog << " " << omissing << dendl;
continue;
}
- pg_log_entry_t& ne = *log.objects[oe.soid];
+ const pg_log_entry_t& ne = *(log.objects.find(oe.soid)->second);
if (ne.version == oe.version) {
dout(10) << " had " << oe << " new " << ne << " : match, stopping" << dendl;
lu = pp->version;
log.last_requested = 0;
}
- void proc_replica_log(ObjectStore::Transaction& t, pg_info_t &oinfo, pg_log_t &olog,
- pg_missing_t& omissing, int from);
+ void proc_replica_log(ObjectStore::Transaction& t, pg_info_t &oinfo, const pg_log_t &olog,
+ pg_missing_t& omissing, int from) const;
protected:
bool merge_old_entry(ObjectStore::Transaction& t, const pg_log_entry_t& oe,