tracer_test.cc 50 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334
  1. // Copyright The OpenTelemetry Authors
  2. // SPDX-License-Identifier: Apache-2.0
  3. #include <assert.h>
  4. #include <gtest/gtest.h>
  5. #include <algorithm>
  6. #include <chrono>
  7. #include <cstdint>
  8. #include <functional>
  9. #include <initializer_list>
  10. #include <map>
  11. #include <string>
  12. #include <unordered_map>
  13. #include <utility>
  14. #include <vector>
  15. #include "opentelemetry/common/attribute_value.h"
  16. #include "opentelemetry/common/key_value_iterable.h"
  17. #include "opentelemetry/common/macros.h"
  18. #include "opentelemetry/common/timestamp.h"
  19. #include "opentelemetry/context/context.h"
  20. #include "opentelemetry/exporters/memory/in_memory_span_data.h"
  21. #include "opentelemetry/exporters/memory/in_memory_span_exporter.h"
  22. #include "opentelemetry/nostd/shared_ptr.h"
  23. #include "opentelemetry/nostd/span.h"
  24. #include "opentelemetry/nostd/string_view.h"
  25. #include "opentelemetry/nostd/unique_ptr.h"
  26. #include "opentelemetry/nostd/variant.h"
  27. #include "opentelemetry/sdk/instrumentationscope/instrumentation_scope.h"
  28. #include "opentelemetry/sdk/instrumentationscope/scope_configurator.h"
  29. #include "opentelemetry/sdk/resource/resource.h"
  30. #include "opentelemetry/sdk/trace/exporter.h"
  31. #include "opentelemetry/sdk/trace/id_generator.h"
  32. #include "opentelemetry/sdk/trace/processor.h"
  33. #include "opentelemetry/sdk/trace/random_id_generator.h"
  34. #include "opentelemetry/sdk/trace/sampler.h"
  35. #include "opentelemetry/sdk/trace/samplers/always_off.h"
  36. #include "opentelemetry/sdk/trace/samplers/always_on.h"
  37. #include "opentelemetry/sdk/trace/samplers/parent.h"
  38. #include "opentelemetry/sdk/trace/simple_processor.h"
  39. #include "opentelemetry/sdk/trace/span_data.h"
  40. #include "opentelemetry/sdk/trace/tracer.h"
  41. #include "opentelemetry/sdk/trace/tracer_config.h"
  42. #include "opentelemetry/sdk/trace/tracer_context.h"
  43. #include "opentelemetry/trace/context.h"
  44. #include "opentelemetry/trace/noop.h"
  45. #include "opentelemetry/trace/scope.h"
  46. #include "opentelemetry/trace/span.h"
  47. #include "opentelemetry/trace/span_context.h"
  48. #include "opentelemetry/trace/span_context_kv_iterable.h"
  49. #include "opentelemetry/trace/span_id.h"
  50. #include "opentelemetry/trace/span_metadata.h"
  51. #include "opentelemetry/trace/span_startoptions.h"
  52. #include "opentelemetry/trace/trace_id.h"
  53. #include "opentelemetry/trace/trace_state.h"
  54. #include "opentelemetry/trace/tracer.h"
  55. using namespace opentelemetry::sdk::trace;
  56. using namespace opentelemetry::sdk::resource;
  57. using namespace opentelemetry::sdk::instrumentationscope;
  58. using opentelemetry::common::SteadyTimestamp;
  59. using opentelemetry::common::SystemTimestamp;
  60. namespace nostd = opentelemetry::nostd;
  61. namespace common = opentelemetry::common;
  62. namespace trace_api = opentelemetry::trace;
  63. using opentelemetry::exporter::memory::InMemorySpanData;
  64. using opentelemetry::exporter::memory::InMemorySpanExporter;
  65. using opentelemetry::trace::SpanContext;
  66. /**
  67. * A mock sampler with ShouldSample returning:
  68. * Decision::RECORD_AND_SAMPLE if trace_id is valid
  69. * Decision::DROP otherwise.
  70. */
  71. class MockSampler final : public Sampler
  72. {
  73. public:
  74. SamplingResult ShouldSample(
  75. const SpanContext & /*parent_context*/,
  76. trace_api::TraceId trace_id,
  77. nostd::string_view /*name*/,
  78. trace_api::SpanKind /*span_kind*/,
  79. const opentelemetry::common::KeyValueIterable & /*attributes*/,
  80. const opentelemetry::trace::SpanContextKeyValueIterable & /*links*/) noexcept override
  81. {
  82. // Sample only if valid trace_id ( This is to test Sampler get's valid trace id)
  83. if (trace_id.IsValid())
  84. {
  85. // Return two pairs of attributes. These attributes should be added to the
  86. // span attributes
  87. return {Decision::RECORD_AND_SAMPLE,
  88. nostd::unique_ptr<const std::map<std::string, opentelemetry::common::AttributeValue>>(
  89. new const std::map<std::string, opentelemetry::common::AttributeValue>(
  90. {{"sampling_attr1", 123}, {"sampling_attr2", "string"}})),
  91. nostd::shared_ptr<opentelemetry::trace::TraceState>(nullptr)};
  92. }
  93. else
  94. {
  95. // we should never reach here
  96. assert(false);
  97. return {Decision::DROP,
  98. nostd::unique_ptr<const std::map<std::string, opentelemetry::common::AttributeValue>>(
  99. nullptr),
  100. nostd::shared_ptr<opentelemetry::trace::TraceState>(nullptr)};
  101. }
  102. }
  103. nostd::string_view GetDescription() const noexcept override { return "MockSampler"; }
  104. };
  105. /**
  106. * A Mock Custom ID Generator
  107. */
  108. class MockIdGenerator : public IdGenerator
  109. {
  110. public:
  111. MockIdGenerator() : IdGenerator(false) {}
  112. opentelemetry::trace::SpanId GenerateSpanId() noexcept override
  113. {
  114. return opentelemetry::trace::SpanId(buf_span);
  115. }
  116. opentelemetry::trace::TraceId GenerateTraceId() noexcept override
  117. {
  118. return opentelemetry::trace::TraceId(buf_trace);
  119. }
  120. uint8_t buf_span[8] = {1, 2, 3, 4, 5, 6, 7, 8};
  121. uint8_t buf_trace[16] = {1, 2, 3, 4, 5, 6, 7, 8, 8, 7, 6, 5, 4, 3, 2, 1};
  122. };
  123. namespace
  124. {
  125. std::shared_ptr<opentelemetry::trace::Tracer> initTracer(std::unique_ptr<SpanExporter> &&exporter)
  126. {
  127. auto processor = std::unique_ptr<SpanProcessor>(new SimpleSpanProcessor(std::move(exporter)));
  128. std::vector<std::unique_ptr<SpanProcessor>> processors;
  129. processors.push_back(std::move(processor));
  130. auto context = std::make_shared<TracerContext>(std::move(processors));
  131. return std::shared_ptr<opentelemetry::trace::Tracer>(new Tracer(context));
  132. }
  133. std::shared_ptr<opentelemetry::trace::Tracer> initTracer(
  134. std::unique_ptr<SpanExporter> &&exporter,
  135. // For testing, just shove a pointer over, we'll take it over.
  136. Sampler *sampler,
  137. IdGenerator *id_generator = new RandomIdGenerator,
  138. const ScopeConfigurator<TracerConfig> &tracer_configurator =
  139. ScopeConfigurator<TracerConfig>::Builder(TracerConfig::Default()).Build(),
  140. std::unique_ptr<InstrumentationScope> scope = InstrumentationScope::Create(""))
  141. {
  142. auto processor = std::unique_ptr<SpanProcessor>(new SimpleSpanProcessor(std::move(exporter)));
  143. std::vector<std::unique_ptr<SpanProcessor>> processors;
  144. processors.push_back(std::move(processor));
  145. auto resource = Resource::Create({});
  146. auto context = std::make_shared<TracerContext>(
  147. std::move(processors), resource, std::unique_ptr<Sampler>(sampler),
  148. std::unique_ptr<IdGenerator>(id_generator),
  149. std::make_unique<ScopeConfigurator<TracerConfig>>(tracer_configurator));
  150. return std::shared_ptr<opentelemetry::trace::Tracer>(new Tracer(context, std::move(scope)));
  151. }
  152. } // namespace
  153. TEST(Tracer, ToInMemorySpanExporter)
  154. {
  155. InMemorySpanExporter *exporter = new InMemorySpanExporter();
  156. std::shared_ptr<InMemorySpanData> span_data = exporter->GetData();
  157. auto tracer = initTracer(std::unique_ptr<SpanExporter>{exporter});
  158. auto span_first = tracer->StartSpan("span 1");
  159. auto scope_first = tracer->WithActiveSpan(span_first);
  160. auto span_second = tracer->StartSpan("span 2");
  161. ASSERT_EQ(0, span_data->GetSpans().size());
  162. span_second->End();
  163. auto span2 = span_data->GetSpans();
  164. ASSERT_EQ(1, span2.size());
  165. ASSERT_EQ("span 2", span2.at(0)->GetName());
  166. EXPECT_TRUE(span2.at(0)->GetTraceId().IsValid());
  167. EXPECT_TRUE(span2.at(0)->GetSpanId().IsValid());
  168. EXPECT_TRUE(span2.at(0)->GetParentSpanId().IsValid());
  169. span_first->End();
  170. auto span1 = span_data->GetSpans();
  171. ASSERT_EQ(1, span1.size());
  172. ASSERT_EQ("span 1", span1.at(0)->GetName());
  173. EXPECT_TRUE(span1.at(0)->GetTraceId().IsValid());
  174. EXPECT_TRUE(span1.at(0)->GetSpanId().IsValid());
  175. EXPECT_FALSE(span1.at(0)->GetParentSpanId().IsValid());
  176. // Verify trace and parent span id propagation
  177. EXPECT_EQ(span1.at(0)->GetTraceId(), span2.at(0)->GetTraceId());
  178. EXPECT_EQ(span2.at(0)->GetParentSpanId(), span1.at(0)->GetSpanId());
  179. }
  180. TEST(Tracer, StartSpanSampleOn)
  181. {
  182. InMemorySpanExporter *exporter = new InMemorySpanExporter();
  183. std::shared_ptr<InMemorySpanData> span_data = exporter->GetData();
  184. auto tracer_on = initTracer(std::unique_ptr<SpanExporter>{exporter});
  185. tracer_on->StartSpan("span 1")->End();
  186. auto spans = span_data->GetSpans();
  187. ASSERT_EQ(1, spans.size());
  188. auto &cur_span_data = spans.at(0);
  189. ASSERT_LT(std::chrono::nanoseconds(0), cur_span_data->GetStartTime().time_since_epoch());
  190. ASSERT_LT(std::chrono::nanoseconds(0), cur_span_data->GetDuration());
  191. }
  192. TEST(Tracer, StartSpanSampleOff)
  193. {
  194. InMemorySpanExporter *exporter = new InMemorySpanExporter();
  195. std::shared_ptr<InMemorySpanData> span_data = exporter->GetData();
  196. auto tracer_off = initTracer(std::unique_ptr<SpanExporter>{exporter}, new AlwaysOffSampler());
  197. // This span will not be recorded.
  198. auto span = tracer_off->StartSpan("span 2");
  199. // Always generate a valid span-context (span-id)
  200. auto context = span->GetContext();
  201. EXPECT_TRUE(context.IsValid());
  202. EXPECT_FALSE(context.IsSampled());
  203. span->End();
  204. // The span doesn't write any span data because the sampling decision is alway
  205. // DROP.
  206. ASSERT_EQ(0, span_data->GetSpans().size());
  207. }
  208. TEST(Tracer, StartSpanCustomIdGenerator)
  209. {
  210. IdGenerator *id_generator = new MockIdGenerator();
  211. InMemorySpanExporter *exporter = new InMemorySpanExporter();
  212. std::shared_ptr<InMemorySpanData> span_data = exporter->GetData();
  213. auto tracer =
  214. initTracer(std::unique_ptr<SpanExporter>{exporter}, new AlwaysOnSampler(), id_generator);
  215. tracer->StartSpan("span 1")->End();
  216. auto spans = span_data->GetSpans();
  217. auto &cur_span_data = spans.at(0);
  218. EXPECT_EQ(cur_span_data->GetTraceId(), id_generator->GenerateTraceId());
  219. EXPECT_EQ(cur_span_data->GetSpanId(), id_generator->GenerateSpanId());
  220. }
  221. TEST(Tracer, StartSpanWithOptionsTime)
  222. {
  223. InMemorySpanExporter *exporter = new InMemorySpanExporter();
  224. std::shared_ptr<InMemorySpanData> span_data = exporter->GetData();
  225. auto tracer = initTracer(std::unique_ptr<SpanExporter>{exporter});
  226. opentelemetry::trace::StartSpanOptions start;
  227. start.start_system_time = SystemTimestamp(std::chrono::nanoseconds(300));
  228. start.start_steady_time = SteadyTimestamp(std::chrono::nanoseconds(10));
  229. opentelemetry::trace::EndSpanOptions end;
  230. end.end_steady_time = SteadyTimestamp(std::chrono::nanoseconds(40));
  231. tracer->StartSpan("span 1", start)->End(end);
  232. auto spans = span_data->GetSpans();
  233. ASSERT_EQ(1, spans.size());
  234. auto &cur_span_data = spans.at(0);
  235. ASSERT_EQ(std::chrono::nanoseconds(300), cur_span_data->GetStartTime().time_since_epoch());
  236. ASSERT_EQ(std::chrono::nanoseconds(30), cur_span_data->GetDuration());
  237. }
  238. TEST(Tracer, StartSpanWithAttributes)
  239. {
  240. InMemorySpanExporter *exporter = new InMemorySpanExporter();
  241. std::shared_ptr<InMemorySpanData> span_data = exporter->GetData();
  242. auto tracer = initTracer(std::unique_ptr<SpanExporter>{exporter});
  243. // Start a span with all supported scalar attribute types.
  244. tracer
  245. ->StartSpan("span 1", {{"attr1", "string"},
  246. {"attr2", false},
  247. {"attr1", 314159},
  248. {"attr3", static_cast<unsigned int>(314159)},
  249. {"attr4", static_cast<int32_t>(-20)},
  250. {"attr5", static_cast<uint32_t>(20)},
  251. {"attr6", static_cast<int64_t>(-20)},
  252. {"attr7", static_cast<uint64_t>(20)},
  253. {"attr8", 3.1},
  254. {"attr9", "string"}})
  255. ->End();
  256. // Start a span with all supported array attribute types.
  257. int listInt[] = {1, 2, 3};
  258. unsigned int listUInt[] = {1, 2, 3};
  259. int32_t listInt32[] = {1, -2, 3};
  260. uint32_t listUInt32[] = {1, 2, 3};
  261. int64_t listInt64[] = {1, -2, 3};
  262. uint64_t listUInt64[] = {1, 2, 3};
  263. double listDouble[] = {1.1, 2.1, 3.1};
  264. bool listBool[] = {true, false};
  265. nostd::string_view listStringView[] = {"a", "b"};
  266. std::map<std::string, common::AttributeValue> m;
  267. m["attr1"] = nostd::span<int>(listInt);
  268. m["attr2"] = nostd::span<unsigned int>(listUInt);
  269. m["attr3"] = nostd::span<int32_t>(listInt32);
  270. m["attr4"] = nostd::span<uint32_t>(listUInt32);
  271. m["attr5"] = nostd::span<int64_t>(listInt64);
  272. m["attr6"] = nostd::span<uint64_t>(listUInt64);
  273. m["attr7"] = nostd::span<double>(listDouble);
  274. m["attr8"] = nostd::span<bool>(listBool);
  275. m["attr9"] = nostd::span<nostd::string_view>(listStringView);
  276. tracer->StartSpan("span 2", m)->End();
  277. auto spans = span_data->GetSpans();
  278. ASSERT_EQ(2, spans.size());
  279. auto &cur_span_data = spans.at(0);
  280. ASSERT_EQ(9, cur_span_data->GetAttributes().size());
  281. ASSERT_EQ(314159, nostd::get<int32_t>(cur_span_data->GetAttributes().at("attr1")));
  282. ASSERT_EQ(false, nostd::get<bool>(cur_span_data->GetAttributes().at("attr2")));
  283. ASSERT_EQ(static_cast<uint32_t>(314159),
  284. nostd::get<uint32_t>(cur_span_data->GetAttributes().at("attr3")));
  285. ASSERT_EQ(-20, nostd::get<int32_t>(cur_span_data->GetAttributes().at("attr4")));
  286. ASSERT_EQ(static_cast<uint32_t>(20),
  287. nostd::get<uint32_t>(cur_span_data->GetAttributes().at("attr5")));
  288. ASSERT_EQ(-20, nostd::get<int64_t>(cur_span_data->GetAttributes().at("attr6")));
  289. ASSERT_EQ(static_cast<uint64_t>(20),
  290. nostd::get<uint64_t>(cur_span_data->GetAttributes().at("attr7")));
  291. ASSERT_EQ(3.1, nostd::get<double>(cur_span_data->GetAttributes().at("attr8")));
  292. ASSERT_EQ("string", nostd::get<std::string>(cur_span_data->GetAttributes().at("attr9")));
  293. auto &cur_span_data2 = spans.at(1);
  294. ASSERT_EQ(9, cur_span_data2->GetAttributes().size());
  295. ASSERT_EQ(std::vector<int32_t>({1, 2, 3}),
  296. nostd::get<std::vector<int32_t>>(cur_span_data2->GetAttributes().at("attr1")));
  297. ASSERT_EQ(std::vector<uint32_t>({1, 2, 3}),
  298. nostd::get<std::vector<uint32_t>>(cur_span_data2->GetAttributes().at("attr2")));
  299. ASSERT_EQ(std::vector<int32_t>({1, -2, 3}),
  300. nostd::get<std::vector<int32_t>>(cur_span_data2->GetAttributes().at("attr3")));
  301. ASSERT_EQ(std::vector<uint32_t>({1, 2, 3}),
  302. nostd::get<std::vector<uint32_t>>(cur_span_data2->GetAttributes().at("attr4")));
  303. ASSERT_EQ(std::vector<int64_t>({1, -2, 3}),
  304. nostd::get<std::vector<int64_t>>(cur_span_data2->GetAttributes().at("attr5")));
  305. ASSERT_EQ(std::vector<uint64_t>({1, 2, 3}),
  306. nostd::get<std::vector<uint64_t>>(cur_span_data2->GetAttributes().at("attr6")));
  307. ASSERT_EQ(std::vector<double>({1.1, 2.1, 3.1}),
  308. nostd::get<std::vector<double>>(cur_span_data2->GetAttributes().at("attr7")));
  309. ASSERT_EQ(std::vector<bool>({true, false}),
  310. nostd::get<std::vector<bool>>(cur_span_data2->GetAttributes().at("attr8")));
  311. ASSERT_EQ(std::vector<std::string>({"a", "b"}),
  312. nostd::get<std::vector<std::string>>(cur_span_data2->GetAttributes().at("attr9")));
  313. }
  314. TEST(Tracer, StartSpanWithAttributesCopy)
  315. {
  316. InMemorySpanExporter *exporter = new InMemorySpanExporter();
  317. std::shared_ptr<InMemorySpanData> span_data = exporter->GetData();
  318. auto tracer = initTracer(std::unique_ptr<SpanExporter>{exporter});
  319. {
  320. std::unique_ptr<std::vector<int64_t>> numbers(new std::vector<int64_t>);
  321. numbers->push_back(1);
  322. numbers->push_back(2);
  323. numbers->push_back(3);
  324. std::unique_ptr<std::vector<nostd::string_view>> strings(new std::vector<nostd::string_view>);
  325. std::string s1("a");
  326. std::string s2("b");
  327. std::string s3("c");
  328. strings->push_back(s1);
  329. strings->push_back(s2);
  330. strings->push_back(s3);
  331. tracer
  332. ->StartSpan("span 1",
  333. {{"attr1", *numbers}, {"attr2", nostd::span<nostd::string_view>(*strings)}})
  334. ->End();
  335. }
  336. auto spans = span_data->GetSpans();
  337. ASSERT_EQ(1, spans.size());
  338. auto &cur_span_data = spans.at(0);
  339. ASSERT_EQ(2, cur_span_data->GetAttributes().size());
  340. auto numbers = nostd::get<std::vector<int64_t>>(cur_span_data->GetAttributes().at("attr1"));
  341. ASSERT_EQ(3, numbers.size());
  342. ASSERT_EQ(1, numbers[0]);
  343. ASSERT_EQ(2, numbers[1]);
  344. ASSERT_EQ(3, numbers[2]);
  345. auto strings = nostd::get<std::vector<std::string>>(cur_span_data->GetAttributes().at("attr2"));
  346. ASSERT_EQ(3, strings.size());
  347. ASSERT_EQ("a", strings[0]);
  348. ASSERT_EQ("b", strings[1]);
  349. ASSERT_EQ("c", strings[2]);
  350. }
  351. TEST(Tracer, GetSampler)
  352. {
  353. auto resource = Resource::Create({});
  354. // Create a Tracer with a default AlwaysOnSampler
  355. auto tracer_on = initTracer(nullptr);
  356. #ifdef OPENTELEMETRY_RTTI_ENABLED
  357. auto &t1 = std::dynamic_pointer_cast<Tracer>(tracer_on)->GetSampler();
  358. #else
  359. auto &t1 = std::static_pointer_cast<Tracer>(tracer_on)->GetSampler();
  360. #endif
  361. ASSERT_EQ("AlwaysOnSampler", t1.GetDescription());
  362. // Create a Tracer with a AlwaysOffSampler
  363. auto tracer_off = initTracer(nullptr, new AlwaysOffSampler());
  364. #ifdef OPENTELEMETRY_RTTI_ENABLED
  365. auto &t2 = std::dynamic_pointer_cast<Tracer>(tracer_off)->GetSampler();
  366. #else
  367. auto &t2 = std::static_pointer_cast<Tracer>(tracer_off)->GetSampler();
  368. #endif
  369. ASSERT_EQ("AlwaysOffSampler", t2.GetDescription());
  370. }
  371. TEST(Tracer, SpanSetAttribute)
  372. {
  373. InMemorySpanExporter *exporter = new InMemorySpanExporter();
  374. std::shared_ptr<InMemorySpanData> span_data = exporter->GetData();
  375. auto tracer = initTracer(std::unique_ptr<SpanExporter>{exporter});
  376. auto span = tracer->StartSpan("span 1");
  377. span->SetAttribute("abc", 3.1);
  378. span->End();
  379. auto spans = span_data->GetSpans();
  380. ASSERT_EQ(1, spans.size());
  381. auto &cur_span_data = spans.at(0);
  382. ASSERT_EQ(3.1, nostd::get<double>(cur_span_data->GetAttributes().at("abc")));
  383. }
  384. TEST(Tracer, TestAfterEnd)
  385. {
  386. InMemorySpanExporter *exporter = new InMemorySpanExporter();
  387. std::shared_ptr<InMemorySpanData> span_data = exporter->GetData();
  388. auto tracer = initTracer(std::unique_ptr<SpanExporter>{exporter});
  389. auto span = tracer->StartSpan("span 1");
  390. span->SetAttribute("abc", 3.1);
  391. span->End();
  392. // test after end
  393. span->SetAttribute("testing null recordable", 3.1);
  394. span->AddEvent("event 1");
  395. span->AddEvent("event 2", std::chrono::system_clock::now());
  396. span->AddEvent("event 3", std::chrono::system_clock::now(), {{"attr1", 1}});
  397. std::string new_name{"new name"};
  398. span->UpdateName(new_name);
  399. span->SetAttribute("attr1", 3.1);
  400. std::string description{"description"};
  401. span->SetStatus(opentelemetry::trace::StatusCode::kError, description);
  402. span->End();
  403. auto spans = span_data->GetSpans();
  404. ASSERT_EQ(1, spans.size());
  405. auto &cur_span_data = spans.at(0);
  406. ASSERT_EQ(3.1, nostd::get<double>(cur_span_data->GetAttributes().at("abc")));
  407. }
  408. TEST(Tracer, SpanSetEvents)
  409. {
  410. InMemorySpanExporter *exporter = new InMemorySpanExporter();
  411. std::shared_ptr<InMemorySpanData> span_data = exporter->GetData();
  412. auto tracer = initTracer(std::unique_ptr<SpanExporter>{exporter});
  413. auto span = tracer->StartSpan("span 1");
  414. span->AddEvent("event 1");
  415. span->AddEvent("event 2", std::chrono::system_clock::now());
  416. span->AddEvent("event 3", std::chrono::system_clock::now(), {{"attr1", 1}});
  417. span->End();
  418. auto spans = span_data->GetSpans();
  419. ASSERT_EQ(1, spans.size());
  420. auto &span_data_events = spans.at(0)->GetEvents();
  421. ASSERT_EQ(3, span_data_events.size());
  422. ASSERT_EQ("event 1", span_data_events[0].GetName());
  423. ASSERT_EQ("event 2", span_data_events[1].GetName());
  424. ASSERT_EQ("event 3", span_data_events[2].GetName());
  425. ASSERT_EQ(0, span_data_events[0].GetAttributes().size());
  426. ASSERT_EQ(0, span_data_events[1].GetAttributes().size());
  427. ASSERT_EQ(1, span_data_events[2].GetAttributes().size());
  428. }
  429. TEST(Tracer, StartSpanWithDisabledConfig)
  430. {
  431. InMemorySpanExporter *exporter = new InMemorySpanExporter();
  432. std::shared_ptr<InMemorySpanData> span_data = exporter->GetData();
  433. ScopeConfigurator<TracerConfig> disable_tracer =
  434. ScopeConfigurator<TracerConfig>::Builder(TracerConfig::Disabled()).Build();
  435. auto tracer = initTracer(std::unique_ptr<SpanExporter>{exporter}, new AlwaysOnSampler(),
  436. new RandomIdGenerator(), disable_tracer);
  437. auto span = tracer->StartSpan("span 1");
  438. std::shared_ptr<opentelemetry::trace::Tracer> noop_tracer =
  439. std::make_shared<opentelemetry::trace::NoopTracer>();
  440. auto noop_span = noop_tracer->StartSpan("noop");
  441. EXPECT_TRUE(span.get() == noop_span.get());
  442. #if OPENTELEMETRY_ABI_VERSION_NO >= 2
  443. EXPECT_FALSE(noop_tracer->Enabled());
  444. EXPECT_FALSE(tracer->Enabled());
  445. #endif
  446. }
  447. TEST(Tracer, StartSpanWithEnabledConfig)
  448. {
  449. InMemorySpanExporter *exporter = new InMemorySpanExporter();
  450. std::shared_ptr<InMemorySpanData> span_data = exporter->GetData();
  451. ScopeConfigurator<TracerConfig> enable_tracer =
  452. ScopeConfigurator<TracerConfig>::Builder(TracerConfig::Enabled()).Build();
  453. auto tracer = initTracer(std::unique_ptr<SpanExporter>{exporter}, new AlwaysOnSampler(),
  454. new RandomIdGenerator(), enable_tracer);
  455. auto span = tracer->StartSpan("span 1");
  456. std::shared_ptr<opentelemetry::trace::Tracer> noop_tracer =
  457. std::make_shared<opentelemetry::trace::NoopTracer>();
  458. auto noop_span = noop_tracer->StartSpan("noop");
  459. EXPECT_FALSE(span.get() == noop_span.get());
  460. #if OPENTELEMETRY_ABI_VERSION_NO >= 2
  461. EXPECT_FALSE(noop_tracer->Enabled());
  462. EXPECT_TRUE(tracer->Enabled());
  463. #endif
  464. }
  465. TEST(Tracer, StartSpanWithCustomConfig)
  466. {
  467. std::shared_ptr<opentelemetry::trace::Tracer> noop_tracer =
  468. std::make_shared<opentelemetry::trace::NoopTracer>();
  469. auto noop_span = noop_tracer->StartSpan("noop");
  470. auto check_if_version_present = [](const InstrumentationScope &scope_info) {
  471. return !scope_info.GetVersion().empty();
  472. };
  473. ScopeConfigurator<TracerConfig> custom_configurator =
  474. ScopeConfigurator<TracerConfig>::Builder(TracerConfig::Enabled())
  475. .AddCondition(check_if_version_present, TracerConfig::Enabled())
  476. .AddConditionNameEquals("foo_library", TracerConfig::Disabled())
  477. .AddConditionNameEquals("", TracerConfig::Disabled())
  478. .Build();
  479. const auto tracer_default_scope =
  480. initTracer(std::unique_ptr<SpanExporter>{new InMemorySpanExporter()}, new AlwaysOnSampler(),
  481. new RandomIdGenerator(), custom_configurator);
  482. const auto span_default_scope = tracer_default_scope->StartSpan("span 1");
  483. EXPECT_TRUE(span_default_scope == noop_span);
  484. auto foo_scope = InstrumentationScope::Create("foo_library");
  485. const auto tracer_foo_scope =
  486. initTracer(std::unique_ptr<SpanExporter>{new InMemorySpanExporter()}, new AlwaysOnSampler(),
  487. new RandomIdGenerator(), custom_configurator, std::move(foo_scope));
  488. const auto span_foo_scope = tracer_foo_scope->StartSpan("span 1");
  489. EXPECT_TRUE(span_foo_scope == noop_span);
  490. auto foo_scope_with_version = InstrumentationScope::Create("foo_library", "1.0.0");
  491. const auto tracer_foo_scope_with_version =
  492. initTracer(std::unique_ptr<SpanExporter>{new InMemorySpanExporter()}, new AlwaysOnSampler(),
  493. new RandomIdGenerator(), custom_configurator, std::move(foo_scope_with_version));
  494. const auto span_foo_scope_with_version = tracer_foo_scope_with_version->StartSpan("span 1");
  495. EXPECT_FALSE(span_foo_scope_with_version == noop_span);
  496. auto bar_scope = InstrumentationScope::Create("bar_library");
  497. auto tracer_bar_scope =
  498. initTracer(std::unique_ptr<SpanExporter>{new InMemorySpanExporter()}, new AlwaysOnSampler(),
  499. new RandomIdGenerator(), custom_configurator, std::move(bar_scope));
  500. auto span_bar_scope = tracer_bar_scope->StartSpan("span 1");
  501. EXPECT_FALSE(span_bar_scope == noop_span);
  502. #if OPENTELEMETRY_ABI_VERSION_NO >= 2
  503. EXPECT_FALSE(noop_tracer->Enabled());
  504. EXPECT_FALSE(tracer_default_scope->Enabled());
  505. EXPECT_FALSE(tracer_foo_scope->Enabled());
  506. EXPECT_TRUE(tracer_foo_scope_with_version->Enabled());
  507. EXPECT_TRUE(tracer_bar_scope->Enabled());
  508. #endif
  509. }
  510. TEST(Tracer, StartSpanWithCustomConfigDifferingConditionOrder)
  511. {
  512. std::shared_ptr<opentelemetry::trace::Tracer> noop_tracer =
  513. std::make_shared<opentelemetry::trace::NoopTracer>();
  514. auto noop_span = noop_tracer->StartSpan("noop");
  515. auto check_if_version_present = [](const InstrumentationScope &scope_info) {
  516. return !scope_info.GetVersion().empty();
  517. };
  518. // 2 configurators with same conditions, but different order
  519. ScopeConfigurator<TracerConfig> custom_configurator_1 =
  520. ScopeConfigurator<TracerConfig>::Builder(TracerConfig::Enabled())
  521. .AddCondition(check_if_version_present, TracerConfig::Enabled())
  522. .AddConditionNameEquals("foo_library", TracerConfig::Disabled())
  523. .Build();
  524. ScopeConfigurator<TracerConfig> custom_configurator_2 =
  525. ScopeConfigurator<TracerConfig>::Builder(TracerConfig::Enabled())
  526. .AddConditionNameEquals("foo_library", TracerConfig::Disabled())
  527. .AddCondition(check_if_version_present, TracerConfig::Enabled())
  528. .Build();
  529. auto foo_scope_with_version_1 = InstrumentationScope::Create("foo_library", "1.0.0");
  530. auto foo_scope_with_version_2 = InstrumentationScope::Create("foo_library", "1.0.0");
  531. const auto tracer_foo_scope_with_version_1 = initTracer(
  532. std::unique_ptr<SpanExporter>{new InMemorySpanExporter()}, new AlwaysOnSampler(),
  533. new RandomIdGenerator(), custom_configurator_1, std::move(foo_scope_with_version_1));
  534. const auto tracer_foo_scope_with_version_2 = initTracer(
  535. std::unique_ptr<SpanExporter>{new InMemorySpanExporter()}, new AlwaysOnSampler(),
  536. new RandomIdGenerator(), custom_configurator_2, std::move(foo_scope_with_version_2));
  537. // Custom configurator 1 evaluates version first and enables the tracer
  538. const auto span_foo_scope_with_version_1 = tracer_foo_scope_with_version_1->StartSpan("span 1");
  539. EXPECT_FALSE(span_foo_scope_with_version_1 == noop_span);
  540. // Custom configurator 2 evaluates the name first and therefore disables the tracer without
  541. // evaluating other condition
  542. const auto span_foo_scope_with_version_2 = tracer_foo_scope_with_version_2->StartSpan("span 1");
  543. EXPECT_TRUE(span_foo_scope_with_version_2 == noop_span);
  544. #if OPENTELEMETRY_ABI_VERSION_NO >= 2
  545. EXPECT_TRUE(tracer_foo_scope_with_version_1->Enabled());
  546. EXPECT_FALSE(tracer_foo_scope_with_version_2->Enabled());
  547. #endif
  548. }
  549. TEST(Tracer, SpanSetLinks)
  550. {
  551. InMemorySpanExporter *exporter = new InMemorySpanExporter();
  552. std::shared_ptr<InMemorySpanData> span_data = exporter->GetData();
  553. auto tracer = initTracer(std::unique_ptr<SpanExporter>{exporter});
  554. {
  555. // Single span link passed through Initialization list
  556. tracer->StartSpan("efg", {{"attr1", 1}}, {{SpanContext(false, false), {{"attr2", 2}}}})->End();
  557. auto spans = span_data->GetSpans();
  558. ASSERT_EQ(1, spans.size());
  559. auto &span_data_links = spans.at(0)->GetLinks();
  560. ASSERT_EQ(1, span_data_links.size());
  561. auto link = span_data_links.at(0);
  562. ASSERT_EQ(nostd::get<int>(link.GetAttributes().at("attr2")), 2);
  563. }
  564. {
  565. // Multiple span links passed through Initialization list
  566. tracer
  567. ->StartSpan("efg", {{"attr1", 1}},
  568. {{SpanContext(false, false), {{"attr2", 2}}},
  569. {SpanContext(false, false), {{"attr3", 3}}}})
  570. ->End();
  571. auto spans = span_data->GetSpans();
  572. ASSERT_EQ(1, spans.size());
  573. auto &span_data_links = spans.at(0)->GetLinks();
  574. ASSERT_EQ(2, span_data_links.size());
  575. auto link1 = span_data_links.at(0);
  576. ASSERT_EQ(nostd::get<int>(link1.GetAttributes().at("attr2")), 2);
  577. auto link2 = span_data_links.at(1);
  578. ASSERT_EQ(nostd::get<int>(link2.GetAttributes().at("attr3")), 3);
  579. }
  580. {
  581. // Multiple links, each with multiple attributes passed through Initialization list
  582. tracer
  583. ->StartSpan("efg", {{"attr1", 1}},
  584. {{SpanContext(false, false), {{"attr2", 2}, {"attr3", 3}}},
  585. {SpanContext(false, false), {{"attr4", 4}}}})
  586. ->End();
  587. auto spans = span_data->GetSpans();
  588. ASSERT_EQ(1, spans.size());
  589. auto &span_data_links = spans.at(0)->GetLinks();
  590. ASSERT_EQ(2, span_data_links.size());
  591. auto link1 = span_data_links.at(0);
  592. ASSERT_EQ(nostd::get<int>(link1.GetAttributes().at("attr2")), 2);
  593. ASSERT_EQ(nostd::get<int>(link1.GetAttributes().at("attr3")), 3);
  594. auto link2 = span_data_links.at(1);
  595. ASSERT_EQ(nostd::get<int>(link2.GetAttributes().at("attr4")), 4);
  596. }
  597. {
  598. std::map<std::string, std::string> attrs1 = {{"attr1", "1"}, {"attr2", "2"}};
  599. std::map<std::string, std::string> attrs2 = {{"attr3", "3"}, {"attr4", "4"}};
  600. std::vector<std::pair<SpanContext, std::map<std::string, std::string>>> links = {
  601. {SpanContext(false, false), attrs1}, {SpanContext(false, false), attrs2}};
  602. tracer->StartSpan("efg", attrs1, links)->End();
  603. auto spans = span_data->GetSpans();
  604. auto &span_data_links = spans.at(0)->GetLinks();
  605. ASSERT_EQ(2, span_data_links.size());
  606. auto link1 = span_data_links.at(0);
  607. ASSERT_EQ(nostd::get<std::string>(link1.GetAttributes().at("attr1")), "1");
  608. ASSERT_EQ(nostd::get<std::string>(link1.GetAttributes().at("attr2")), "2");
  609. auto link2 = span_data_links.at(1);
  610. ASSERT_EQ(nostd::get<std::string>(link2.GetAttributes().at("attr3")), "3");
  611. ASSERT_EQ(nostd::get<std::string>(link2.GetAttributes().at("attr4")), "4");
  612. }
  613. }
  614. #if OPENTELEMETRY_ABI_VERSION_NO >= 2
  615. TEST(Tracer, SpanAddLinkAbiv2)
  616. {
  617. InMemorySpanExporter *exporter = new InMemorySpanExporter();
  618. std::shared_ptr<InMemorySpanData> span_data = exporter->GetData();
  619. auto tracer = initTracer(std::unique_ptr<SpanExporter>{exporter});
  620. {
  621. auto span = tracer->StartSpan("span");
  622. SpanContext target(false, false);
  623. // Single link attribute passed through Initialization list
  624. span->AddLink(target, {{"attr2", 2}});
  625. span->End();
  626. auto spans = span_data->GetSpans();
  627. ASSERT_EQ(1, spans.size());
  628. auto &span_data_links = spans.at(0)->GetLinks();
  629. ASSERT_EQ(1, span_data_links.size());
  630. auto link = span_data_links.at(0);
  631. auto attrs = link.GetAttributes();
  632. ASSERT_EQ(nostd::get<int>(attrs.at("attr2")), 2);
  633. }
  634. {
  635. auto span = tracer->StartSpan("span");
  636. SpanContext target(false, false);
  637. // Multiple link attributes passed through Initialization list
  638. span->AddLink(target, {{"attr2", 2}, {"attr3", 3}});
  639. span->End();
  640. auto spans = span_data->GetSpans();
  641. ASSERT_EQ(1, spans.size());
  642. auto &span_data_links = spans.at(0)->GetLinks();
  643. ASSERT_EQ(1, span_data_links.size());
  644. auto link = span_data_links.at(0);
  645. auto attrs = link.GetAttributes();
  646. ASSERT_EQ(nostd::get<int>(attrs.at("attr2")), 2);
  647. ASSERT_EQ(nostd::get<int>(attrs.at("attr3")), 3);
  648. }
  649. {
  650. std::map<std::string, std::string> attrs_map = {{"attr1", "1"}, {"attr2", "2"}};
  651. auto span = tracer->StartSpan("span");
  652. SpanContext target(false, false);
  653. span->AddLink(target, attrs_map);
  654. span->End();
  655. auto spans = span_data->GetSpans();
  656. auto &span_data_links = spans.at(0)->GetLinks();
  657. ASSERT_EQ(1, span_data_links.size());
  658. auto link = span_data_links.at(0);
  659. auto attrs = link.GetAttributes();
  660. ASSERT_EQ(nostd::get<std::string>(attrs.at("attr1")), "1");
  661. ASSERT_EQ(nostd::get<std::string>(attrs.at("attr2")), "2");
  662. }
  663. {
  664. auto span = tracer->StartSpan("span");
  665. SpanContext target(false, false);
  666. // Single link attribute passed through Initialization list
  667. span->AddLink(target, {{"attr1", 1}});
  668. // Multiple link attributes passed through Initialization list
  669. span->AddLink(target, {{"attr2", 2}, {"attr3", 3}});
  670. std::map<std::string, std::string> attrs_map = {{"attr4", "4"}, {"attr5", "5"}};
  671. span->AddLink(target, attrs_map);
  672. span->End();
  673. auto spans = span_data->GetSpans();
  674. ASSERT_EQ(1, spans.size());
  675. auto &span_data_links = spans.at(0)->GetLinks();
  676. ASSERT_EQ(3, span_data_links.size());
  677. {
  678. auto link = span_data_links.at(0);
  679. auto attrs = link.GetAttributes();
  680. ASSERT_EQ(attrs.size(), 1);
  681. ASSERT_EQ(nostd::get<int>(attrs.at("attr1")), 1);
  682. }
  683. {
  684. auto link = span_data_links.at(1);
  685. auto attrs = link.GetAttributes();
  686. ASSERT_EQ(attrs.size(), 2);
  687. ASSERT_EQ(nostd::get<int>(attrs.at("attr2")), 2);
  688. ASSERT_EQ(nostd::get<int>(attrs.at("attr3")), 3);
  689. }
  690. {
  691. auto link = span_data_links.at(2);
  692. auto attrs = link.GetAttributes();
  693. ASSERT_EQ(attrs.size(), 2);
  694. ASSERT_EQ(nostd::get<std::string>(attrs.at("attr4")), "4");
  695. ASSERT_EQ(nostd::get<std::string>(attrs.at("attr5")), "5");
  696. }
  697. }
  698. }
  699. TEST(Tracer, SpanAddLinksAbiv2)
  700. {
  701. InMemorySpanExporter *exporter = new InMemorySpanExporter();
  702. std::shared_ptr<InMemorySpanData> span_data = exporter->GetData();
  703. auto tracer = initTracer(std::unique_ptr<SpanExporter>{exporter});
  704. {
  705. auto span = tracer->StartSpan("span");
  706. // Single span link passed through Initialization list
  707. span->AddLinks({{SpanContext(false, false), {{"attr2", 2}}}});
  708. span->End();
  709. auto spans = span_data->GetSpans();
  710. ASSERT_EQ(1, spans.size());
  711. auto &span_data_links = spans.at(0)->GetLinks();
  712. ASSERT_EQ(1, span_data_links.size());
  713. auto link = span_data_links.at(0);
  714. ASSERT_EQ(nostd::get<int>(link.GetAttributes().at("attr2")), 2);
  715. }
  716. {
  717. auto span = tracer->StartSpan("span");
  718. // Multiple span links passed through Initialization list
  719. span->AddLinks(
  720. {{SpanContext(false, false), {{"attr2", 2}}}, {SpanContext(false, false), {{"attr3", 3}}}});
  721. span->End();
  722. auto spans = span_data->GetSpans();
  723. ASSERT_EQ(1, spans.size());
  724. auto &span_data_links = spans.at(0)->GetLinks();
  725. ASSERT_EQ(2, span_data_links.size());
  726. auto link1 = span_data_links.at(0);
  727. ASSERT_EQ(nostd::get<int>(link1.GetAttributes().at("attr2")), 2);
  728. auto link2 = span_data_links.at(1);
  729. ASSERT_EQ(nostd::get<int>(link2.GetAttributes().at("attr3")), 3);
  730. }
  731. {
  732. auto span = tracer->StartSpan("span");
  733. // Multiple links, each with multiple attributes passed through Initialization list
  734. span->AddLinks({{SpanContext(false, false), {{"attr2", 2}, {"attr3", 3}}},
  735. {SpanContext(false, false), {{"attr4", 4}}}});
  736. span->End();
  737. auto spans = span_data->GetSpans();
  738. ASSERT_EQ(1, spans.size());
  739. auto &span_data_links = spans.at(0)->GetLinks();
  740. ASSERT_EQ(2, span_data_links.size());
  741. auto link1 = span_data_links.at(0);
  742. ASSERT_EQ(nostd::get<int>(link1.GetAttributes().at("attr2")), 2);
  743. ASSERT_EQ(nostd::get<int>(link1.GetAttributes().at("attr3")), 3);
  744. auto link2 = span_data_links.at(1);
  745. ASSERT_EQ(nostd::get<int>(link2.GetAttributes().at("attr4")), 4);
  746. }
  747. {
  748. std::map<std::string, std::string> attrs1 = {{"attr1", "1"}, {"attr2", "2"}};
  749. std::map<std::string, std::string> attrs2 = {{"attr3", "3"}, {"attr4", "4"}};
  750. std::vector<std::pair<SpanContext, std::map<std::string, std::string>>> links = {
  751. {SpanContext(false, false), attrs1}, {SpanContext(false, false), attrs2}};
  752. auto span = tracer->StartSpan("span");
  753. span->AddLinks(links);
  754. span->End();
  755. auto spans = span_data->GetSpans();
  756. auto &span_data_links = spans.at(0)->GetLinks();
  757. ASSERT_EQ(2, span_data_links.size());
  758. auto link1 = span_data_links.at(0);
  759. ASSERT_EQ(nostd::get<std::string>(link1.GetAttributes().at("attr1")), "1");
  760. ASSERT_EQ(nostd::get<std::string>(link1.GetAttributes().at("attr2")), "2");
  761. auto link2 = span_data_links.at(1);
  762. ASSERT_EQ(nostd::get<std::string>(link2.GetAttributes().at("attr3")), "3");
  763. ASSERT_EQ(nostd::get<std::string>(link2.GetAttributes().at("attr4")), "4");
  764. }
  765. {
  766. auto span = tracer->StartSpan("span");
  767. // Single span link passed through Initialization list
  768. span->AddLinks({{SpanContext(false, false), {{"attr10", 10}}}});
  769. span->AddLinks({{SpanContext(false, false), {{"attr11", 11}}}});
  770. // Multiple span links passed through Initialization list
  771. span->AddLinks({{SpanContext(false, false), {{"attr12", 12}}},
  772. {SpanContext(false, false), {{"attr13", 13}}}});
  773. span->AddLinks({{SpanContext(false, false), {{"attr14", 14}}},
  774. {SpanContext(false, false), {{"attr15", 15}}}});
  775. // Multiple links, each with multiple attributes passed through Initialization list
  776. span->AddLinks({{SpanContext(false, false), {{"attr16", 16}, {"attr17", 17}}},
  777. {SpanContext(false, false), {{"attr18", 18}}}});
  778. span->AddLinks({{SpanContext(false, false), {{"attr19", 19}, {"attr20", 20}}},
  779. {SpanContext(false, false), {{"attr21", 21}}}});
  780. std::map<std::string, std::string> attrsa1 = {{"attra1", "1"}, {"attra2", "2"}};
  781. std::map<std::string, std::string> attrsa2 = {{"attra3", "3"}, {"attra4", "4"}};
  782. std::vector<std::pair<SpanContext, std::map<std::string, std::string>>> linksa = {
  783. {SpanContext(false, false), attrsa1}, {SpanContext(false, false), attrsa2}};
  784. span->AddLinks(linksa);
  785. std::map<std::string, std::string> attrsb1 = {{"attrb1", "1"}, {"attrb2", "2"}};
  786. std::map<std::string, std::string> attrsb2 = {{"attrb3", "3"}, {"attrb4", "4"}};
  787. std::vector<std::pair<SpanContext, std::map<std::string, std::string>>> linksb = {
  788. {SpanContext(false, false), attrsb1}, {SpanContext(false, false), attrsb2}};
  789. span->AddLinks(linksb);
  790. span->End();
  791. auto spans = span_data->GetSpans();
  792. ASSERT_EQ(1, spans.size());
  793. auto &span_data_links = spans.at(0)->GetLinks();
  794. ASSERT_EQ(14, span_data_links.size());
  795. {
  796. auto link = span_data_links.at(0);
  797. auto attrs = link.GetAttributes();
  798. ASSERT_EQ(attrs.size(), 1);
  799. ASSERT_EQ(nostd::get<int>(attrs.at("attr10")), 10);
  800. }
  801. {
  802. auto link = span_data_links.at(1);
  803. auto attrs = link.GetAttributes();
  804. ASSERT_EQ(attrs.size(), 1);
  805. ASSERT_EQ(nostd::get<int>(attrs.at("attr11")), 11);
  806. }
  807. {
  808. auto link = span_data_links.at(2);
  809. auto attrs = link.GetAttributes();
  810. ASSERT_EQ(attrs.size(), 1);
  811. ASSERT_EQ(nostd::get<int>(attrs.at("attr12")), 12);
  812. }
  813. {
  814. auto link = span_data_links.at(3);
  815. auto attrs = link.GetAttributes();
  816. ASSERT_EQ(attrs.size(), 1);
  817. ASSERT_EQ(nostd::get<int>(attrs.at("attr13")), 13);
  818. }
  819. {
  820. auto link = span_data_links.at(4);
  821. auto attrs = link.GetAttributes();
  822. ASSERT_EQ(attrs.size(), 1);
  823. ASSERT_EQ(nostd::get<int>(attrs.at("attr14")), 14);
  824. }
  825. {
  826. auto link = span_data_links.at(5);
  827. auto attrs = link.GetAttributes();
  828. ASSERT_EQ(attrs.size(), 1);
  829. ASSERT_EQ(nostd::get<int>(attrs.at("attr15")), 15);
  830. }
  831. {
  832. auto link = span_data_links.at(6);
  833. auto attrs = link.GetAttributes();
  834. ASSERT_EQ(attrs.size(), 2);
  835. ASSERT_EQ(nostd::get<int>(attrs.at("attr16")), 16);
  836. ASSERT_EQ(nostd::get<int>(attrs.at("attr17")), 17);
  837. }
  838. {
  839. auto link = span_data_links.at(7);
  840. auto attrs = link.GetAttributes();
  841. ASSERT_EQ(attrs.size(), 1);
  842. ASSERT_EQ(nostd::get<int>(attrs.at("attr18")), 18);
  843. }
  844. {
  845. auto link = span_data_links.at(8);
  846. auto attrs = link.GetAttributes();
  847. ASSERT_EQ(attrs.size(), 2);
  848. ASSERT_EQ(nostd::get<int>(attrs.at("attr19")), 19);
  849. ASSERT_EQ(nostd::get<int>(attrs.at("attr20")), 20);
  850. }
  851. {
  852. auto link = span_data_links.at(9);
  853. auto attrs = link.GetAttributes();
  854. ASSERT_EQ(attrs.size(), 1);
  855. ASSERT_EQ(nostd::get<int>(attrs.at("attr21")), 21);
  856. }
  857. {
  858. auto link = span_data_links.at(10);
  859. auto attrs = link.GetAttributes();
  860. ASSERT_EQ(attrs.size(), 2);
  861. ASSERT_EQ(nostd::get<std::string>(attrs.at("attra1")), "1");
  862. ASSERT_EQ(nostd::get<std::string>(attrs.at("attra2")), "2");
  863. }
  864. {
  865. auto link = span_data_links.at(11);
  866. auto attrs = link.GetAttributes();
  867. ASSERT_EQ(attrs.size(), 2);
  868. ASSERT_EQ(nostd::get<std::string>(attrs.at("attra3")), "3");
  869. ASSERT_EQ(nostd::get<std::string>(attrs.at("attra4")), "4");
  870. }
  871. {
  872. auto link = span_data_links.at(12);
  873. auto attrs = link.GetAttributes();
  874. ASSERT_EQ(attrs.size(), 2);
  875. ASSERT_EQ(nostd::get<std::string>(attrs.at("attrb1")), "1");
  876. ASSERT_EQ(nostd::get<std::string>(attrs.at("attrb2")), "2");
  877. }
  878. {
  879. auto link = span_data_links.at(13);
  880. auto attrs = link.GetAttributes();
  881. ASSERT_EQ(attrs.size(), 2);
  882. ASSERT_EQ(nostd::get<std::string>(attrs.at("attrb3")), "3");
  883. ASSERT_EQ(nostd::get<std::string>(attrs.at("attrb4")), "4");
  884. }
  885. }
  886. }
  887. TEST(Tracer, SpanMixLinksAbiv2)
  888. {
  889. InMemorySpanExporter *exporter = new InMemorySpanExporter();
  890. std::shared_ptr<InMemorySpanData> span_data = exporter->GetData();
  891. auto tracer = initTracer(std::unique_ptr<SpanExporter>{exporter});
  892. {
  893. // Link 1 added at StartSpan
  894. auto span =
  895. tracer->StartSpan("span", {{"attr1", 1}}, {{SpanContext(false, false), {{"attr2", 2}}}});
  896. SpanContext target(false, false);
  897. // Link 2 added with AddLink
  898. span->AddLink(target, {{"attr3", 3}});
  899. // Link 3 added with AddLinks
  900. span->AddLinks({{SpanContext(false, false), {{"attr4", 4}}}});
  901. span->End();
  902. auto spans = span_data->GetSpans();
  903. ASSERT_EQ(1, spans.size());
  904. auto &span_data_links = spans.at(0)->GetLinks();
  905. ASSERT_EQ(3, span_data_links.size());
  906. {
  907. auto link = span_data_links.at(0);
  908. auto attrs = link.GetAttributes();
  909. ASSERT_EQ(attrs.size(), 1);
  910. ASSERT_EQ(nostd::get<int>(attrs.at("attr2")), 2);
  911. }
  912. {
  913. auto link = span_data_links.at(1);
  914. auto attrs = link.GetAttributes();
  915. ASSERT_EQ(attrs.size(), 1);
  916. ASSERT_EQ(nostd::get<int>(attrs.at("attr3")), 3);
  917. }
  918. {
  919. auto link = span_data_links.at(2);
  920. auto attrs = link.GetAttributes();
  921. ASSERT_EQ(attrs.size(), 1);
  922. ASSERT_EQ(nostd::get<int>(attrs.at("attr4")), 4);
  923. }
  924. }
  925. }
  926. #endif /* OPENTELEMETRY_ABI_VERSION_NO >= 2 */
  927. TEST(Tracer, TestAlwaysOnSampler)
  928. {
  929. InMemorySpanExporter *exporter = new InMemorySpanExporter();
  930. std::shared_ptr<InMemorySpanData> span_data = exporter->GetData();
  931. auto tracer_on = initTracer(std::unique_ptr<SpanExporter>{exporter});
  932. // Testing AlwaysOn sampler.
  933. // Create two spans for each tracer. Check the exported result.
  934. auto span_on_1 = tracer_on->StartSpan("span 1");
  935. auto span_on_2 = tracer_on->StartSpan("span 2");
  936. span_on_2->End();
  937. span_on_1->End();
  938. auto spans = span_data->GetSpans();
  939. ASSERT_EQ(2, spans.size());
  940. ASSERT_EQ("span 2", spans.at(0)->GetName()); // span 2 ends first.
  941. ASSERT_EQ("span 1", spans.at(1)->GetName());
  942. }
  943. TEST(Tracer, TestAlwaysOffSampler)
  944. {
  945. InMemorySpanExporter *exporter = new InMemorySpanExporter();
  946. std::shared_ptr<InMemorySpanData> span_data = exporter->GetData();
  947. auto tracer_off = initTracer(std::unique_ptr<SpanExporter>{exporter}, new AlwaysOffSampler());
  948. auto span_off_1 = tracer_off->StartSpan("span 1");
  949. auto span_off_2 = tracer_off->StartSpan("span 2");
  950. span_off_1->SetAttribute("attr1", 3.1); // Not recorded.
  951. span_off_2->End();
  952. span_off_1->End();
  953. // The tracer export nothing with an AlwaysOff sampler
  954. ASSERT_EQ(0, span_data->GetSpans().size());
  955. }
  956. TEST(Tracer, TestParentBasedSampler)
  957. {
  958. // Current ShouldSample always pass an empty ParentContext,
  959. // so this sampler will work as an AlwaysOnSampler.
  960. InMemorySpanExporter *exporter = new InMemorySpanExporter();
  961. std::shared_ptr<InMemorySpanData> span_data_parent_on = exporter->GetData();
  962. auto tracer_parent_on = initTracer(std::unique_ptr<SpanExporter>{exporter},
  963. new ParentBasedSampler(std::make_shared<AlwaysOnSampler>()));
  964. auto span_parent_on_1 = tracer_parent_on->StartSpan("span 1");
  965. auto span_parent_on_2 = tracer_parent_on->StartSpan("span 2");
  966. span_parent_on_1->SetAttribute("attr1", 3.1);
  967. span_parent_on_2->End();
  968. span_parent_on_1->End();
  969. auto spans = span_data_parent_on->GetSpans();
  970. ASSERT_EQ(2, spans.size());
  971. ASSERT_EQ("span 2", spans.at(0)->GetName());
  972. ASSERT_EQ("span 1", spans.at(1)->GetName());
  973. // Current ShouldSample always pass an empty ParentContext,
  974. // so this sampler will work as an AlwaysOnSampler.
  975. InMemorySpanExporter *exporter2 = new InMemorySpanExporter();
  976. std::shared_ptr<InMemorySpanData> span_data_parent_off = exporter2->GetData();
  977. auto tracer_parent_off =
  978. initTracer(std::unique_ptr<SpanExporter>{exporter2},
  979. // Add this to avoid different results for old and new version of clang-format
  980. new ParentBasedSampler(std::make_shared<AlwaysOffSampler>()));
  981. auto span_parent_off_1 = tracer_parent_off->StartSpan("span 1");
  982. auto span_parent_off_2 = tracer_parent_off->StartSpan("span 2");
  983. span_parent_off_1->SetAttribute("attr1", 3.1);
  984. span_parent_off_1->End();
  985. span_parent_off_2->End();
  986. ASSERT_EQ(0, span_data_parent_off->GetSpans().size());
  987. }
  988. TEST(Tracer, WithActiveSpan)
  989. {
  990. InMemorySpanExporter *exporter = new InMemorySpanExporter();
  991. std::shared_ptr<InMemorySpanData> span_data = exporter->GetData();
  992. auto tracer = initTracer(std::unique_ptr<SpanExporter>{exporter});
  993. auto spans = span_data.get()->GetSpans();
  994. ASSERT_EQ(0, spans.size());
  995. {
  996. auto span_first = tracer->StartSpan("span 1");
  997. auto scope_first = tracer->WithActiveSpan(span_first);
  998. {
  999. auto span_second = tracer->StartSpan("span 2");
  1000. auto scope_second = tracer->WithActiveSpan(span_second);
  1001. spans = span_data->GetSpans();
  1002. ASSERT_EQ(0, spans.size());
  1003. span_second->End();
  1004. }
  1005. spans = span_data->GetSpans();
  1006. ASSERT_EQ(1, spans.size());
  1007. EXPECT_EQ("span 2", spans.at(0)->GetName());
  1008. EXPECT_EQ(spans.at(0).get()->GetParentSpanId(), span_first->GetContext().span_id());
  1009. EXPECT_EQ(spans.at(0).get()->GetTraceId(), span_first->GetContext().trace_id());
  1010. {
  1011. trace_api::StartSpanOptions options;
  1012. opentelemetry::context::Context c1;
  1013. c1 = c1.SetValue(opentelemetry::trace::kIsRootSpanKey, true);
  1014. options.parent = c1;
  1015. auto root_span = tracer->StartSpan("span root", options);
  1016. spans = span_data->GetSpans();
  1017. ASSERT_EQ(0, spans.size());
  1018. root_span->End();
  1019. }
  1020. spans = span_data->GetSpans();
  1021. ASSERT_EQ(1, spans.size());
  1022. EXPECT_EQ("span root", spans.at(0)->GetName());
  1023. EXPECT_EQ(spans.at(0).get()->GetParentSpanId(), opentelemetry::trace::SpanId());
  1024. EXPECT_NE(spans.at(0).get()->GetTraceId(), span_first->GetContext().trace_id());
  1025. span_first->End();
  1026. }
  1027. spans = span_data->GetSpans();
  1028. ASSERT_EQ(1, spans.size());
  1029. EXPECT_EQ("span 1", spans.at(0)->GetName());
  1030. }
  1031. TEST(Tracer, ExpectParent)
  1032. {
  1033. InMemorySpanExporter *exporter = new InMemorySpanExporter();
  1034. std::shared_ptr<InMemorySpanData> span_data = exporter->GetData();
  1035. auto tracer = initTracer(std::unique_ptr<SpanExporter>{exporter});
  1036. auto spans = span_data.get()->GetSpans();
  1037. ASSERT_EQ(0, spans.size());
  1038. auto span_first = tracer->StartSpan("span 1");
  1039. trace_api::StartSpanOptions options;
  1040. options.parent = span_first->GetContext();
  1041. auto span_second = tracer->StartSpan("span 2", options);
  1042. options.parent = span_second->GetContext();
  1043. auto span_third = tracer->StartSpan("span 3", options);
  1044. span_third->End();
  1045. span_second->End();
  1046. span_first->End();
  1047. spans = span_data->GetSpans();
  1048. ASSERT_EQ(3, spans.size());
  1049. auto spandata_first = std::move(spans.at(2));
  1050. auto spandata_second = std::move(spans.at(1));
  1051. auto spandata_third = std::move(spans.at(0));
  1052. EXPECT_EQ("span 1", spandata_first->GetName());
  1053. EXPECT_EQ("span 2", spandata_second->GetName());
  1054. EXPECT_EQ("span 3", spandata_third->GetName());
  1055. EXPECT_EQ(spandata_first->GetSpanId(), spandata_second->GetParentSpanId());
  1056. EXPECT_EQ(spandata_second->GetSpanId(), spandata_third->GetParentSpanId());
  1057. }
  1058. TEST(Tracer, ExpectParentAsContext)
  1059. {
  1060. InMemorySpanExporter *exporter = new InMemorySpanExporter();
  1061. std::shared_ptr<InMemorySpanData> span_data = exporter->GetData();
  1062. auto tracer = initTracer(std::unique_ptr<SpanExporter>{exporter});
  1063. auto spans = span_data.get()->GetSpans();
  1064. ASSERT_EQ(0, spans.size());
  1065. auto span_first = tracer->StartSpan("span 1");
  1066. opentelemetry::context::Context c1;
  1067. auto c2 = trace_api::SetSpan(c1, span_first);
  1068. trace_api::StartSpanOptions options;
  1069. options.parent = c2;
  1070. auto span_second = tracer->StartSpan("span 2", options);
  1071. auto c3 = trace_api::SetSpan(c2, span_second);
  1072. options.parent = c3;
  1073. auto span_third = tracer->StartSpan("span 3", options);
  1074. span_third->End();
  1075. span_second->End();
  1076. span_first->End();
  1077. spans = span_data->GetSpans();
  1078. ASSERT_EQ(3, spans.size());
  1079. auto spandata_first = std::move(spans.at(2));
  1080. auto spandata_second = std::move(spans.at(1));
  1081. auto spandata_third = std::move(spans.at(0));
  1082. EXPECT_EQ("span 1", spandata_first->GetName());
  1083. EXPECT_EQ("span 2", spandata_second->GetName());
  1084. EXPECT_EQ("span 3", spandata_third->GetName());
  1085. EXPECT_EQ(spandata_first->GetSpanId(), spandata_second->GetParentSpanId());
  1086. EXPECT_EQ(spandata_second->GetSpanId(), spandata_third->GetParentSpanId());
  1087. }
  1088. TEST(Tracer, ValidTraceIdToSampler)
  1089. {
  1090. InMemorySpanExporter *exporter = new InMemorySpanExporter();
  1091. std::shared_ptr<InMemorySpanData> span_data = exporter->GetData();
  1092. auto tracer = initTracer(std::unique_ptr<SpanExporter>{exporter});
  1093. auto span = tracer->StartSpan("span 1");
  1094. // sampler was fed with valid trace_id, so span shouldn't be NoOp Span.
  1095. EXPECT_TRUE(span->IsRecording());
  1096. EXPECT_TRUE(span->GetContext().IsValid());
  1097. }
  1098. TEST(Tracer, SpanCleanupWithScope)
  1099. {
  1100. InMemorySpanExporter *exporter = new InMemorySpanExporter();
  1101. std::shared_ptr<InMemorySpanData> span_data = exporter->GetData();
  1102. auto tracer = initTracer(std::unique_ptr<SpanExporter>{exporter}, new MockSampler());
  1103. {
  1104. auto span0 = tracer->StartSpan("Span0");
  1105. auto span1 = tracer->StartSpan("span1");
  1106. {
  1107. trace_api::Scope scope1(span1);
  1108. auto span2 = tracer->StartSpan("span2");
  1109. {
  1110. trace_api::Scope scope2(span2);
  1111. auto span3 = tracer->StartSpan("span3");
  1112. }
  1113. }
  1114. }
  1115. EXPECT_EQ(4, span_data->GetSpans().size());
  1116. }