ceph_assert(op->target.flags & (CEPH_OSD_FLAG_READ|CEPH_OSD_FLAG_WRITE));
- if (pool_full_try) {
- op->target.flags |= CEPH_OSD_FLAG_FULL_TRY;
- }
-
bool need_send = false;
if (op->target.paused) {
ldout(cct, 10) << " tid " << op->tid << " op " << op << " is paused"
std::atomic<int> global_op_flags{0}; // flags which are applied to each IO op
bool keep_balanced_budget = false;
bool honor_pool_full = true;
- bool pool_full_try = false;
// If this is true, accumulate a set of blocklisted entities
// to be drained by consume_blocklist_events.
void set_honor_pool_full() { honor_pool_full = true; }
void unset_honor_pool_full() { honor_pool_full = false; }
- void set_pool_full_try() { pool_full_try = true; }
- void unset_pool_full_try() { pool_full_try = false; }
-
void _scan_requests(
OSDSession *s,
bool skipped_map,