aboutsummaryrefslogtreecommitdiffstats
path: root/library
diff options
context:
space:
mode:
authord-mokhnatkin <d-mokhnatkin@yandex-team.ru>2022-02-10 16:50:43 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:50:43 +0300
commitd94e393f3d35cf42ec17be6dc35149893a0b49cf (patch)
tree5d5cb817648f650d76cf1076100726fd9b8448e8 /library
parent4a2fe1d5dc0a49394dec49309de618073ccd14b7 (diff)
downloadydb-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.cpp22
-rw-r--r--library/cpp/streams/lz/lz.cpp14
-rw-r--r--library/cpp/streams/lz/lz_ut.cpp18
-rw-r--r--library/cpp/streams/lz/ut/ya.make2
-rw-r--r--library/cpp/streams/lz/ut/yq_609.databin722 -> 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
index 144f4b4cc7..9694b0c97f 100644
--- a/library/cpp/streams/lz/ut/yq_609.data
+++ b/library/cpp/streams/lz/ut/yq_609.data
Binary files differ