aboutsummaryrefslogtreecommitdiffstats
path: root/util/stream
diff options
context:
space:
mode:
authorleo <leo@yandex-team.ru>2022-02-10 16:46:40 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:46:40 +0300
commit980edcd3304699edf9d4e4d6a656e585028e2a72 (patch)
tree139f47f3911484ae9af0eb347b1a88bd6c4bb35f /util/stream
parentb036a557f285146e5e35d4213e29a094ab907bcf (diff)
downloadydb-980edcd3304699edf9d4e4d6a656e585028e2a72.tar.gz
Restoring authorship annotation for <leo@yandex-team.ru>. Commit 1 of 2.
Diffstat (limited to 'util/stream')
-rw-r--r--util/stream/file.cpp16
-rw-r--r--util/stream/file.h2
-rw-r--r--util/stream/pipe.cpp4
-rw-r--r--util/stream/zlib_ut.cpp2
4 files changed, 12 insertions, 12 deletions
diff --git a/util/stream/file.cpp b/util/stream/file.cpp
index dc5d2f6311..00b1827429 100644
--- a/util/stream/file.cpp
+++ b/util/stream/file.cpp
@@ -5,12 +5,12 @@
TUnbufferedFileInput::TUnbufferedFileInput(const TString& path)
: File_(path, OpenExisting | RdOnly | Seq)
-{
+{
if (!File_.IsOpen()) {
ythrow TIoException() << "file " << path << " not open";
- }
-}
-
+ }
+}
+
TUnbufferedFileInput::TUnbufferedFileInput(const TFile& file)
: File_(file)
{
@@ -80,7 +80,7 @@ public:
inline ~TImpl() = default;
};
-TMappedFileInput::TMappedFileInput(const TFile& file)
+TMappedFileInput::TMappedFileInput(const TFile& file)
: TMemoryInput(nullptr, 0)
, Impl_(new TImpl(file))
{
@@ -90,8 +90,8 @@ TMappedFileInput::TMappedFileInput(const TFile& file)
TMappedFileInput::TMappedFileInput(const TString& path)
: TMemoryInput(nullptr, 0)
, Impl_(new TImpl(TFile(path, OpenExisting | RdOnly)))
-{
+{
Reset(Impl_->Data(), Impl_->Size());
-}
-
+}
+
TMappedFileInput::~TMappedFileInput() = default;
diff --git a/util/stream/file.h b/util/stream/file.h
index c1cf4f591d..a0010a909c 100644
--- a/util/stream/file.h
+++ b/util/stream/file.h
@@ -6,7 +6,7 @@
#include "buffered.h"
#include "mem.h"
-#include <util/system/file.h>
+#include <util/system/file.h>
#include <utility>
/**
diff --git a/util/stream/pipe.cpp b/util/stream/pipe.cpp
index 51be1934a7..4f44b5ea60 100644
--- a/util/stream/pipe.cpp
+++ b/util/stream/pipe.cpp
@@ -39,7 +39,7 @@ TPipeBase::TPipeBase(const TString& command, const char* mode)
TPipeBase::~TPipeBase() = default;
TPipeInput::TPipeInput(const TString& command)
- : TPipeBase(command, "r")
+ : TPipeBase(command, "r")
{
}
@@ -62,7 +62,7 @@ size_t TPipeInput::DoRead(void* buf, size_t len) {
}
TPipeOutput::TPipeOutput(const TString& command)
- : TPipeBase(command, "w")
+ : TPipeBase(command, "w")
{
}
diff --git a/util/stream/zlib_ut.cpp b/util/stream/zlib_ut.cpp
index 2290b4a9de..b6b89e4a82 100644
--- a/util/stream/zlib_ut.cpp
+++ b/util/stream/zlib_ut.cpp
@@ -73,7 +73,7 @@ Y_UNIT_TEST_SUITE(TZLibTest) {
UNIT_ASSERT_EQUAL(d.ReadAll(), DATA);
}
- }
+ }
Y_UNIT_TEST(Dictionary) {
static constexpr TStringBuf data = "<html><body></body></html>";