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
commit99609724f661f7e21d1cb08e8d80e87c3632fdb3 (patch)
tree49e222ea1c5804306084bb3ae065bb702625360f /util/stream
parent980edcd3304699edf9d4e4d6a656e585028e2a72 (diff)
downloadydb-99609724f661f7e21d1cb08e8d80e87c3632fdb3.tar.gz
Restoring authorship annotation for <leo@yandex-team.ru>. Commit 2 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 00b1827429..dc5d2f6311 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 a0010a909c..c1cf4f591d 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 4f44b5ea60..51be1934a7 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 b6b89e4a82..2290b4a9de 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>";