#define tracepoint(...)
#endif
+using std::ostream;
+using std::set;
+using std::string;
+using std::stringstream;
+
+using ceph::Formatter;
+
OpRequest::OpRequest(Message *req, OpTracker *tracker) :
TrackedOp(tracker, req->get_recv_stamp()),
rmw_flags(0), request(req),
return classes_;
}
- void _dump(Formatter *f) const override;
+ void _dump(ceph::Formatter *f) const override;
bool has_feature(uint64_t f) const {
return request->get_connection()->has_feature(f);
OpRequest(Message *req, OpTracker *tracker);
protected:
- void _dump_op_descriptor_unlocked(ostream& stream) const override;
+ void _dump_op_descriptor_unlocked(std::ostream& stream) const override;
void _unregistered() override;
- bool filter_out(const set<string>& filters) override;
+ bool filter_out(const std::set<std::string>& filters) override;
public:
~OpRequest() override {
void mark_reached_pg() {
mark_flag_point(flag_reached_pg, "reached_pg");
}
- void mark_delayed(const string& s) {
+ void mark_delayed(const std::string& s) {
mark_flag_point_string(flag_delayed, s);
}
void mark_started() {
mark_flag_point(flag_started, "started");
}
- void mark_sub_op_sent(const string& s) {
+ void mark_sub_op_sent(const std::string& s) {
mark_flag_point_string(flag_sub_op_sent, s);
}
void mark_commit_sent() {
private:
void set_rmw_flags(int flags);
void mark_flag_point(uint8_t flag, const char *s);
- void mark_flag_point_string(uint8_t flag, const string& s);
+ void mark_flag_point_string(uint8_t flag, const std::string& s);
};
typedef OpRequest::Ref OpRequestRef;
-ostream& operator<<(ostream& out, const OpRequest::ClassInfo& i);
+std::ostream& operator<<(std::ostream& out, const OpRequest::ClassInfo& i);
#endif /* OPREQUEST_H_ */