peer_features(CEPH_FEATURES_SUPPORTED_DEFAULT),
acting_features(CEPH_FEATURES_SUPPORTED_DEFAULT),
upacting_features(CEPH_FEATURES_SUPPORTED_DEFAULT),
- do_sort_bitwise(false),
last_epoch(0)
{
#ifdef PG_DEBUG_REFS
upacting_features &= osdmap->get_xinfo(*p).features;
}
- do_sort_bitwise = osdmap->test_flag(CEPH_OSDMAP_SORTBITWISE);
+ assert(osdmap->test_flag(CEPH_OSDMAP_SORTBITWISE));
_on_new_interval();
}
uint64_t acting_features;
uint64_t upacting_features;
- bool do_sort_bitwise;
epoch_t last_epoch;
public:
uint64_t get_min_acting_features() const { return acting_features; }
uint64_t get_min_upacting_features() const { return upacting_features; }
- /// true if we will sort hobjects bitwise for this pg interval
- bool get_sort_bitwise() const {
- return do_sort_bitwise;
- }
-
void init_primary_up_acting(
const vector<int> &newup,
const vector<int> &newacting,
virtual pg_shard_t primary_shard() const = 0;
virtual uint64_t min_peer_features() const = 0;
- virtual bool sort_bitwise() const = 0;
virtual hobject_t get_temp_recovery_object(eversion_t version,
snapid_t snap) = 0;
uint64_t min_peer_features() const override {
return get_min_peer_features();
}
- bool sort_bitwise() const override {
- return get_sort_bitwise();
- }
void send_message_osd_cluster(
int peer, Message *m, epoch_t from_epoch) override;