Signed-off-by: Kefu Chai <kchai@redhat.com>
// todo
return seastar::now();
}
+
+void PG::print(ostream& out) const
+{
+ out << "pg[" << info
+ << " " << up;
+ if (acting != up)
+ out << "/" << acting;
+ out << " lpr=" << last_peering_reset
+ << " " << pg_state_string(info.stats.state)
+ << "]";
+}
+
+
+std::ostream& operator<<(std::ostream& os, const PG& pg)
+{
+ pg.print(os);
+ return os;
+}
seastar::future<> handle_advance_map(cached_map_t next_map);
seastar::future<> handle_activate_map();
+ void print(ostream& os) const;
+
private:
void update_primary_state(const std::vector<int>& new_up,
int new_up_primary,
cached_map_t osdmap;
ceph::net::Messenger& msgr;
};
+
+std::ostream& operator<<(std::ostream&, const PG& pg);