const hobject_t &soid,
const object_stat_sum_t &delta_stats) override;
void on_primary_error(const hobject_t &oid, eversion_t v) override;
+ void backfill_add_missing(const hobject_t &oid, eversion_t v) override;
void remove_missing_object(const hobject_t &oid,
eversion_t v,
Context *on_complete) override;
eversion_t at_version; // pg's current version pointer
version_t user_at_version; // pg's current user version pointer
+ /// index of the current subop - only valid inside of do_osd_ops()
int current_osd_subop_num;
+ /// total number of subops processed in this context for cls_cxx_subop_version()
+ int processed_subop_count = 0;
PGTransactionUPtr op_t;
vector<pg_log_entry_t> log;
BLOCKED_PROMOTE,
HANDLED_PROXY,
HANDLED_REDIRECT,
+ REPLIED_WITH_EAGAIN,
};
cache_result_t maybe_handle_cache_detail(OpRequestRef op,
bool write_ordered,
bufferlist *val);
int getattrs_maybe_cache(
ObjectContextRef obc,
- map<string, bufferlist> *out,
- bool user_only = false);
+ map<string, bufferlist> *out);
};
inline ostream& operator<<(ostream& out, const PrimaryLogPG::RepGather& repop)