RepoMirrors/ceph
1
0
Fork 0
mirror of https://github.com/ceph/ceph synced 2024-12-30 07:23:11 +00:00
Code Issues Packages Projects Releases Wiki Activity

common/TrackedOp: some cleanup

Browse Source 
Signed-off-by: Sage Weil <sage@redhat.com>
This commit is contained in:
Sage Weil 2016-12-16 13:59:00 -05:00
parent e7613bd7e2
commit 719c66ef01
1 changed files with 8 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
src/common/TrackedOp.h
View File

@ -172,12 +172,12 @@ protected:
}
};
vector<Event> events; /// list of events and their times
mutable Mutex lock; /// to protect the events list
const char *current; /// the current state the event is in
uint64_t seq; /// a unique value set by the OpTracker
vector<Event> events; ///< list of events and their times
mutable Mutex lock = {"TrackedOp::lock"}; ///< to protect the events list
const char *current = 0; ///< the current state the event is in
uint64_t seq = 0; ///< a unique value set by the OpTracker
uint32_t warn_interval_multiplier; // limits output of a given op warning
uint32_t warn_interval_multiplier = 1; //< limits output of a given op warning
enum {
STATE_UNTRACKED = 0,
@ -191,10 +191,7 @@ protected:
TrackedOp(OpTracker *_tracker, const utime_t& initiated) :
tracker(_tracker),
initiated_at(initiated),
lock("TrackedOp::lock"),
seq(0),
warn_interval_multiplier(1)
initiated_at(initiated)
{
events.reserve(OPTRACKER_PREALLOC_EVENTS);
}
@ -244,12 +241,14 @@ public:
}
return desc;
}
private:
void _gen_desc() const {
ostringstream ss;
_dump_op_descriptor_unlocked(ss);
desc_str = ss.str();
desc = desc_str.c_str();
}
public:
void reset_desc() {
desc = nullptr;
}