Method CreateBthreadSpan

src/brpc/span.cpp:243–284

}

std::shared_ptr<Span> Span::CreateBthreadSpan(const std::string& full_method_name,
                                              int64_t base_real_us) {
    std::shared_ptr<Span> parent = Span::tls_parent();
    Span* span_raw = butil::get_object<Span>(Forbidden());
    if (__builtin_expect(span_raw == NULL, 0)) {
        return nullptr;
    }
    std::shared_ptr<Span> span(span_raw, SpanDeleter());
    span->_log_id = 0;
    span->_base_cid = INVALID_BTHREAD_ID;
    span->_ending_tid = INVALID_BTHREAD;  // Bthread Span uses ending_tid
    span->_type = SPAN_TYPE_BTHREAD;
    span->_async = false;
    span->_protocol = PROTOCOL_UNKNOWN;
    span->_error_code = 0;
    span->_request_size = 0;
    span->_response_size = 0;
    span->_base_real_us = base_real_us;
    span->_received_real_us = 0;
    span->_start_parse_real_us = 0;
    span->_start_callback_real_us = 0;
    span->_start_send_real_us = 0;
    span->_sent_real_us = 0;
    span->_full_method_name = full_method_name;
    span->_info.clear();

    if (parent) {
        span->_trace_id = parent->trace_id();
        span->_parent_span_id = parent->span_id();
        span->_local_parent = parent;
        {
            BAIDU_SCOPED_LOCK(parent->_client_list_spinlock);
            parent->_client_list.push_back(span);
        }
    } else {
        span->_trace_id = GenerateTraceId();
        span->_parent_span_id = 0;
    }

    span->_span_id = GenerateSpanId();
    return span;
}

inline const std::string& unknown_span_name() {
    // thread-safe in gcc.