}
void Objecter::_scan_requests(OSDSession *s,
- bool force_resend,
+ bool skipped_map,
bool cluster_full,
map<int64_t, bool> *pool_full_map,
map<ceph_tid_t, Op*>& need_resend,
(*pool_full_map)[op->target.base_oloc.pool];
switch (r) {
case RECALC_OP_TARGET_NO_ACTION:
- if (!force_resend && !force_resend_writes)
+ if (!skipped_map && !force_resend_writes)
break;
// -- fall-thru --
case RECALC_OP_TARGET_NEED_RESEND:
op->session ? op->session->con.get() : nullptr);
switch (r) {
case RECALC_OP_TARGET_NO_ACTION:
- if (!force_resend && !(force_resend_writes && op->respects_full()))
+ if (!skipped_map && !(force_resend_writes && op->respects_full()))
break;
// -- fall-thru --
case RECALC_OP_TARGET_NEED_RESEND:
switch (r) {
case RECALC_OP_TARGET_NO_ACTION:
// resend if skipped map; otherwise do nothing.
- if (!force_resend && !force_resend_writes)
+ if (!skipped_map && !force_resend_writes)
break;
// -- fall-thru --
case RECALC_OP_TARGET_NEED_RESEND:
void unset_osdmap_full_try() { osdmap_full_try = false; }
void _scan_requests(OSDSession *s,
- bool force_resend,
+ bool skipped_map,
bool cluster_full,
map<int64_t, bool> *pool_full_map,
map<ceph_tid_t, Op*>& need_resend,