diff options
author | asatarin <asatarin@yandex-team.ru> | 2022-02-10 16:47:30 +0300 |
---|---|---|
committer | Daniil Cherednik <dcherednik@yandex-team.ru> | 2022-02-10 16:47:30 +0300 |
commit | ca04a556317a80ac802f38457a2292185282878b (patch) | |
tree | c0748b5dcbade83af788c0abfa89c0383d6b779c /library/cpp | |
parent | 4ca29390ac54b7877174de542de47532c67453b5 (diff) | |
download | ydb-ca04a556317a80ac802f38457a2292185282878b.tar.gz |
Restoring authorship annotation for <asatarin@yandex-team.ru>. Commit 2 of 2.
Diffstat (limited to 'library/cpp')
-rw-r--r-- | library/cpp/actors/core/actor_coroutine_ut.cpp | 12 | ||||
-rw-r--r-- | library/cpp/actors/core/mailbox.cpp | 8 | ||||
-rw-r--r-- | library/cpp/actors/memory_log/memlog.cpp | 96 | ||||
-rw-r--r-- | library/cpp/actors/testlib/test_runtime.cpp | 14 | ||||
-rw-r--r-- | library/cpp/actors/testlib/test_runtime.h | 16 | ||||
-rw-r--r-- | library/cpp/bucket_quoter/bucket_quoter.h | 4 | ||||
-rw-r--r-- | library/cpp/messagebus/netaddr_ut.cpp | 4 | ||||
-rw-r--r-- | library/cpp/messagebus/test/ut/locator_uniq_ut.cpp | 4 | ||||
-rw-r--r-- | library/cpp/messagebus/test/ut/one_way_ut.cpp | 12 | ||||
-rw-r--r-- | library/cpp/messagebus/test/ut/ya.make | 78 | ||||
-rw-r--r-- | library/cpp/messagebus/test_utils.h | 8 | ||||
-rw-r--r-- | library/cpp/messagebus/ya.make | 6 | ||||
-rw-r--r-- | library/cpp/testing/unittest/registar.cpp | 2 | ||||
-rw-r--r-- | library/cpp/testing/unittest/registar.h | 18 | ||||
-rw-r--r-- | library/cpp/threading/skip_list/perf/main.cpp | 10 |
15 files changed, 146 insertions, 146 deletions
diff --git a/library/cpp/actors/core/actor_coroutine_ut.cpp b/library/cpp/actors/core/actor_coroutine_ut.cpp index 3397987bc8..951512b877 100644 --- a/library/cpp/actors/core/actor_coroutine_ut.cpp +++ b/library/cpp/actors/core/actor_coroutine_ut.cpp @@ -7,8 +7,8 @@ #include "hfunc.h" #include <library/cpp/testing/unittest/registar.h> -#include <util/system/sanitizers.h> - +#include <util/system/sanitizers.h> + using namespace NActors; Y_UNIT_TEST_SUITE(ActorCoro) { @@ -128,10 +128,10 @@ Y_UNIT_TEST_SUITE(ActorCoro) { } Y_UNIT_TEST(Basic) { - if (NSan::TSanIsOn()) { - // TODO https://st.yandex-team.ru/DEVTOOLS-3154 - return; - } + if (NSan::TSanIsOn()) { + // TODO https://st.yandex-team.ru/DEVTOOLS-3154 + return; + } Check(MakeHolder<TEvEnough>()); } diff --git a/library/cpp/actors/core/mailbox.cpp b/library/cpp/actors/core/mailbox.cpp index f3a0b48287..d84b4f9e46 100644 --- a/library/cpp/actors/core/mailbox.cpp +++ b/library/cpp/actors/core/mailbox.cpp @@ -3,8 +3,8 @@ #include <library/cpp/actors/util/datetime.h> -#include <util/system/sanitizers.h> - +#include <util/system/sanitizers.h> + namespace NActors { TMailboxTable::TMailboxTable() : LastAllocatedLine(0) @@ -178,7 +178,7 @@ namespace NActors { switch (x->MailboxType) { case TMailboxType::Simple: { TSimpleMailbox* const mailbox = TSimpleMailbox::Get(lineHint, x); -#if (!defined(_tsan_enabled_)) +#if (!defined(_tsan_enabled_)) Y_VERIFY_DEBUG(mailbox->Type == (ui32)x->MailboxType); #endif mailbox->Queue.Push(ev.Release()); @@ -202,7 +202,7 @@ namespace NActors { return false; TRevolvingMailbox* const mailbox = TRevolvingMailbox::Get(lineHint, x); -#if (!defined(_tsan_enabled_)) +#if (!defined(_tsan_enabled_)) Y_VERIFY_DEBUG(mailbox->Type == (ui32)x->MailboxType); #endif mailbox->QueueWriter.Push(ev.Release()); diff --git a/library/cpp/actors/memory_log/memlog.cpp b/library/cpp/actors/memory_log/memlog.cpp index d7aa94d762..8e6b46727d 100644 --- a/library/cpp/actors/memory_log/memlog.cpp +++ b/library/cpp/actors/memory_log/memlog.cpp @@ -198,32 +198,32 @@ void NoCacheMemcpy(char* dst, const char* src, size_t size) noexcept { } memcpy(dst, src, size); } - -NO_SANITIZE_THREAD -void NoWCacheMemcpy(char* dst, const char* src, size_t size) noexcept { - constexpr ui16 ITEMS_COUNT = 1024; - alignas(TMemoryLog::MemcpyAlignment) __m128 buf[ITEMS_COUNT]; - while (size >= sizeof(buf)) { - memcpy(&buf, src, sizeof(buf)); - - for (ui16 i = 0; i < ITEMS_COUNT; ++i) { - _mm_stream_ps((float*)dst, buf[i]); - dst += sizeof(__m128); - } - - size -= sizeof(buf); - src += sizeof(buf); - } - - memcpy(&buf, src, size); - // no problem to copy few bytes more - size = AlignUp(size, sizeof(__m128)); - for (ui16 i = 0; i < size / sizeof(__m128); ++i) { - _mm_stream_ps((float*)dst, buf[i]); - dst += sizeof(__m128); - } -} - + +NO_SANITIZE_THREAD +void NoWCacheMemcpy(char* dst, const char* src, size_t size) noexcept { + constexpr ui16 ITEMS_COUNT = 1024; + alignas(TMemoryLog::MemcpyAlignment) __m128 buf[ITEMS_COUNT]; + while (size >= sizeof(buf)) { + memcpy(&buf, src, sizeof(buf)); + + for (ui16 i = 0; i < ITEMS_COUNT; ++i) { + _mm_stream_ps((float*)dst, buf[i]); + dst += sizeof(__m128); + } + + size -= sizeof(buf); + src += sizeof(buf); + } + + memcpy(&buf, src, size); + // no problem to copy few bytes more + size = AlignUp(size, sizeof(__m128)); + for (ui16 i = 0; i < size / sizeof(__m128); ++i) { + _mm_stream_ps((float*)dst, buf[i]); + dst += sizeof(__m128); + } +} + #endif NO_SANITIZE_THREAD @@ -240,12 +240,12 @@ char* BareMemLogWrite(const char* begin, size_t msgSize, bool isLast) noexcept { #if defined(_x86_64_) || defined(_i386_) if (AlignDown(begin, TMemoryLog::MemcpyAlignment) == begin) { NoCacheMemcpy(buffer, begin, msgSize); - } else { - NoWCacheMemcpy(buffer, begin, msgSize); - } -#else - memcpy(buffer, begin, msgSize); -#endif + } else { + NoWCacheMemcpy(buffer, begin, msgSize); + } +#else + memcpy(buffer, begin, msgSize); +#endif if (lastMark) { TMemoryLog::ChangeLastMark(buffer + msgSize); @@ -267,7 +267,7 @@ bool MemLogWrite(const char* begin, size_t msgSize, bool addLF) noexcept { // check for format for snprintf constexpr size_t prologSize = 48; alignas(TMemoryLog::MemcpyAlignment) char prolog[prologSize + 1]; - Y_VERIFY(AlignDown(&prolog, TMemoryLog::MemcpyAlignment) == &prolog); + Y_VERIFY(AlignDown(&prolog, TMemoryLog::MemcpyAlignment) == &prolog); int snprintfResult = snprintf(prolog, prologSize + 1, "TS %020" PRIu64 " TI %020" PRIu64 " ", GetCycleCountFast(), threadId); @@ -288,18 +288,18 @@ bool MemLogWrite(const char* begin, size_t msgSize, bool addLF) noexcept { } #if defined(_x86_64_) || defined(_i386_) - // warning: copy prolog first to avoid corruption of the message - // by prolog tail - NoCacheMemcpy(buffer, prolog, prologSize); + // warning: copy prolog first to avoid corruption of the message + // by prolog tail + NoCacheMemcpy(buffer, prolog, prologSize); if (AlignDown(begin + prologSize, TMemoryLog::MemcpyAlignment) == begin + prologSize) { - NoCacheMemcpy(buffer + prologSize, begin, msgSize); + NoCacheMemcpy(buffer + prologSize, begin, msgSize); } else { - NoWCacheMemcpy(buffer + prologSize, begin, msgSize); - } -#else - memcpy(buffer, prolog, prologSize); - memcpy(buffer + prologSize, begin, msgSize); -#endif + NoWCacheMemcpy(buffer + prologSize, begin, msgSize); + } +#else + memcpy(buffer, prolog, prologSize); + memcpy(buffer + prologSize, begin, msgSize); +#endif if (addLF) { buffer[prologSize + msgSize] = '\n'; @@ -336,9 +336,9 @@ bool MemLogVPrintF(const char* format, va_list params) noexcept { // alignment required by NoCacheMemcpy alignas(TMemoryLog::MemcpyAlignment) char buf[TMemoryLog::MAX_MESSAGE_SIZE]; - Y_VERIFY(AlignDown(&buf, TMemoryLog::MemcpyAlignment) == &buf); + Y_VERIFY(AlignDown(&buf, TMemoryLog::MemcpyAlignment) == &buf); - int prologSize = snprintf(buf, + int prologSize = snprintf(buf, TMemoryLog::MAX_MESSAGE_SIZE - 2, "TS %020" PRIu64 " TI %020" PRIu64 " ", GetCycleCountFast(), @@ -350,7 +350,7 @@ bool MemLogVPrintF(const char* format, va_list params) noexcept { Y_VERIFY((ui32)prologSize <= TMemoryLog::MAX_MESSAGE_SIZE); int add = vsnprintf( - &buf[prologSize], + &buf[prologSize], TMemoryLog::MAX_MESSAGE_SIZE - prologSize - 2, format, params); @@ -360,8 +360,8 @@ bool MemLogVPrintF(const char* format, va_list params) noexcept { Y_VERIFY(add >= 0); auto totalSize = prologSize + add; - buf[totalSize++] = '\n'; + buf[totalSize++] = '\n'; Y_VERIFY((ui32)totalSize <= TMemoryLog::MAX_MESSAGE_SIZE); - return BareMemLogWrite(buf, totalSize) != nullptr; + return BareMemLogWrite(buf, totalSize) != nullptr; } diff --git a/library/cpp/actors/testlib/test_runtime.cpp b/library/cpp/actors/testlib/test_runtime.cpp index eea97fb613..6fa25b9965 100644 --- a/library/cpp/actors/testlib/test_runtime.cpp +++ b/library/cpp/actors/testlib/test_runtime.cpp @@ -12,7 +12,7 @@ #include <library/cpp/actors/interconnect/interconnect.h> #include <library/cpp/actors/interconnect/interconnect_tcp_proxy.h> #include <library/cpp/actors/interconnect/interconnect_proxy_wrapper.h> - + #include <util/generic/maybe.h> #include <util/generic/bt_exception.h> #include <util/random/mersenne.h> @@ -23,7 +23,7 @@ bool VERBOSE = false; const bool PRINT_EVENT_BODY = false; namespace { - + TString MakeClusterId() { pid_t pid = getpid(); TStringBuilder uuid; @@ -457,7 +457,7 @@ namespace NActors { TTestActorRuntimeBase::TTestActorRuntimeBase(ui32 nodeCount, ui32 dataCenterCount, bool useRealThreads) : ScheduledCount(0) - , ScheduledLimit(100000) + , ScheduledLimit(100000) , MainThreadId(TThread::CurrentThreadId()) , ClusterUUID(MakeClusterId()) , FirstNodeId(NextNodeId) @@ -472,7 +472,7 @@ namespace NActors { , TimeProvider(new TTimeProvider(*this)) , ShouldContinue() , CurrentTimestamp(0) - , DispatchTimeout(DEFAULT_DISPATCH_TIMEOUT) + , DispatchTimeout(DEFAULT_DISPATCH_TIMEOUT) , ReschedulingDelay(TDuration::MicroSeconds(0)) , ObserverFunc(&TTestActorRuntimeBase::DefaultObserverFunc) , ScheduledEventsSelectorFunc(&CollapsedTimeScheduledEventsSelector) @@ -1832,12 +1832,12 @@ namespace NActors { while (Context->Queue->Head()) { HasReply = false; ctx.ExecutorThread.Send(GetForwardedEvent().Release()); - int count = 100; - while (!HasReply && count > 0) { + int count = 100; + while (!HasReply && count > 0) { try { Runtime->DispatchEvents(DelegateeOptions); } catch (TEmptyEventQueueException&) { - count--; + count--; Cerr << "No reply" << Endl; } } diff --git a/library/cpp/actors/testlib/test_runtime.h b/library/cpp/actors/testlib/test_runtime.h index dabca4bac4..26e3b45c98 100644 --- a/library/cpp/actors/testlib/test_runtime.h +++ b/library/cpp/actors/testlib/test_runtime.h @@ -26,18 +26,18 @@ #include <util/system/mutex.h> #include <util/system/condvar.h> #include <util/system/thread.h> -#include <util/system/sanitizers.h> -#include <util/system/valgrind.h> +#include <util/system/sanitizers.h> +#include <util/system/valgrind.h> #include <utility> #include <functional> -const TDuration DEFAULT_DISPATCH_TIMEOUT = NSan::PlainOrUnderSanitizer( - NValgrind::PlainOrUnderValgrind(TDuration::Seconds(60), TDuration::Seconds(120)), - TDuration::Seconds(120) -); - - +const TDuration DEFAULT_DISPATCH_TIMEOUT = NSan::PlainOrUnderSanitizer( + NValgrind::PlainOrUnderValgrind(TDuration::Seconds(60), TDuration::Seconds(120)), + TDuration::Seconds(120) +); + + namespace NActors { struct THeSingleSystemEnv { }; diff --git a/library/cpp/bucket_quoter/bucket_quoter.h b/library/cpp/bucket_quoter/bucket_quoter.h index 0e0ac59f1b..3d92ef8450 100644 --- a/library/cpp/bucket_quoter/bucket_quoter.h +++ b/library/cpp/bucket_quoter/bucket_quoter.h @@ -89,7 +89,7 @@ public: , UsecWaited(usecWaited) , AggregateInflow(aggregateInflow) , Bucket(fill ? capacity : 0) - , LastAdd(Timer::Now()) + , LastAdd(Timer::Now()) , InflowTokensPerSecond(&FixedInflow) , BucketTokensCapacity(&FixedCapacity) , FixedInflow(inflow) @@ -108,7 +108,7 @@ public: , UsecWaited(usecWaited) , AggregateInflow(aggregateInflow) , Bucket(fill ? AtomicGet(*capacity) : 0) - , LastAdd(Timer::Now()) + , LastAdd(Timer::Now()) , InflowTokensPerSecond(inflow) , BucketTokensCapacity(capacity) { diff --git a/library/cpp/messagebus/netaddr_ut.cpp b/library/cpp/messagebus/netaddr_ut.cpp index dcaeae3e8a..e5c68bf402 100644 --- a/library/cpp/messagebus/netaddr_ut.cpp +++ b/library/cpp/messagebus/netaddr_ut.cpp @@ -1,13 +1,13 @@ #include <library/cpp/testing/unittest/registar.h> #include "netaddr.h" -#include "test_utils.h" +#include "test_utils.h" using namespace NBus; Y_UNIT_TEST_SUITE(TNetAddr) { Y_UNIT_TEST(ResolveIpv4) { - ASSUME_IP_V4_ENABLED; + ASSUME_IP_V4_ENABLED; UNIT_ASSERT(TNetAddr("ns1.yandex.ru", 80, EIP_VERSION_4).IsIpv4()); } diff --git a/library/cpp/messagebus/test/ut/locator_uniq_ut.cpp b/library/cpp/messagebus/test/ut/locator_uniq_ut.cpp index afc99b05e4..3fdd175d73 100644 --- a/library/cpp/messagebus/test/ut/locator_uniq_ut.cpp +++ b/library/cpp/messagebus/test/ut/locator_uniq_ut.cpp @@ -15,8 +15,8 @@ protected: UNIT_TEST_SUITE_REGISTRATION(TLocatorRegisterUniqTest); void TLocatorRegisterUniqTest::TestRegister() { - ASSUME_IP_V4_ENABLED; - + ASSUME_IP_V4_ENABLED; + NBus::TBusLocator locator; const char* serviceName = "TestService"; const char* hostName = "192.168.0.42"; diff --git a/library/cpp/messagebus/test/ut/one_way_ut.cpp b/library/cpp/messagebus/test/ut/one_way_ut.cpp index 56f7697762..9c21227e2b 100644 --- a/library/cpp/messagebus/test/ut/one_way_ut.cpp +++ b/library/cpp/messagebus/test/ut/one_way_ut.cpp @@ -65,9 +65,9 @@ struct NullClient : TBusClientHandlerError { } ~NullClient() override { - Session->Shutdown(); - } - + Session->Shutdown(); + } + /// dispatch of requests is done here void Work() { int batch = 10; @@ -107,9 +107,9 @@ public: } ~NullServer() override { - Session->Shutdown(); - } - + Session->Shutdown(); + } + /// when message comes do not send reply, just acknowledge void OnMessage(TOnMessageContext& mess) override { TExampleRequest* fmess = static_cast<TExampleRequest*>(mess.GetMessage()); diff --git a/library/cpp/messagebus/test/ut/ya.make b/library/cpp/messagebus/test/ut/ya.make index 672f3febbe..fe1b4961d6 100644 --- a/library/cpp/messagebus/test/ut/ya.make +++ b/library/cpp/messagebus/test/ut/ya.make @@ -11,46 +11,46 @@ TAG( ya:fat ) -FORK_SUBTESTS() - -PEERDIR( +FORK_SUBTESTS() + +PEERDIR( library/cpp/testing/unittest_main library/cpp/messagebus library/cpp/messagebus/test/helper library/cpp/messagebus/www -) - -SRCS( - messagebus_ut.cpp - module_client_ut.cpp - module_client_one_way_ut.cpp - module_server_ut.cpp - one_way_ut.cpp - starter_ut.cpp - sync_client_ut.cpp - locator_uniq_ut.cpp - ../../actor/actor_ut.cpp - ../../actor/ring_buffer_ut.cpp - ../../actor/tasks_ut.cpp - ../../actor/what_thread_does_guard_ut.cpp - ../../async_result_ut.cpp - ../../cc_semaphore_ut.cpp - ../../coreconn_ut.cpp - ../../duration_histogram_ut.cpp - ../../message_status_counter_ut.cpp - ../../misc/weak_ptr_ut.cpp - ../../latch_ut.cpp - ../../lfqueue_batch_ut.cpp - ../../local_flags_ut.cpp - ../../memory_ut.cpp - ../../moved_ut.cpp - ../../netaddr_ut.cpp - ../../network_ut.cpp - ../../nondestroying_holder_ut.cpp - ../../scheduler_actor_ut.cpp - ../../scheduler/scheduler_ut.cpp - ../../socket_addr_ut.cpp - ../../vector_swaps_ut.cpp -) - -END() +) + +SRCS( + messagebus_ut.cpp + module_client_ut.cpp + module_client_one_way_ut.cpp + module_server_ut.cpp + one_way_ut.cpp + starter_ut.cpp + sync_client_ut.cpp + locator_uniq_ut.cpp + ../../actor/actor_ut.cpp + ../../actor/ring_buffer_ut.cpp + ../../actor/tasks_ut.cpp + ../../actor/what_thread_does_guard_ut.cpp + ../../async_result_ut.cpp + ../../cc_semaphore_ut.cpp + ../../coreconn_ut.cpp + ../../duration_histogram_ut.cpp + ../../message_status_counter_ut.cpp + ../../misc/weak_ptr_ut.cpp + ../../latch_ut.cpp + ../../lfqueue_batch_ut.cpp + ../../local_flags_ut.cpp + ../../memory_ut.cpp + ../../moved_ut.cpp + ../../netaddr_ut.cpp + ../../network_ut.cpp + ../../nondestroying_holder_ut.cpp + ../../scheduler_actor_ut.cpp + ../../scheduler/scheduler_ut.cpp + ../../socket_addr_ut.cpp + ../../vector_swaps_ut.cpp +) + +END() diff --git a/library/cpp/messagebus/test_utils.h b/library/cpp/messagebus/test_utils.h index 42725c0b9b..2abdf504b1 100644 --- a/library/cpp/messagebus/test_utils.h +++ b/library/cpp/messagebus/test_utils.h @@ -1,6 +1,6 @@ -#pragma once - -// Do nothing if there is no support for IPv4 +#pragma once + +// Do nothing if there is no support for IPv4 #define ASSUME_IP_V4_ENABLED \ do { \ try { \ @@ -9,4 +9,4 @@ Y_UNUSED(ex); \ return; \ } \ - } while (0) + } while (0) diff --git a/library/cpp/messagebus/ya.make b/library/cpp/messagebus/ya.make index f022234eb3..e13cf06dea 100644 --- a/library/cpp/messagebus/ya.make +++ b/library/cpp/messagebus/ya.make @@ -3,9 +3,9 @@ LIBRARY() OWNER(g:messagebus) IF (SANITIZER_TYPE == "undefined") - NO_SANITIZE() -ENDIF() - + NO_SANITIZE() +ENDIF() + SRCS( acceptor.cpp acceptor_status.cpp diff --git a/library/cpp/testing/unittest/registar.cpp b/library/cpp/testing/unittest/registar.cpp index 614217c1a5..3679b768ed 100644 --- a/library/cpp/testing/unittest/registar.cpp +++ b/library/cpp/testing/unittest/registar.cpp @@ -50,7 +50,7 @@ void ::NUnitTest::NPrivate::RaiseError(const char* what, const TString& msg, boo if (::NUnitTest::ContinueOnFail || !fatalFailure) { return; } - throw TAssertException(); + throw TAssertException(); } void ::NUnitTest::SetRaiseErrorHandler(::NUnitTest::TRaiseErrorHandler handler) { diff --git a/library/cpp/testing/unittest/registar.h b/library/cpp/testing/unittest/registar.h index 00466a8cc7..44517a0092 100644 --- a/library/cpp/testing/unittest/registar.h +++ b/library/cpp/testing/unittest/registar.h @@ -437,18 +437,18 @@ public: \ #define UNIT_ASSERT_STRINGS_EQUAL(A, B) UNIT_ASSERT_STRINGS_EQUAL_C(A, B, "") -#define UNIT_ASSERT_STRING_CONTAINS_C(A, B, C) \ - do { \ +#define UNIT_ASSERT_STRING_CONTAINS_C(A, B, C) \ + do { \ const TString _a(A); \ const TString _b(B); \ - if (!_a.Contains(_b)) { \ + if (!_a.Contains(_b)) { \ auto&& msg = Sprintf("\"%s\" does not contain \"%s\", %s", ToString(_a).data(), ToString(_b).data(), (::TStringBuilder() << C).data()); \ - UNIT_FAIL_IMPL("strings contains assertion failed", msg); \ - } \ - } while (false) - -#define UNIT_ASSERT_STRING_CONTAINS(A, B) UNIT_ASSERT_STRING_CONTAINS_C(A, B, "") - + UNIT_FAIL_IMPL("strings contains assertion failed", msg); \ + } \ + } while (false) + +#define UNIT_ASSERT_STRING_CONTAINS(A, B) UNIT_ASSERT_STRING_CONTAINS_C(A, B, "") + #define UNIT_ASSERT_NO_DIFF(A, B) \ do { \ const TString _a(A); \ diff --git a/library/cpp/threading/skip_list/perf/main.cpp b/library/cpp/threading/skip_list/perf/main.cpp index c3eb6a6917..4ad52049e7 100644 --- a/library/cpp/threading/skip_list/perf/main.cpp +++ b/library/cpp/threading/skip_list/perf/main.cpp @@ -215,7 +215,7 @@ namespace { for (const TTest& test : Tests) { LogInfo() << "Starting test " << test.Name << Endl; - + TInstant started = TInstant::Now(); try { test.Func(); @@ -226,7 +226,7 @@ namespace { } LogInfo() << "List size = " << List.GetSize() << Endl; - + TDuration duration = TInstant::Now() - started; LogInfo() << "test " << test.Name << " duration: " << duration @@ -276,8 +276,8 @@ namespace { for (size_t i = 0; i < Iterations; ++i) { List.Insert(TListItem(Random.GetString(KeyLen), Random.GetString(ValueLen))); } - } - + } + void TEST_LookupRandom() { for (size_t i = 0; i < Iterations; ++i) { List.SeekTo(TListItem(Random.GetString(KeyLen), TStringBuf())); @@ -296,7 +296,7 @@ namespace { TGuard<TMutex> guard(Mutex); List.Insert(TListItem(Random.GetString(KeyLen), Random.GetString(ValueLen))); } - } + } TDuration duration = TInstant::Now() - started; LogInfo() << "Average time for producer = " |