extern "C" void _rados_set_osdmap_full_try(rados_ioctx_t io)
{
librados::IoCtxImpl *ctx = (librados::IoCtxImpl *)io;
- ctx->objecter->set_osdmap_full_try();
+ ctx->objecter->set_pool_full_try();
}
LIBRADOS_C_API_BASE_DEFAULT(rados_set_osdmap_full_try);
extern "C" void _rados_unset_osdmap_full_try(rados_ioctx_t io)
{
librados::IoCtxImpl *ctx = (librados::IoCtxImpl *)io;
- ctx->objecter->unset_osdmap_full_try();
+ ctx->objecter->unset_pool_full_try();
}
LIBRADOS_C_API_BASE_DEFAULT(rados_unset_osdmap_full_try);
void librados::IoCtx::set_osdmap_full_try()
{
- io_ctx_impl->objecter->set_osdmap_full_try();
+ io_ctx_impl->objecter->set_pool_full_try();
}
void librados::IoCtx::unset_osdmap_full_try()
{
- io_ctx_impl->objecter->unset_osdmap_full_try();
+ io_ctx_impl->objecter->unset_pool_full_try();
}
///////////////////////////// Rados //////////////////////////////
purge_queue.update_op_limit(*mdsmap);
- objecter->unset_honor_osdmap_full();
+ objecter->unset_honor_pool_full();
finisher = new Finisher(cct, "MDSRank", "MR_Finisher");
ceph_assert(op->target.flags & (CEPH_OSD_FLAG_READ|CEPH_OSD_FLAG_WRITE));
- if (osdmap_full_try) {
+ if (pool_full_try) {
op->target.flags |= CEPH_OSD_FLAG_FULL_TRY;
}
bool Objecter::_osdmap_pool_full(const pg_pool_t &p) const
{
- return p.has_flag(pg_pool_t::FLAG_FULL) && honor_osdmap_full;
+ return p.has_flag(pg_pool_t::FLAG_FULL) && honor_pool_full;
}
/**
bool Objecter::_osdmap_full_flag() const
{
// Ignore the FULL flag if the caller does not have honor_osdmap_full
- return osdmap->test_flag(CEPH_OSDMAP_FULL) && honor_osdmap_full;
+ return osdmap->test_flag(CEPH_OSDMAP_FULL) && honor_pool_full;
}
void Objecter::update_pool_full_map(map<int64_t, bool>& pool_full_map)
// pre-luminous osds
flags |= CEPH_OSD_FLAG_ONDISK;
- if (!honor_osdmap_full)
+ if (!honor_pool_full)
flags |= CEPH_OSD_FLAG_FULL_FORCE;
op->target.paused = false;
std::atomic<unsigned> num_in_flight{0};
std::atomic<int> global_op_flags{0}; // flags which are applied to each IO op
bool keep_balanced_budget = false;
- bool honor_osdmap_full = true;
- bool osdmap_full_try = false;
+ bool honor_pool_full = true;
+ bool pool_full_try = false;
// If this is true, accumulate a set of blacklisted entities
// to be drained by consume_blacklist_events.
void set_balanced_budget() { keep_balanced_budget = true; }
void unset_balanced_budget() { keep_balanced_budget = false; }
- void set_honor_osdmap_full() { honor_osdmap_full = true; }
- void unset_honor_osdmap_full() { honor_osdmap_full = false; }
+ void set_honor_pool_full() { honor_pool_full = true; }
+ void unset_honor_pool_full() { honor_pool_full = false; }
- void set_osdmap_full_try() { osdmap_full_try = true; }
- void unset_osdmap_full_try() { osdmap_full_try = false; }
+ void set_pool_full_try() { pool_full_try = true; }
+ void unset_pool_full_try() { pool_full_try = false; }
void _scan_requests(
OSDSession *s,