diff options
author | d-mokhnatkin <d-mokhnatkin@yandex-team.ru> | 2022-02-10 16:50:43 +0300 |
---|---|---|
committer | Daniil Cherednik <dcherednik@yandex-team.ru> | 2022-02-10 16:50:43 +0300 |
commit | d94e393f3d35cf42ec17be6dc35149893a0b49cf (patch) | |
tree | 5d5cb817648f650d76cf1076100726fd9b8448e8 /library | |
parent | 4a2fe1d5dc0a49394dec49309de618073ccd14b7 (diff) | |
download | ydb-d94e393f3d35cf42ec17be6dc35149893a0b49cf.tar.gz |
Restoring authorship annotation for <d-mokhnatkin@yandex-team.ru>. Commit 2 of 2.
Diffstat (limited to 'library')
-rw-r--r-- | library/cpp/actors/http/http_proxy.cpp | 22 | ||||
-rw-r--r-- | library/cpp/streams/lz/lz.cpp | 14 | ||||
-rw-r--r-- | library/cpp/streams/lz/lz_ut.cpp | 18 | ||||
-rw-r--r-- | library/cpp/streams/lz/ut/ya.make | 2 | ||||
-rw-r--r-- | library/cpp/streams/lz/ut/yq_609.data | bin | 722 -> 721 bytes |
5 files changed, 28 insertions, 28 deletions
diff --git a/library/cpp/actors/http/http_proxy.cpp b/library/cpp/actors/http/http_proxy.cpp index 4b57a8453d..36c6855d93 100644 --- a/library/cpp/actors/http/http_proxy.cpp +++ b/library/cpp/actors/http/http_proxy.cpp @@ -1,4 +1,4 @@ -#include <library/cpp/actors/core/events.h> +#include <library/cpp/actors/core/events.h> #include <library/cpp/monlib/metrics/metric_registry.h> #include "http_proxy.h" @@ -43,19 +43,19 @@ protected: HFunc(TEvHttpProxy::TEvHttpConnectionClosed, Handle); HFunc(TEvHttpProxy::TEvResolveHostRequest, Handle); HFunc(TEvHttpProxy::TEvReportSensors, Handle); - HFunc(NActors::TEvents::TEvPoison, Handle); + HFunc(NActors::TEvents::TEvPoison, Handle); } } - void PassAway() override { - Send(Poller, new NActors::TEvents::TEvPoisonPill()); + void PassAway() override { + Send(Poller, new NActors::TEvents::TEvPoisonPill()); for (const NActors::TActorId& connection : Connections) { - Send(connection, new NActors::TEvents::TEvPoisonPill()); + Send(connection, new NActors::TEvents::TEvPoisonPill()); } for (const NActors::TActorId& acceptor : Acceptors) { - Send(acceptor, new NActors::TEvents::TEvPoisonPill()); + Send(acceptor, new NActors::TEvents::TEvPoisonPill()); } - NActors::TActorBootstrapped<THttpProxy>::PassAway(); + NActors::TActorBootstrapped<THttpProxy>::PassAway(); } void Handle(TEvHttpProxy::TEvHttpIncomingRequest::TPtr event, const NActors::TActorContext& ctx) { @@ -200,10 +200,10 @@ protected: NMonitoring::ExplicitHistogram({1, 5, 10, 50, 100, 500, 1000, 5000, 10000, 30000, 60000}))->Record(sensors.Time.MilliSeconds()); } - void Handle(NActors::TEvents::TEvPoison::TPtr, const NActors::TActorContext&) { - PassAway(); - } - + void Handle(NActors::TEvents::TEvPoison::TPtr, const NActors::TActorContext&) { + PassAway(); + } + NActors::TActorId Poller; TVector<TActorId> Acceptors; diff --git a/library/cpp/streams/lz/lz.cpp b/library/cpp/streams/lz/lz.cpp index de090a257c..b65bb3ed96 100644 --- a/library/cpp/streams/lz/lz.cpp +++ b/library/cpp/streams/lz/lz.cpp @@ -3,7 +3,7 @@ #include <util/system/yassert.h> #include <util/system/byteorder.h> #include <util/memory/addstorage.h> -#include <util/generic/buffer.h> +#include <util/generic/buffer.h> #include <util/generic/utility.h> #include <util/generic/singleton.h> #include <util/generic/yexception.h> @@ -193,8 +193,8 @@ public: , Version_(CheckVer(Load<ui32>())) , BlockSize_(Load<ui16>()) , OutBufSize_(TDecompressor::Hint(BlockSize_)) - , Tmp_(2 * OutBufSize_) - , In_(Tmp_.Data()) + , Tmp_(2 * OutBufSize_) + , In_(Tmp_.Data()) , Out_(In_ + OutBufSize_) { this->InitFromStream(Slave_); @@ -237,9 +237,9 @@ public: TMemoryInput header(tmp, sizeof(tmp)); const ui16 len = GLoad<ui16>(&header); - if (len > Tmp_.Capacity()) { - ythrow TDecompressorError() << "invalid len inside block header"; - } + if (len > Tmp_.Capacity()) { + ythrow TDecompressorError() << "invalid len inside block header"; + } const ui8 compressed = GLoad<ui8>(&header); if (compressed > 1) { @@ -271,7 +271,7 @@ protected: const ui32 Version_; const ui16 BlockSize_; const size_t OutBufSize_; - TBuffer Tmp_; + TBuffer Tmp_; char* In_; char* Out_; }; diff --git a/library/cpp/streams/lz/lz_ut.cpp b/library/cpp/streams/lz/lz_ut.cpp index 5949f397c1..6876f070fc 100644 --- a/library/cpp/streams/lz/lz_ut.cpp +++ b/library/cpp/streams/lz/lz_ut.cpp @@ -275,13 +275,13 @@ Y_UNIT_TEST_SUITE(TLzTest) { UNIT_ASSERT_EQUAL(is->ReadAll(), "123456789"); } - - Y_UNIT_TEST(TestYQ609) { - auto data = NResource::Find("/yq_609.data"); - - TMemoryInput input(data.Data(), data.Size()); - - TLz4Decompress d(&input); - UNIT_ASSERT_EXCEPTION(d.ReadAll(), TDecompressorError); - } + + Y_UNIT_TEST(TestYQ609) { + auto data = NResource::Find("/yq_609.data"); + + TMemoryInput input(data.Data(), data.Size()); + + TLz4Decompress d(&input); + UNIT_ASSERT_EXCEPTION(d.ReadAll(), TDecompressorError); + } } diff --git a/library/cpp/streams/lz/ut/ya.make b/library/cpp/streams/lz/ut/ya.make index ca35b53f10..18288c8ac9 100644 --- a/library/cpp/streams/lz/ut/ya.make +++ b/library/cpp/streams/lz/ut/ya.make @@ -8,7 +8,7 @@ OWNER( RESOURCE( random.data /random.data request.data /request.data - yq_609.data /yq_609.data + yq_609.data /yq_609.data ) SRCS( diff --git a/library/cpp/streams/lz/ut/yq_609.data b/library/cpp/streams/lz/ut/yq_609.data Binary files differindex 144f4b4cc7..9694b0c97f 100644 --- a/library/cpp/streams/lz/ut/yq_609.data +++ b/library/cpp/streams/lz/ut/yq_609.data |