diff options
author | serxa <serxa@yandex-team.ru> | 2022-02-10 16:49:08 +0300 |
---|---|---|
committer | Daniil Cherednik <dcherednik@yandex-team.ru> | 2022-02-10 16:49:08 +0300 |
commit | e5d4696304c6689379ac7ce334512404d4b7836c (patch) | |
tree | 5d5cb817648f650d76cf1076100726fd9b8448e8 /library/cpp/lwtrace/trace_ut.cpp | |
parent | d6d7db348c2cc64e71243cab9940ee6778f4317d (diff) | |
download | ydb-e5d4696304c6689379ac7ce334512404d4b7836c.tar.gz |
Restoring authorship annotation for <serxa@yandex-team.ru>. Commit 2 of 2.
Diffstat (limited to 'library/cpp/lwtrace/trace_ut.cpp')
-rw-r--r-- | library/cpp/lwtrace/trace_ut.cpp | 194 |
1 files changed, 97 insertions, 97 deletions
diff --git a/library/cpp/lwtrace/trace_ut.cpp b/library/cpp/lwtrace/trace_ut.cpp index dd67212ea2..cb03e4fbde 100644 --- a/library/cpp/lwtrace/trace_ut.cpp +++ b/library/cpp/lwtrace/trace_ut.cpp @@ -1,11 +1,11 @@ -#include "all.h" - +#include "all.h" + #include <library/cpp/lwtrace/protos/lwtrace.pb.h> #include <library/cpp/testing/unittest/registar.h> - + #include <google/protobuf/text_format.h> - + enum ESimpleEnum { ValueA, ValueB, @@ -27,53 +27,53 @@ enum class EEnumClass { PROBE(DurationParam, GROUPS("Group"), TYPES(TDuration), NAMES("value")) \ PROBE(ProtoEnum, GROUPS("Group"), TYPES(NLWTrace::EOperatorType), NAMES("value")) \ PROBE(IntIntParams, GROUPS("Group"), TYPES(ui32, ui64), NAMES("value1", "value2")) \ - /**/ - -LWTRACE_DECLARE_PROVIDER(LWTRACE_UT_PROVIDER) -LWTRACE_DEFINE_PROVIDER(LWTRACE_UT_PROVIDER) -LWTRACE_USING(LWTRACE_UT_PROVIDER) - -using namespace NLWTrace; - + /**/ + +LWTRACE_DECLARE_PROVIDER(LWTRACE_UT_PROVIDER) +LWTRACE_DEFINE_PROVIDER(LWTRACE_UT_PROVIDER) +LWTRACE_USING(LWTRACE_UT_PROVIDER) + +using namespace NLWTrace; + Y_UNIT_TEST_SUITE(LWTraceTrace) { #ifndef LWTRACE_DISABLE Y_UNIT_TEST(Smoke) { - TManager mngr(*Singleton<TProbeRegistry>(), true); - TQuery q; - bool parsed = NProtoBuf::TextFormat::ParseFromString(R"END( - Blocks { - ProbeDesc { - Name: "NoParam" - Provider: "LWTRACE_UT_PROVIDER" - } - Action { - LogAction { } - } - } - )END", - &q); - UNIT_ASSERT(parsed); - mngr.New("Query1", q); - LWPROBE(NoParam); - struct { - void Push(TThread::TId, const TLogItem& item) { - UNIT_ASSERT(TString(item.Probe->Event.Name) == "NoParam"); - } - } reader; - mngr.ReadLog("Query1", reader); + TManager mngr(*Singleton<TProbeRegistry>(), true); + TQuery q; + bool parsed = NProtoBuf::TextFormat::ParseFromString(R"END( + Blocks { + ProbeDesc { + Name: "NoParam" + Provider: "LWTRACE_UT_PROVIDER" + } + Action { + LogAction { } + } + } + )END", + &q); + UNIT_ASSERT(parsed); + mngr.New("Query1", q); + LWPROBE(NoParam); + struct { + void Push(TThread::TId, const TLogItem& item) { + UNIT_ASSERT(TString(item.Probe->Event.Name) == "NoParam"); + } + } reader; + mngr.ReadLog("Query1", reader); LWPROBE(EnumParams, ValueA, EEnumClass::ValueC); LWPROBE(InstantParam, TInstant::Seconds(42)); LWPROBE(DurationParam, TDuration::MilliSeconds(146)); LWPROBE(ProtoEnum, OT_EQ); - } + } Y_UNIT_TEST(Predicate) { TManager mngr(*Singleton<TProbeRegistry>(), true); TQuery q; bool parsed = NProtoBuf::TextFormat::ParseFromString(R"END( Blocks { - ProbeDesc { + ProbeDesc { Name: "IntParam" Provider: "LWTRACE_UT_PROVIDER" } @@ -85,7 +85,7 @@ Y_UNIT_TEST_SUITE(LWTraceTrace) { } } Action { - LogAction { } + LogAction { } } } )END", &q); @@ -117,7 +117,7 @@ Y_UNIT_TEST_SUITE(LWTraceTrace) { TQuery q; bool parsed = NProtoBuf::TextFormat::ParseFromString(R"END( Blocks { - ProbeDesc { + ProbeDesc { Name: "IntParam" Provider: "LWTRACE_UT_PROVIDER" } @@ -203,7 +203,7 @@ Y_UNIT_TEST_SUITE(LWTraceTrace) { } } Blocks { - ProbeDesc { + ProbeDesc { Name: "IntParam" Provider: "LWTRACE_UT_PROVIDER" } @@ -216,53 +216,53 @@ Y_UNIT_TEST_SUITE(LWTraceTrace) { Operators { Type: OT_EQ Argument { Variable: "varDec" } - Argument { Value: "-1" } + Argument { Value: "-1" } } Operators { Type: OT_EQ Argument { Variable: "varMov" } - Argument { Value: "3" } + Argument { Value: "3" } } Operators { Type: OT_EQ Argument { Variable: "varAddEq" } - Argument { Value: "5" } + Argument { Value: "5" } } Operators { Type: OT_EQ Argument { Variable: "varSubEq" } - Argument { Value: "-5" } + Argument { Value: "-5" } } Operators { Type: OT_EQ Argument { Variable: "varAdd" } - Argument { Value: "5" } + Argument { Value: "5" } } Operators { Type: OT_EQ Argument { Variable: "varSub" } - Argument { Value: "1" } + Argument { Value: "1" } } Operators { Type: OT_EQ Argument { Variable: "varMul" } - Argument { Value: "12" } + Argument { Value: "12" } } Operators { Type: OT_EQ Argument { Variable: "varDiv" } - Argument { Value: "3" } + Argument { Value: "3" } } Operators { Type: OT_EQ Argument { Variable: "varMod" } - Argument { Value: "2" } + Argument { Value: "2" } } } Action { LogAction { } } - } + } )END", &q); UNIT_ASSERT(parsed); mngr.New("QueryName", q); @@ -286,7 +286,7 @@ Y_UNIT_TEST_SUITE(LWTraceTrace) { TQuery q; bool parsed = NProtoBuf::TextFormat::ParseFromString(R"END( Blocks { - ProbeDesc { + ProbeDesc { Name: "IntIntParams" Provider: "LWTRACE_UT_PROVIDER" } @@ -353,7 +353,7 @@ Y_UNIT_TEST_SUITE(LWTraceTrace) { } } Blocks { - ProbeDesc { + ProbeDesc { Name: "IntIntParams" Provider: "LWTRACE_UT_PROVIDER" } @@ -361,48 +361,48 @@ Y_UNIT_TEST_SUITE(LWTraceTrace) { Operators { Type: OT_EQ Argument { Variable: "varMov" } - Argument { Param: "value1" } + Argument { Param: "value1" } } Operators { Type: OT_EQ Argument { Variable: "varAddEq" } - Argument { Param: "value1" } + Argument { Param: "value1" } } Operators { Type: OT_EQ Argument { Variable: "varSubEq" } - Argument { Value: "-22" } + Argument { Value: "-22" } } Operators { Type: OT_EQ Argument { Variable: "varAdd" } - Argument { Value: "25" } + Argument { Value: "25" } } Operators { Type: OT_EQ Argument { Variable: "varSub" } - Argument { Value: "19" } + Argument { Value: "19" } } Operators { Type: OT_EQ Argument { Variable: "varMul" } - Argument { Value: "66" } + Argument { Value: "66" } } Operators { Type: OT_EQ Argument { Variable: "varDiv" } - Argument { Value: "7" } + Argument { Value: "7" } } Operators { Type: OT_EQ Argument { Variable: "varMod" } - Argument { Value: "1" } + Argument { Value: "1" } } } Action { LogAction { } } - } + } )END", &q); UNIT_ASSERT(parsed); mngr.New("QueryName", q); @@ -424,12 +424,12 @@ Y_UNIT_TEST_SUITE(LWTraceTrace) { bool parsed = NProtoBuf::TextFormat::ParseFromString(R"END( PerThreadLogSize: 3 Blocks { - ProbeDesc { + ProbeDesc { Name: "IntParam" Provider: "LWTRACE_UT_PROVIDER" } Action { - LogAction { } + LogAction { } } } )END", &q); @@ -501,7 +501,7 @@ Y_UNIT_TEST_SUITE(LWTraceTrace) { TQuery q; bool parsed = NProtoBuf::TextFormat::ParseFromString(R"END( Blocks { - ProbeDesc { + ProbeDesc { Name: "NoParam" Provider: "LWTRACE_UT_PROVIDER" } @@ -521,7 +521,7 @@ Y_UNIT_TEST_SUITE(LWTraceTrace) { TQuery q; bool parsed = NProtoBuf::TextFormat::ParseFromString(R"END( Blocks { - ProbeDesc { + ProbeDesc { Name: "NoParam" Provider: "LWTRACE_UT_PROVIDER" } @@ -539,7 +539,7 @@ Y_UNIT_TEST_SUITE(LWTraceTrace) { TInstant t0 = Now(); LWPROBE(NoParam); TInstant t1 = Now(); - UNIT_ASSERT(t1.NanoSeconds() - t0.NanoSeconds() >= sleepTimeNs); + UNIT_ASSERT(t1.NanoSeconds() - t0.NanoSeconds() >= sleepTimeNs); } Y_UNIT_TEST(ProtoEnumTraits) { @@ -550,37 +550,37 @@ Y_UNIT_TEST_SUITE(LWTraceTrace) { } Y_UNIT_TEST(Track) { - TManager mngr(*Singleton<TProbeRegistry>(), true); - TQuery q; - bool parsed = NProtoBuf::TextFormat::ParseFromString(R"END( - Blocks { - ProbeDesc { - Name: "IntParam" - Provider: "LWTRACE_UT_PROVIDER" - } - Action { - RunLogShuttleAction { } - } - } + TManager mngr(*Singleton<TProbeRegistry>(), true); + TQuery q; + bool parsed = NProtoBuf::TextFormat::ParseFromString(R"END( + Blocks { + ProbeDesc { + Name: "IntParam" + Provider: "LWTRACE_UT_PROVIDER" + } + Action { + RunLogShuttleAction { } + } + } )END", &q); - UNIT_ASSERT(parsed); - mngr.New("Query1", q); - - { - TOrbit orbit; - LWTRACK(IntParam, orbit, 1); - LWTRACK(StringParam, orbit, "str"); - } - - struct { - void Push(TThread::TId, const TTrackLog& tl) { - UNIT_ASSERT(tl.Items.size() == 2); - UNIT_ASSERT(TString(tl.Items[0].Probe->Event.Name) == "IntParam"); - UNIT_ASSERT(TString(tl.Items[1].Probe->Event.Name) == "StringParam"); - } - } reader; - mngr.ReadDepot("Query1", reader); - } + UNIT_ASSERT(parsed); + mngr.New("Query1", q); + + { + TOrbit orbit; + LWTRACK(IntParam, orbit, 1); + LWTRACK(StringParam, orbit, "str"); + } + + struct { + void Push(TThread::TId, const TTrackLog& tl) { + UNIT_ASSERT(tl.Items.size() == 2); + UNIT_ASSERT(TString(tl.Items[0].Probe->Event.Name) == "IntParam"); + UNIT_ASSERT(TString(tl.Items[1].Probe->Event.Name) == "StringParam"); + } + } reader; + mngr.ReadDepot("Query1", reader); + } Y_UNIT_TEST(ShouldSerializeTracks) { @@ -877,4 +877,4 @@ Y_UNIT_TEST_SUITE(LWTraceTrace) { mngr.ReadDepot("Query1", reader); } #endif // LWTRACE_DISABLE -} +} |