virtual int do_command(cmdmap_t cmdmap, ostream& ss,
bufferlist& idata, bufferlist& odata) = 0;
- virtual bool same_for_read_since(epoch_t e) = 0;
- virtual bool same_for_modify_since(epoch_t e) = 0;
- virtual bool same_for_rep_modify_since(epoch_t e) = 0;
-
virtual void on_role_change() = 0;
virtual void on_pool_change() = 0;
virtual void on_change(ObjectStore::Transaction *t) = 0;
return osd->logger;
}
-// =======================
-// pg changes
-
-bool ReplicatedPG::same_for_read_since(epoch_t e)
-{
- return (e >= info.history.same_primary_since);
-}
-
-bool ReplicatedPG::same_for_modify_since(epoch_t e)
-{
- return (e >= info.history.same_primary_since);
-}
-
-bool ReplicatedPG::same_for_rep_modify_since(epoch_t e)
-{
- // check osd map: same set, or primary+acker?
- return e >= info.history.same_primary_since;
-}
// ====================
// missing objects
int _delete_oid(OpContext *ctx, bool no_whiteout);
int _rollback_to(OpContext *ctx, ceph_osd_op& op);
public:
- bool same_for_read_since(epoch_t e);
- bool same_for_modify_since(epoch_t e);
- bool same_for_rep_modify_since(epoch_t e);
-
bool is_missing_object(const hobject_t& oid) const;
bool is_unreadable_object(const hobject_t &oid) const {
return is_missing_object(oid) ||