}
}
-void OpTracker::mark_event(TrackedOp *op, const string &dest, utime_t time)
+void OpTracker::mark_event(TrackedOp *op, const char *evt,
+ utime_t time)
{
if (!op->state)
return;
- return _mark_event(op, dest, time);
-}
-void OpTracker::_mark_event(TrackedOp *op, const string &evt,
- utime_t time)
-{
dout(5);
- *_dout << "seq: " << op->seq
- << ", time: " << time << ", event: " << evt
- << ", op: ";
+ *_dout << "seq: " << op->seq
+ << ", time: " << time << ", event: " << evt
+ << ", op: ";
op->_dump_op_descriptor_unlocked(*_dout);
*_dout << dendl;
-
}
void TrackedOp::mark_event(const string &event)
Mutex::Locker l(lock);
events.push_back(make_pair(now, event));
}
- tracker->mark_event(this, event);
+ tracker->mark_event(this, event.c_str());
_event_marked();
}
OpHistory history;
float complaint_time;
int log_threshold;
- void _mark_event(TrackedOp *op, const string &evt, utime_t now);
bool tracking_enabled;
RWLock lock;
* with a warning string for each old Op.
* @return True if there are any Ops to warn on, false otherwise.
*/
- bool check_ops_in_flight(std::vector<string> &warning_strings, int *slow = NULL);
- void mark_event(TrackedOp *op, const string &evt,
+ bool check_ops_in_flight(std::vector<string> &warning_strings,
+ int *slow = NULL);
+
+ void mark_event(TrackedOp *op, const char *evt,
utime_t time = ceph_clock_now());
void on_shutdown() {