jspan span;
if (msg) {
msg->mark_event("sub_op_started");
- span = tracing::osd::tracer.add_span(__func__, msg->osd_parent_span);
}
trace.event("handle_sub_write");
jspan span;
if (client_op) {
op->trace = client_op->pg_trace;
- span = tracing::osd::tracer.add_span("ECBackend::submit_transaction", client_op->osd_parent_span);
}
dout(10) << __func__ << ": op " << *op << " starting" << dendl;
start_rmw(op, std::move(t));
messages.push_back(std::make_pair(i->osd, r));
}
}
- jspan span;
- if (op->client_op) {
- span = tracing::osd::tracer.add_span("EC sub write", op->client_op->osd_parent_span);
- }
if (!messages.empty()) {
get_parent()->send_message_osd_cluster(messages, get_osdmap_epoch());
void OSD::ms_fast_dispatch(Message *m)
{
- auto dispatch_span = tracing::osd::tracer.start_trace(__func__);
FUNCTRACE(cct);
if (service.is_stopping()) {
m->put();
tracepoint(osd, ms_fast_dispatch, reqid.name._type,
reqid.name._num, reqid.tid, reqid.inc);
}
- op->osd_parent_span = tracing::osd::tracer.add_span("op-request-created", dispatch_span);
+ op->osd_parent_span = tracing::osd::tracer.start_trace("op-request-created");
if (m->trace)
op->osd_trace.init("osd op", &trace_endpoint, &m->trace);
op->pg_trace.event("do request");
}
- [[maybe_unused]] auto span = tracing::osd::tracer.add_span(__func__, op->osd_parent_span);
// make sure we have a new enough map
auto p = waiting_for_map.find(op->get_source());
<< " flags " << ceph_osd_flag_string(m->get_flags())
<< dendl;
- [[maybe_unused]] auto span = tracing::osd::tracer.add_span(__func__, op->osd_parent_span);
// missing object?
if (is_unreadable_object(head)) {
reqid.name._num, reqid.tid, reqid.inc);
}
- [[maybe_unused]] auto span = tracing::osd::tracer.add_span(__func__, ctx->op->osd_parent_span);
int result = prepare_transaction(ctx);
dout(10) << "do_osd_op " << soid << " " << ops << dendl;
- jspan span;
- if (ctx->op) {
- span = tracing::osd::tracer.add_span(__func__, ctx->op->osd_parent_span);
- }
ctx->current_osd_subop_num = 0;
for (auto p = ops.begin(); p != ops.end(); ++p, ctx->current_osd_subop_num++, ctx->processed_subop_count++) {
OSDOp& osd_op = *p;
<< dendl;
utime_t now = ceph_clock_now();
- jspan span;
- if (ctx->op) {
- span = tracing::osd::tracer.add_span(__func__, ctx->op->osd_parent_span);
- }
// Drop the reference if deduped chunk is modified
if (ctx->new_obs.oi.is_dirty() &&
void PrimaryLogPG::eval_repop(RepGather *repop)
{
- jspan span;
- if (repop->op) {
- span = tracing::osd::tracer.add_span(__func__, repop->op->osd_parent_span);
- }
dout(10) << "eval_repop " << *repop
<< (repop->op && repop->op->get_req<MOSDOp>() ? "" : " (no op)") << dendl;
<< " o " << soid
<< dendl;
- jspan span;
- if (ctx->op) {
- span = tracing::osd::tracer.add_span(__func__, ctx->op->osd_parent_span);
- }
repop->v = ctx->at_version;
ceph_assert(insert_res.second);
InProgressOp &op = *insert_res.first->second;
- jspan span;
- if (orig_op) {
- span = tracing::osd::tracer.add_span("ReplicatedBackend::submit_transaction", orig_op->osd_parent_span);
- }
op.waiting_for_commit.insert(
parent->get_acting_recovery_backfill_shards().begin(),
<< " " << m->logbl.length()
<< dendl;
- jspan span;
- if (op) {
- span = tracing::osd::tracer.add_span(__func__, op->osd_parent_span);
- }
// sanity checks
ceph_assert(m->map_epoch >= get_info().history.same_interval_since);
PGRef& pg,
ThreadPool::TPHandle &handle)
{
- [[maybe_unused]] auto span = tracing::osd::tracer.add_span("PGOpItem::run", op->osd_parent_span);
osd->dequeue_op(pg, op, handle);
pg->unlock();
}