From: Pavan Rallabhandi Date: Wed, 20 Aug 2014 08:31:57 +0000 (+0530) Subject: TrackedOp:_dump_op_descriptor is renamed to _dump_op_descriptor_unlocked X-Git-Tag: v0.86~236^2 X-Git-Url: http://git-server-git.apps.pok.os.sepia.ceph.com/?a=commitdiff_plain;h=e45f5c2c33508bec3b177e51fd6cc5fde1f0e674;p=ceph.git TrackedOp:_dump_op_descriptor is renamed to _dump_op_descriptor_unlocked Caller don't need to hold lock before calling _dump_op_descriptor(),so, to reflect this it is renamed to _dump_op_descriptor_unlocked(). Signed-off-by: Pavan Rallabhandi Signed-off-by: Somnath Roy --- diff --git a/src/common/TrackedOp.cc b/src/common/TrackedOp.cc index 9ad8e447b4c..11863a48019 100644 --- a/src/common/TrackedOp.cc +++ b/src/common/TrackedOp.cc @@ -169,7 +169,7 @@ bool OpTracker::check_ops_in_flight(std::vector &warning_vector) stringstream ss; ss << "slow request " << age << " seconds old, received at " << (*i)->get_initiated() << ": "; - (*i)->_dump_op_descriptor(ss); + (*i)->_dump_op_descriptor_unlocked(ss); ss << " currently " << ((*i)->current.size() ? (*i)->current : (*i)->state_string()); warning_vector.push_back(ss.str()); @@ -232,7 +232,7 @@ void OpTracker::_mark_event(TrackedOp *op, const string &evt, utime_t time) { stringstream ss; - op->_dump_op_descriptor(ss); + op->_dump_op_descriptor_unlocked(ss); dout(5) << //"reqid: " << op->get_reqid() << ", seq: " << op->seq << ", time: " << time << ", event: " << evt @@ -267,7 +267,7 @@ void TrackedOp::mark_event(const string &event) void TrackedOp::dump(utime_t now, Formatter *f) const { stringstream name; - _dump_op_descriptor(name); + _dump_op_descriptor_unlocked(name); f->dump_string("description", name.str().c_str()); // this TrackedOp f->dump_stream("initiated_at") << get_initiated(); f->dump_float("age", now - get_initiated()); diff --git a/src/common/TrackedOp.h b/src/common/TrackedOp.h index 9a06d12791c..b08c2aa6f39 100644 --- a/src/common/TrackedOp.h +++ b/src/common/TrackedOp.h @@ -149,7 +149,7 @@ protected: /// if you want something else to happen when events are marked, implement virtual void _event_marked() {} /// return a unique descriptor of the Op; eg the message it's attached to - virtual void _dump_op_descriptor(ostream& stream) const = 0; + virtual void _dump_op_descriptor_unlocked(ostream& stream) const = 0; /// called when the last non-OpTracker reference is dropped virtual void _unregistered() {}; diff --git a/src/mds/Mutation.cc b/src/mds/Mutation.cc index f2ea0cea4f9..9335189c32f 100644 --- a/src/mds/Mutation.cc +++ b/src/mds/Mutation.cc @@ -343,7 +343,7 @@ void MDRequestImpl::_dump(utime_t now, Formatter *f) const } } -void MDRequestImpl::_dump_op_descriptor(ostream& stream) const +void MDRequestImpl::_dump_op_descriptor_unlocked(ostream& stream) const { if (client_request) { client_request->print(stream); diff --git a/src/mds/Mutation.h b/src/mds/Mutation.h index ed3f0fa0d47..fee0ad164b8 100644 --- a/src/mds/Mutation.h +++ b/src/mds/Mutation.h @@ -324,7 +324,7 @@ struct MDRequestImpl : public MutationImpl, public TrackedOp { typedef ceph::shared_ptr Ref; protected: void _dump(utime_t now, Formatter *f) const; - void _dump_op_descriptor(ostream& stream) const; + void _dump_op_descriptor_unlocked(ostream& stream) const; }; typedef ceph::shared_ptr MDRequestRef; diff --git a/src/osd/OpRequest.cc b/src/osd/OpRequest.cc index 8e2ffb27979..a6ee3ee5dfc 100644 --- a/src/osd/OpRequest.cc +++ b/src/osd/OpRequest.cc @@ -60,7 +60,7 @@ void OpRequest::_dump(utime_t now, Formatter *f) const } } -void OpRequest::_dump_op_descriptor(ostream& stream) const +void OpRequest::_dump_op_descriptor_unlocked(ostream& stream) const { get_req()->print(stream); } diff --git a/src/osd/OpRequest.h b/src/osd/OpRequest.h index 4c9795847b2..b9bfa9b3ef3 100644 --- a/src/osd/OpRequest.h +++ b/src/osd/OpRequest.h @@ -94,7 +94,7 @@ private: OpRequest(Message *req, OpTracker *tracker); protected: - void _dump_op_descriptor(ostream& stream) const; + void _dump_op_descriptor_unlocked(ostream& stream) const; void _unregistered(); public: