aboutsummaryrefslogtreecommitdiffstats
path: root/util/stream
diff options
context:
space:
mode:
authororivej <orivej@yandex-team.ru>2022-02-10 16:44:49 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:44:49 +0300
commit718c552901d703c502ccbefdfc3c9028d608b947 (patch)
tree46534a98bbefcd7b1f3faa5b52c138ab27db75b7 /util/stream
parente9656aae26e0358d5378e5b63dcac5c8dbe0e4d0 (diff)
downloadydb-718c552901d703c502ccbefdfc3c9028d608b947.tar.gz
Restoring authorship annotation for <orivej@yandex-team.ru>. Commit 1 of 2.
Diffstat (limited to 'util/stream')
-rw-r--r--util/stream/direct_io.cpp8
-rw-r--r--util/stream/direct_io.h2
-rw-r--r--util/stream/output.cpp14
-rw-r--r--util/stream/str.cpp4
-rw-r--r--util/stream/str.h4
5 files changed, 16 insertions, 16 deletions
diff --git a/util/stream/direct_io.cpp b/util/stream/direct_io.cpp
index 649033af34..9f7de8e613 100644
--- a/util/stream/direct_io.cpp
+++ b/util/stream/direct_io.cpp
@@ -21,21 +21,21 @@ size_t TRandomAccessFileInput::DoSkip(size_t len) {
}
TRandomAccessFileOutput::TRandomAccessFileOutput(TDirectIOBufferedFile& file)
- : File(&file)
+ : File(&file)
{
}
void TRandomAccessFileOutput::DoWrite(const void* buf, size_t len) {
- File->Write(buf, len);
+ File->Write(buf, len);
}
void TRandomAccessFileOutput::DoFlush() {
- File->FlushData();
+ File->FlushData();
}
TBufferedFileOutputEx::TBufferedFileOutputEx(const TString& path, EOpenMode oMode, size_t buflen)
: TRandomAccessFileOutput(*(new TDirectIOBufferedFile(path, oMode, buflen)))
- , FileHolder(File)
+ , FileHolder(File)
{
}
diff --git a/util/stream/direct_io.h b/util/stream/direct_io.h
index 2e1f2e07dd..fed8e88c3a 100644
--- a/util/stream/direct_io.h
+++ b/util/stream/direct_io.h
@@ -25,7 +25,7 @@ public:
TRandomAccessFileOutput& operator=(TRandomAccessFileOutput&&) noexcept = default;
protected:
- TDirectIOBufferedFile* File;
+ TDirectIOBufferedFile* File;
private:
void DoWrite(const void* buf, size_t len) override;
diff --git a/util/stream/output.cpp b/util/stream/output.cpp
index db81b81b70..3abb22bed4 100644
--- a/util/stream/output.cpp
+++ b/util/stream/output.cpp
@@ -132,7 +132,7 @@ void Out<TUtf32StringBuf>(IOutputStream& o, const TUtf32StringBuf& p) {
template <>
void Out<const wchar16*>(IOutputStream& o, const wchar16* w) {
if (w) {
- WriteString(o, w, std::char_traits<wchar16>::length(w));
+ WriteString(o, w, std::char_traits<wchar16>::length(w));
} else {
o.Write("(null)");
}
@@ -141,7 +141,7 @@ void Out<const wchar16*>(IOutputStream& o, const wchar16* w) {
template <>
void Out<const wchar32*>(IOutputStream& o, const wchar32* w) {
if (w) {
- WriteString(o, w, std::char_traits<wchar32>::length(w));
+ WriteString(o, w, std::char_traits<wchar32>::length(w));
} else {
o.Write("(null)");
}
@@ -174,11 +174,11 @@ void Out<TUtf32String>(IOutputStream& o, const TUtf32String& w) {
void Out<type>(IOutputStream & o, type p) { \
char buf[len]; \
o.Write(buf, ToString(p, buf, sizeof(buf))); \
- } \
- \
- template <> \
- void Out<volatile type>(IOutputStream & o, volatile type p) { \
- Out<type>(o, p); \
+ } \
+ \
+ template <> \
+ void Out<volatile type>(IOutputStream & o, volatile type p) { \
+ Out<type>(o, p); \
}
DEF_CONV_NUM(bool, 64)
diff --git a/util/stream/str.cpp b/util/stream/str.cpp
index 13f0e8ef28..9622a1a254 100644
--- a/util/stream/str.cpp
+++ b/util/stream/str.cpp
@@ -5,8 +5,8 @@ static constexpr size_t MIN_BUFFER_GROW_SIZE = 16;
TStringInput::~TStringInput() = default;
size_t TStringInput::DoNext(const void** ptr, size_t len) {
- len = Min(len, S_->size() - Pos_);
- *ptr = S_->data() + Pos_;
+ len = Min(len, S_->size() - Pos_);
+ *ptr = S_->data() + Pos_;
Pos_ += len;
return len;
}
diff --git a/util/stream/str.h b/util/stream/str.h
index 028bd572c0..6233e73671 100644
--- a/util/stream/str.h
+++ b/util/stream/str.h
@@ -30,7 +30,7 @@ public:
* @param s String to read from.
*/
inline TStringInput(const TString& s) noexcept
- : S_(&s)
+ : S_(&s)
, Pos_(0)
{
}
@@ -52,7 +52,7 @@ protected:
void DoUndo(size_t len) override;
private:
- const TString* S_;
+ const TString* S_;
size_t Pos_;
friend class TStringStream;