| 1 | //===-- TraceTests.cpp - Tracing unit tests ---------------------*- C++ -*-===// |
| 2 | // |
| 3 | // Part of the LLVM Project, under the Apache License v2.0 with LLVM Exceptions. |
| 4 | // See https://llvm.org/LICENSE.txt for license information. |
| 5 | // SPDX-License-Identifier: Apache-2.0 WITH LLVM-exception |
| 6 | // |
| 7 | //===----------------------------------------------------------------------===// |
| 8 | |
| 9 | #include "TestTracer.h" |
| 10 | #include "support/Trace.h" |
| 11 | #include "llvm/ADT/SmallString.h" |
| 12 | #include "llvm/ADT/StringRef.h" |
| 13 | #include "llvm/Support/SourceMgr.h" |
| 14 | #include "llvm/Support/Threading.h" |
| 15 | #include "llvm/Support/YAMLParser.h" |
| 16 | #include "gmock/gmock.h" |
| 17 | #include "gtest/gtest.h" |
| 18 | |
| 19 | namespace clang { |
| 20 | namespace clangd { |
| 21 | namespace { |
| 22 | |
| 23 | using testing::_; |
| 24 | using testing::ElementsAre; |
| 25 | using testing::SizeIs; |
| 26 | using testing::StartsWith; |
| 27 | |
| 28 | MATCHER_P(stringNode, Val, "" ) { |
| 29 | if (arg->getType() != llvm::yaml::Node::NK_Scalar) { |
| 30 | *result_listener << "is a " << arg->getVerbatimTag(); |
| 31 | return false; |
| 32 | } |
| 33 | llvm::SmallString<32> S; |
| 34 | return Val == static_cast<llvm::yaml::ScalarNode *>(arg)->getValue(Storage&: S); |
| 35 | } |
| 36 | |
| 37 | // Checks that N is a Mapping (JS object) with the expected scalar properties. |
| 38 | // The object must have all the Expected properties, but may have others. |
| 39 | bool verifyObject(llvm::yaml::Node &N, |
| 40 | std::map<std::string, std::string> Expected) { |
| 41 | auto *M = llvm::dyn_cast<llvm::yaml::MappingNode>(Val: &N); |
| 42 | if (!M) { |
| 43 | ADD_FAILURE() << "Not an object" ; |
| 44 | return false; |
| 45 | } |
| 46 | bool Match = true; |
| 47 | llvm::SmallString<32> Tmp; |
| 48 | for (auto &Prop : *M) { |
| 49 | auto *K = llvm::dyn_cast_or_null<llvm::yaml::ScalarNode>(Val: Prop.getKey()); |
| 50 | if (!K) |
| 51 | continue; |
| 52 | std::string KS = K->getValue(Storage&: Tmp).str(); |
| 53 | auto I = Expected.find(x: KS); |
| 54 | if (I == Expected.end()) |
| 55 | continue; // Ignore properties with no assertion. |
| 56 | |
| 57 | auto *V = llvm::dyn_cast_or_null<llvm::yaml::ScalarNode>(Val: Prop.getValue()); |
| 58 | if (!V) { |
| 59 | ADD_FAILURE() << KS << " is not a string" ; |
| 60 | Match = false; |
| 61 | continue; |
| 62 | } |
| 63 | std::string VS = V->getValue(Storage&: Tmp).str(); |
| 64 | if (VS != I->second) { |
| 65 | ADD_FAILURE() << KS << " expected " << I->second << " but actual " << VS; |
| 66 | Match = false; |
| 67 | } |
| 68 | Expected.erase(position: I); |
| 69 | } |
| 70 | for (const auto &P : Expected) { |
| 71 | ADD_FAILURE() << P.first << " missing, expected " << P.second; |
| 72 | Match = false; |
| 73 | } |
| 74 | return Match; |
| 75 | } |
| 76 | |
| 77 | TEST(TraceTest, SmokeTest) { |
| 78 | // Capture some events. |
| 79 | std::string JSON; |
| 80 | { |
| 81 | llvm::raw_string_ostream OS(JSON); |
| 82 | auto JSONTracer = trace::createJSONTracer(OS); |
| 83 | trace::Session Session(*JSONTracer); |
| 84 | { |
| 85 | trace::Span Tracer("A" ); |
| 86 | trace::log(Name: "B" ); |
| 87 | } |
| 88 | } |
| 89 | |
| 90 | // Get the root JSON object using the YAML parser. |
| 91 | llvm::SourceMgr SM; |
| 92 | llvm::yaml::Stream Stream(JSON, SM); |
| 93 | auto Doc = Stream.begin(); |
| 94 | ASSERT_NE(Doc, Stream.end()); |
| 95 | auto *Root = llvm::dyn_cast_or_null<llvm::yaml::MappingNode>(Val: Doc->getRoot()); |
| 96 | ASSERT_NE(Root, nullptr) << "Root should be an object" ; |
| 97 | |
| 98 | // Check whether we expect thread name events on this platform. |
| 99 | llvm::SmallString<32> ThreadName; |
| 100 | get_thread_name(Name&: ThreadName); |
| 101 | bool ThreadsHaveNames = !ThreadName.empty(); |
| 102 | |
| 103 | // We expect in order: |
| 104 | // displayTimeUnit: "ns" |
| 105 | // traceEvents: [process name, thread name, start span, log, end span] |
| 106 | // (The order doesn't matter, but the YAML parser is awkward to use otherwise) |
| 107 | auto Prop = Root->begin(); |
| 108 | ASSERT_NE(Prop, Root->end()) << "Expected displayTimeUnit property" ; |
| 109 | ASSERT_THAT(Prop->getKey(), stringNode("displayTimeUnit" )); |
| 110 | EXPECT_THAT(Prop->getValue(), stringNode("ns" )); |
| 111 | ASSERT_NE(++Prop, Root->end()) << "Expected traceEvents property" ; |
| 112 | EXPECT_THAT(Prop->getKey(), stringNode("traceEvents" )); |
| 113 | auto *Events = |
| 114 | llvm::dyn_cast_or_null<llvm::yaml::SequenceNode>(Val: Prop->getValue()); |
| 115 | ASSERT_NE(Events, nullptr) << "traceEvents should be an array" ; |
| 116 | auto Event = Events->begin(); |
| 117 | ASSERT_NE(Event, Events->end()) << "Expected process name" ; |
| 118 | EXPECT_TRUE(verifyObject(*Event, {{"ph" , "M" }, {"name" , "process_name" }})); |
| 119 | if (ThreadsHaveNames) { |
| 120 | ASSERT_NE(++Event, Events->end()) << "Expected thread name" ; |
| 121 | EXPECT_TRUE(verifyObject(*Event, {{"ph" , "M" }, {"name" , "thread_name" }})); |
| 122 | } |
| 123 | ASSERT_NE(++Event, Events->end()) << "Expected log message" ; |
| 124 | EXPECT_TRUE(verifyObject(*Event, {{"ph" , "i" }, {"name" , "Log" }})); |
| 125 | ASSERT_NE(++Event, Events->end()) << "Expected span end" ; |
| 126 | EXPECT_TRUE(verifyObject(*Event, {{"ph" , "X" }, {"name" , "A" }})); |
| 127 | ASSERT_EQ(++Event, Events->end()); |
| 128 | ASSERT_EQ(++Prop, Root->end()); |
| 129 | } |
| 130 | |
| 131 | TEST(MetricsTracer, LatencyTest) { |
| 132 | trace::TestTracer Tracer; |
| 133 | constexpr llvm::StringLiteral MetricName = "span_latency" ; |
| 134 | constexpr llvm::StringLiteral OpName = "op_name" ; |
| 135 | { |
| 136 | // A span should record latencies to span_latency by default. |
| 137 | trace::Span SpanWithLat(OpName); |
| 138 | EXPECT_THAT(Tracer.takeMetric(MetricName, OpName), SizeIs(0)); |
| 139 | } |
| 140 | EXPECT_THAT(Tracer.takeMetric(MetricName, OpName), SizeIs(1)); |
| 141 | } |
| 142 | |
| 143 | class CSVMetricsTracerTest : public ::testing::Test { |
| 144 | protected: |
| 145 | CSVMetricsTracerTest() |
| 146 | : OS(Output), Tracer(trace::createCSVMetricTracer(OS)), Session(*Tracer) { |
| 147 | } |
| 148 | trace::Metric Dist = {"dist" , trace::Metric::Distribution, "lbl" }; |
| 149 | trace::Metric Counter = {"cnt" , trace::Metric::Counter}; |
| 150 | |
| 151 | std::vector<std::string> outputLines() { |
| 152 | // Deliberately don't flush output stream, the tracer should do that. |
| 153 | // This is important when clangd crashes. |
| 154 | llvm::SmallVector<llvm::StringRef> Lines; |
| 155 | llvm::StringRef(Output).split(A&: Lines, Separator: "\r\n" ); |
| 156 | return {Lines.begin(), Lines.end()}; |
| 157 | } |
| 158 | |
| 159 | std::string Output; |
| 160 | llvm::raw_string_ostream OS; |
| 161 | std::unique_ptr<trace::EventTracer> Tracer; |
| 162 | trace::Session Session; |
| 163 | }; |
| 164 | |
| 165 | TEST_F(CSVMetricsTracerTest, RecordsValues) { |
| 166 | Dist.record(Value: 1, Label: "x" ); |
| 167 | Counter.record(Value: 1, Label: "" ); |
| 168 | Dist.record(Value: 2, Label: "y" ); |
| 169 | |
| 170 | ASSERT_THAT(outputLines(), |
| 171 | ElementsAre("Kind,Metric,Label,Value,Timestamp" , |
| 172 | StartsWith("d,dist,x,1.000000e+00," ), |
| 173 | StartsWith("c,cnt,,1.000000e+00," ), |
| 174 | StartsWith("d,dist,y,2.000000e+00," ), "" )); |
| 175 | } |
| 176 | |
| 177 | TEST_F(CSVMetricsTracerTest, Escaping) { |
| 178 | Dist.record(Value: 1, Label: "," ); |
| 179 | Dist.record(Value: 1, Label: "a\"b" ); |
| 180 | Dist.record(Value: 1, Label: "a\nb" ); |
| 181 | |
| 182 | EXPECT_THAT(outputLines(), ElementsAre(_, StartsWith(R"(d,dist,",",1)" ), |
| 183 | StartsWith(R"(d,dist,"a""b",1)" ), |
| 184 | StartsWith("d,dist,\"a\nb\",1" ), "" )); |
| 185 | } |
| 186 | |
| 187 | TEST_F(CSVMetricsTracerTest, IgnoresArgs) { |
| 188 | trace::Span Tracer("Foo" ); |
| 189 | EXPECT_EQ(nullptr, Tracer.Args); |
| 190 | } |
| 191 | |
| 192 | } // namespace |
| 193 | } // namespace clangd |
| 194 | } // namespace clang |
| 195 | |