Home - News ( United States | United Kingdom | Italy | Germany ) - Football scores

Showing content from http://www.ncbi.nlm.nih.gov/IEB/ToolBox/CPP_DOC/doxyhtml/opentelemetry__tracer_8cpp_source.html below:

NCBI C++ ToolKit: src/corelib/opentelemetry/opentelemetry_tracer.cpp Source File

opentelemetry;

TIdBuf = vector<uint8_t>;

constexpr

kTraceIdSize = trace::TraceId::kSize;

TTraceIdBuf = nostd::span<const uint8_t, kTraceIdSize>;

TIdBuf trace_id_hash(

&s)

h1 = c + (h1 << 5) + h1;

h2 = c + (h2 << 6) + (h2 << 16) - h2;

TIdBuf

(kTraceIdSize, 0);

(

= 0;

< kTraceIdSize / 2; ++

) {

constexpr

kSpanIdSize = trace::SpanId::kSize;

TSpanIdBuf = nostd::span<const uint8_t, kSpanIdSize>;

TIdBuf span_id_hash(

&s)

h = c + (h << 6) + (h << 16) - h;

TIdBuf

(kSpanIdSize, 0);

(

= 0;

< kSpanIdSize; ++

) {

s_GenerateSpanId();

s_GenerateTraceId();

phid.substr(0, phid.find_first_of(

));

dot = phid.find_last_of(

);

(dot != string::npos && phid.size() > dot) {

phid.substr(0, dot);

TIdBuf span_id_buf = span_id_hash(phid);

trace::SpanId(TSpanIdBuf(span_id_buf.data(), span_id_buf.size()));

base_phid = s_GetBaseHitId();

TIdBuf trace_id_buf = trace_id_hash(base_phid);

trace::TraceId(TTraceIdBuf(trace_id_buf.data(), trace_id_buf.size()));

parent_phid = s_GetParentHitId();

(parent_phid.empty())

trace::SpanId();

TIdBuf span_id_buf = span_id_hash(parent_phid);

trace::SpanId(TSpanIdBuf(span_id_buf.data(), span_id_buf.size()));

= nostd::shared_ptr<trace::Tracer>;

app_name =

;

app_ver =

;

app_name = guard->GetProgramDisplayName();

app_ver = guard->GetVersion().Print();

trace::Provider::GetTracerProvider()->GetTracer(app_name, app_ver);

processor = sdk::trace::SimpleSpanProcessorFactory::Create(std::move(exporter));

vector<unique_ptr<sdk::trace::SpanProcessor>> processors;

processors.push_back(std::move(processor));

opentelemetry::sdk::resource::Resource

sdk::resource::Resource::Create({});

unique_ptr<sdk::trace::Sampler> sampler(

sdk::trace::AlwaysOnSampler());

shared_ptr<trace::TracerProvider> provider =

sdk::trace::TracerProviderFactory::Create(std::move(processors),

resource, std::move(sampler), std::move(id_generator));

trace::Provider::SetTracerProvider(provider);

shared_ptr<trace::TracerProvider> none;

trace::Provider::SetTracerProvider(none);

x_InitOtlp(endpoint);

x_InitOtlp(TParam_OtlpEndpoint::GetDefault());

(

);

exporter::otlp::OtlpHttpExporterOptions http_opt;

http_opt.content_type = exporter::otlp::HttpRequestContentType::kBinary;

http_opt.url = !endpoint.empty() ? endpoint :

;

m_Tracer =

(exporter::otlp::OtlpHttpExporterFactory::Create(http_opt));

exporter::otlp::OtlpGrpcExporterOptions grpc_opt;

grpc_opt.endpoint = !endpoint.empty() ? endpoint :

;

m_Tracer =

(exporter::otlp::OtlpGrpcExporterFactory::Create(grpc_opt));

(

);

m_Tracer =

(exporter::trace::OStreamSpanExporterFactory::Create(ostr));

TIdBuf

(

.

() / 2, 0);

(

= 0;

<

.size() / 2; ++

) {

[

] = NStr::StringToNumeric<uint8_t>(

.substr(

*2, 2), 0, 16);

constexpr

kVersion_Digits = 2;

constexpr

kTraceId_Digits = 32;

constexpr

kParentId_Digits = 16;

constexpr

kFlags_Digits = 2;

constexpr

kSeparator1_Pos = kVersion_Digits;

constexpr

kSeparator2_Pos = kSeparator1_Pos + 1 + kTraceId_Digits;

constexpr

kSeparator3_Pos = kSeparator2_Pos + 1 + kParentId_Digits;

constexpr

kTraceParent_Size = kVersion_Digits + 1 + kTraceId_Digits + 1 + kParentId_Digits + 1 + kFlags_Digits;

(kTraceIdSize*2 == kTraceId_Digits);

(kSpanIdSize*2 == kParentId_Digits);

& traceparent =

.GetSrcTraceParent();

(traceparent.size() >= kTraceParent_Size &&

traceparent[kSeparator1_Pos] ==

&&

traceparent[kSeparator2_Pos] ==

&&

traceparent[kSeparator3_Pos] ==

) {

TIdBuf tid_buf =

(traceparent.substr(kSeparator1_Pos + 1, kTraceId_Digits));

TIdBuf pid_buf =

(traceparent.substr(kSeparator2_Pos + 1, kParentId_Digits));

TIdBuf flags_buf =

(traceparent.substr(kSeparator3_Pos + 1, kFlags_Digits));

trace_id = trace::TraceId(TTraceIdBuf(tid_buf.data(), tid_buf.size()));

parent_id = trace::SpanId(TSpanIdBuf(pid_buf.data(), pid_buf.size()));

= (flags_buf[0] << 8) | flags_buf[1];

ts =

.GetSrcTraceState();

ncbi_pos = ts.find(

);

(ncbi_pos ==

)

ts;

vector<string> states;

(

&

: states) {

(

==

) {

(!new_ts.empty())

+=

;

new_ts =

+

+

+ new_ts;

(!new_ts.empty()) new_ts +=

;

(!tracer)

;

(&current_ctx != &

) {

phid_cur = current_ctx.IsSetHitID() ? current_ctx.GetHitID() :

;

phid_arg =

.IsSetHitID() ?

.GetHitID() :

;

<<

phid_cur <<

<< phid_arg);

trace::TraceId context_tid;

trace::SpanId context_pid;

trace::SpanContext parent_ctx(context_tid, context_pid, trace::TraceFlags(0),

);

trace::StartSpanOptions options;

options.parent = parent_ctx;

(

.GetTracerSpanKind()) {

options.kind = trace::SpanKind::kInternal;

options.kind = trace::SpanKind::kServer;

options.kind = trace::SpanKind::kClient;

options.kind = m_SpanKind;

span->SetStatus(trace_api::StatusCode::kOk);

span->SetAttribute(

,

);

span->SetAttribute(

, diag_context.

());

span->SetAttribute(

, diag_context.

());

span->SetAttribute(

,

.GetRequestID());

span->SetAttribute(

,

.GetHitID());

s =

.GetClientIP();

( !s.empty() ) span->SetAttribute(

, s);

( !s.empty() ) span->SetAttribute(

, s);

trace_id_buf[2*trace::TraceId::kSize + 1];

trace_id_buf[2*trace::TraceId::kSize] = 0;

span->GetContext().trace_id().ToLowerBase16(

nostd::span<char, 2*trace::TraceId::kSize>(trace_id_buf, 2*trace::TraceId::kSize));

trace_id(trace_id_buf);

span_id_buf[2*trace::SpanId::kSize + 1];

span_id_buf[2*trace::SpanId::kSize] = 0;

span->GetContext().span_id().ToLowerBase16(

nostd::span<char, 2*trace::SpanId::kSize>(span_id_buf, 2*trace::SpanId::kSize));

span_id(span_id_buf);

.

(

, trace_id)

.

(

, span_id);

shared_ptr<COpentelemetryTracerSpan> ctx_span = make_shared<COpentelemetryTracerSpan>(span);

ctx_span->m_TraceParent =

+

(trace_id) +

+ span_id +

;

.SetTracerSpan(ctx_span);

ctx_span =

.GetTracerSpan();

(!ctx_span)

;

ot_span = dynamic_pointer_cast<COpentelemetryTracerSpan>(ctx_span);

(!ot_span)

;

ot_span->GetSpan()->End();

(!m_Span)

;

m_Span->UpdateName(name);

( !m_Span )

;

m_Span->SetAttribute(trace::SemanticConventions::kClientAddress,

);

m_Span->SetAttribute(trace::SemanticConventions::kClientPort,

);

m_Span->SetAttribute(trace::SemanticConventions::kServerAddress,

);

m_Span->SetAttribute(trace::SemanticConventions::kServerPort,

);

m_Span->SetAttribute(trace::SemanticConventions::kUrlFull,

);

m_Span->SetAttribute(trace::SemanticConventions::kHttpRequestMethod,

);

m_Span->SetAttribute(trace::SemanticConventions::kUrlScheme,

);

m_Span->SetAttribute(trace::SemanticConventions::kHttpScheme,

);

m_Span->SetAttribute(trace::SemanticConventions::kHttpResponseStatusCode,

);

m_Span->SetAttribute(trace::SemanticConventions::kErrorType,

);

( !m_Span )

;

m_Span->SetAttribute(attr,

);

( !m_Span )

;

(header_type) {

SetCustomAttribute(

+ name,

);

SetCustomAttribute(

+ name,

);

( !m_Span )

;

m_Span->SetStatus(status ==

? trace::StatusCode::kOk : trace::StatusCode::kError);

m_TraceParent;

( !m_Span )

;

m_Span->AddEvent(

, attr);

( m_Span ) m_Span->End();

sdk::trace::IdGenerator TParent

static string s_GetBaseHitId(void)

static string s_GetParentHitId(void)

static trace::TraceId s_GenerateTraceId() noexcept

static trace::SpanId s_GenerateParentSpanId() noexcept

trace::SpanId GenerateSpanId() noexcept override

static trace::SpanId s_GenerateSpanId() noexcept

trace::TraceId GenerateTraceId() noexcept override

static CNcbiApplicationGuard InstanceGuard(void)

Singleton method.

int m_ErrCode

Error code.

int m_ErrSubCode

Sub Error code.

CDiagContext_Extra & Print(const string &name, const string &value)

The method does not print the argument, but adds it to the string.

void SetAttribute(ESpanAttribute attr, const string &value) override

void EndSpan(void) override

const char * m_File

File name.

const char * m_Buffer

Not guaranteed to be '\0'-terminated!

const string & GetHost(void) const

Get host name.

string GetStringUID(TUID uid=0) const

Return string representation of UID.

CDiagContext & GetDiagContext(void)

Get diag context instance.

const string & GetTraceParent(void) const override

const char * m_Module

Module name.

void SetName(const string &name) override

void OnRequestStop(CRequestContext &context) override

CDiagContext_Extra Extra(void) const

Create a temporary CDiagContext_Extra object.

TCount m_ProcPost

Number of the post in the process.

void SetSpanStatus(ESpanStatus status) override

size_t m_Line

Line number in file.

TUID GetUID(void) const

Return (create if not created yet) unique diagnostic ID.

EDiagSev m_Severity

Severity level.

void SetHttpHeader(EHttpHeaderType header_type, const string &name, const string &value) override

const char * m_Prefix

Prefix string.

TDiagPostFlags m_Flags

Bitwise OR of "EDiagPostFlag".

static CRequestContext & GetRequestContext(void)

Shortcut to CDiagContextThreadData::GetThreadData().GetRequestContext()

~COpentelemetryTracer(void)

const string & GetTraceState(void) const override

COpentelemetryTracer(void)

Export using exporter settings from the environment/INI file.

void PostEvent(const SDiagMessage &message) override

static TPID GetPID(void)

Get cached PID (read real PID if not cached yet).

TCount m_ThrPost

Number of the post in the thread.

size_t m_BufferLen

Length of m_Buffer.

static const char * SeverityName(EDiagSev sev)

Get a common symbolic name for the severity levels.

void SetCustomAttribute(const string &attr, const string &value) override

const char * m_Class

Class name.

static void CleanupTracer(void)

Uninstall current tracer, if any.

~COpentelemetryTracerSpan(void)

void OnRequestStart(CRequestContext &context) override

string GetHitID(void) const

Get explicit hit id or the default one (from HTTP_NCBI_PHID etc).

const char * m_Function

Function name.

#define ERR_POST(message)

Error posting with file, line number information but without error codes.

const char * m_ErrText

Sometimes 'error' has no numeric code, but can be represented as text.

void x_InitOtlp(const string &endpoint)

void x_InitStream(ostream &ostr)

@ eDPF_AppLog

Post message to application log.

void Warning(CExceptionArgs_Base &args)

@ eParam_NoThread

Do not use per-thread values.

uint64_t Uint8

8-byte (64-bit) unsigned integer

#define END_NCBI_SCOPE

End previously defined NCBI scope.

#define BEGIN_NCBI_SCOPE

Define ncbi namespace.

static list< string > & Split(const CTempString str, const CTempString delim, list< string > &arr, TSplitFlags flags=0, vector< SIZE_TYPE > *token_pos=NULL)

Split a string using specified delimiters.

static bool SplitInTwo(const CTempString str, const CTempString delim, string &str1, string &str2, TSplitFlags flags=0)

Split a string into two pieces using the specified delimiters.

static enable_if< is_arithmetic< TNumeric >::value||is_convertible< TNumeric, Int8 >::value, string >::type NumericToString(TNumeric value, TNumToStringFlags flags=0, int base=10)

Convert numeric value to string.

static string TruncateSpaces(const string &str, ETrunc where=eTrunc_Both)

Truncate whitespace in a string.

static TThreadSystemID GetCurrentThreadSystemID(void)

Get the current thread ID.

const struct ncbi::grid::netcache::search::fields::SIZE size

const struct ncbi::grid::netcache::search::fields::KEY key

const GenericPointer< typename T::ValueType > T2 value

Defines the CNcbiApplication and CAppException classes for creating NCBI applications.

Multi-threading – mutexes; rw-locks; semaphore.

static string s_UpdateTraceState(CRequestContext &ctx, const string &traceparent)

static void s_ParseIds(CRequestContext &ctx, trace::TraceId &trace_id, trace::SpanId &parent_id, int &flags)

NCBI_PARAM_ENUM_DEF_EX(EOTEL_Exporter, OTEL, TRACES_EXPORTER, EOTEL_Exporter::e_Otlp, eParam_NoThread, OTEL_TRACES_EXPORTER)

DEFINE_STATIC_FAST_MUTEX(s_InitTracerMutex)

nostd::shared_ptr< trace::Tracer > TTracer

NCBI_PARAM_ENUM_DECL(EOTEL_Exporter, OTEL, TRACES_EXPORTER)

typedef NCBI_PARAM_TYPE(OTEL, TRACES_EXPORTER) TParam_Exporter

static string s_DefaultSpanNamePrefix

TIdBuf string_to_id(const string &id)

NCBI_PARAM_ENUM_ARRAY(EOTEL_Exporter, OTEL, TRACES_EXPORTER)

static TTracer s_GetTracer(void)

static TTracer s_InitTracer(unique_ptr< sdk::trace::SpanExporter > exporter)

NCBI_PARAM_DECL(string, OTEL, EXPORTER_OTLP_ENDPOINT)

NCBI_PARAM_DEF_EX(string, OTEL, EXPORTER_OTLP_ENDPOINT, "", eParam_NoThread, OTEL_EXPORTER_OTLP_ENDPOINT)

Defines COpentelemetryTracer class for NCBI C++ diagnostic API.

@ eSuccess

Successfully retrieved.

static SLJIT_INLINE sljit_ins msg(sljit_gpr r, sljit_s32 d, sljit_gpr x, sljit_gpr b)

static CS_CONTEXT * context

RetroSearch is an open source project built by @garambo | Open a GitHub Issue

Search and Browse the WWW like it's 1997 | Search results from DuckDuckGo

HTML: 3.2 | Encoding: UTF-8 | Version: 0.7.4