diff options
| author | d-mokhnatkin <[email protected]> | 2022-02-10 16:50:43 +0300 | 
|---|---|---|
| committer | Daniil Cherednik <[email protected]> | 2022-02-10 16:50:43 +0300 | 
| commit | d94e393f3d35cf42ec17be6dc35149893a0b49cf (patch) | |
| tree | 5d5cb817648f650d76cf1076100726fd9b8448e8 /library/cpp | |
| parent | 4a2fe1d5dc0a49394dec49309de618073ccd14b7 (diff) | |
Restoring authorship annotation for <[email protected]>. Commit 2 of 2.
Diffstat (limited to 'library/cpp')
| -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 4b57a8453dc..36c6855d93f 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 de090a257c9..b65bb3ed965 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 5949f397c1b..6876f070fc0 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 ca35b53f101..18288c8ac91 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 144f4b4cc70..9694b0c97f1 100644 --- a/library/cpp/streams/lz/ut/yq_609.data +++ b/library/cpp/streams/lz/ut/yq_609.data  | 
