From 0b4df52b6cdff860033bf02132e48e2abcb4c93a Mon Sep 17 00:00:00 2001 From: Michal Jarzabek Date: Sun, 29 May 2016 11:28:03 +0100 Subject: [PATCH] osd/OSD.h: change iterator to const_iterator Signed-off-by: Michal Jarzabek --- src/osd/OSD.h | 38 +++++++++++++++++++------------------- 1 file changed, 19 insertions(+), 19 deletions(-) diff --git a/src/osd/OSD.h b/src/osd/OSD.h index 6fbebd6dc820..592b9306cbef 100644 --- a/src/osd/OSD.h +++ b/src/osd/OSD.h @@ -571,8 +571,8 @@ public: Mutex::Locker l(pre_publish_lock); assert(next_osdmap); while (true) { - map::iterator i = map_reservations.begin(); - if (i == map_reservations.end() || i->first >= next_osdmap->get_epoch()) { + map::const_iterator i = map_reservations.cbegin(); + if (i == map_reservations.cend() || i->first >= next_osdmap->get_epoch()) { break; } else { pre_publish_cond.Wait(pre_publish_lock); @@ -669,11 +669,11 @@ public: Mutex::Locker l(sched_scrub_lock); if (sched_scrub_pg.empty()) return false; - set::iterator iter = sched_scrub_pg.lower_bound(next); - if (iter == sched_scrub_pg.end()) + set::const_iterator iter = sched_scrub_pg.lower_bound(next); + if (iter == sched_scrub_pg.cend()) return false; ++iter; - if (iter == sched_scrub_pg.end()) + if (iter == sched_scrub_pg.cend()) return false; *out = *iter; return true; @@ -1166,8 +1166,8 @@ public: void dump_live_pgids() { Mutex::Locker l(pgid_lock); derr << "live pgids:" << dendl; - for (map::iterator i = pgid_tracker.begin(); - i != pgid_tracker.end(); + for (map::const_iterator i = pgid_tracker.cbegin(); + i != pgid_tracker.cend(); ++i) { derr << "\t" << *i << dendl; live_pgs[i->first]->dump_live_ids(); @@ -1453,9 +1453,9 @@ private: void clear_waiting_sessions() { Mutex::Locker l(session_waiting_lock); - for (map >::iterator i = - session_waiting_for_pg.begin(); - i != session_waiting_for_pg.end(); + for (map >::const_iterator i = + session_waiting_for_pg.cbegin(); + i != session_waiting_for_pg.cend(); ++i) { for (set::iterator j = i->second.begin(); j != i->second.end(); @@ -1525,9 +1525,9 @@ private: Mutex::Locker l(session->session_dispatch_lock); clear_session_waiting_on_map(session); - for (map >::iterator i = - session->waiting_for_pg.begin(); - i != session->waiting_for_pg.end(); + for (map >::const_iterator i = + session->waiting_for_pg.cbegin(); + i != session->waiting_for_pg.cend(); ++i) { clear_session_waiting_on_pg(session, i->first); } @@ -1544,8 +1544,8 @@ private: void register_session_waiting_on_pg(Session *session, spg_t pgid) { Mutex::Locker l(session_waiting_lock); set &s = session_waiting_for_pg[pgid]; - set::iterator i = s.find(session); - if (i == s.end()) { + set::const_iterator i = s.find(session); + if (i == s.cend()) { session->get(); s.insert(session); } @@ -1883,11 +1883,11 @@ private: // items in pqueue are behind items in pg_for_processing sdata->pqueue->remove_by_filter(f); - map >::iterator iter = + map >::const_iterator iter = sdata->pg_for_processing.find(pg); - if (iter != sdata->pg_for_processing.end()) { - for (auto i = iter->second.rbegin(); - i != iter->second.rend(); + if (iter != sdata->pg_for_processing.cend()) { + for (auto i = iter->second.crbegin(); + i != iter->second.crend(); ++i) { f.accumulate(*i); } -- 2.47.3