logger->inc(l_osd_map);
logger->inc(l_osd_mape, last - first + 1);
- if (first <= osdmap->get_epoch())
- logger->inc(l_osd_mape_dup, osdmap->get_epoch() - first + 1);
+ if (first <= superblock.newest_map)
+ logger->inc(l_osd_mape_dup, superblock.newest_map - first + 1);
+ if (service.max_oldest_map < m->oldest_map) {
+ service.max_oldest_map = m->oldest_map;
+ assert(service.max_oldest_map >= superblock.oldest_map);
+ }
- // make sure there is something new, here, before we bother flushing the queues and such
- if (last <= osdmap->get_epoch()) {
+ // make sure there is something new, here, before we bother flushing
+ // the queues and such
+ if (last <= superblock.newest_map) {
dout(10) << " no new maps here, dropping" << dendl;
m->put();
return;