bool was_pausewr = osdmap->test_flag(CEPH_OSDMAP_PAUSEWR) || cluster_full || _osdmap_has_pool_full();
map<int64_t, bool> pool_full_map;
for (map<int64_t, pg_pool_t>::const_iterator it = osdmap->get_pools().begin();
- it != osdmap->get_pools().end(); it++)
+ it != osdmap->get_pools().end(); ++it)
- pool_full_map[it->first] = it->second.has_flag(pg_pool_t::FLAG_FULL);
+ pool_full_map[it->first] = _osdmap_pool_full(it->second);
list<LingerOp*> need_resend_linger;
bool Objecter::_osdmap_has_pool_full() const
{
for (map<int64_t, pg_pool_t>::const_iterator it = osdmap->get_pools().begin();
- it != osdmap->get_pools().end(); it++) {
+ it != osdmap->get_pools().end(); ++it) {
- if (it->second.has_flag(pg_pool_t::FLAG_FULL))
+ if (_osdmap_pool_full(it->second))
return true;
}
return false;
void Objecter::update_pool_full_map(map<int64_t, bool>& pool_full_map)
{
for (map<int64_t, pg_pool_t>::const_iterator it = osdmap->get_pools().begin();
- it != osdmap->get_pools().end(); it++) {
+ it != osdmap->get_pools().end(); ++it) {
if (pool_full_map.find(it->first) == pool_full_map.end()) {
- pool_full_map[it->first] = it->second.has_flag(pg_pool_t::FLAG_FULL);
+ pool_full_map[it->first] = _osdmap_pool_full(it->second);
} else {
- pool_full_map[it->first] = it->second.has_flag(pg_pool_t::FLAG_FULL) || pool_full_map[it->first];
+ pool_full_map[it->first] = _osdmap_pool_full(it->second) || pool_full_map[it->first];
}
}
}