diff options
author | Alexey Salmin <alexey.salmin@gmail.com> | 2022-02-10 16:49:37 +0300 |
---|---|---|
committer | Daniil Cherednik <dcherednik@yandex-team.ru> | 2022-02-10 16:49:37 +0300 |
commit | 71af077a5dfe7e9f932a508422c2dac81a57ebc0 (patch) | |
tree | 5d5cb817648f650d76cf1076100726fd9b8448e8 /util/stream/buffered.cpp | |
parent | 3c5b1607b38f637d2f3313791ed25c2e080d2647 (diff) | |
download | ydb-71af077a5dfe7e9f932a508422c2dac81a57ebc0.tar.gz |
Restoring authorship annotation for Alexey Salmin <alexey.salmin@gmail.com>. Commit 2 of 2.
Diffstat (limited to 'util/stream/buffered.cpp')
-rw-r--r-- | util/stream/buffered.cpp | 34 |
1 files changed, 17 insertions, 17 deletions
diff --git a/util/stream/buffered.cpp b/util/stream/buffered.cpp index 229cb78423..a00e592e1c 100644 --- a/util/stream/buffered.cpp +++ b/util/stream/buffered.cpp @@ -193,16 +193,16 @@ public: using TPart = IOutputStream::TPart; - alignas(TPart) char data[2 * sizeof(TPart)]; - TPart* parts = reinterpret_cast<TPart*>(data); + alignas(TPart) char data[2 * sizeof(TPart)]; + TPart* parts = reinterpret_cast<TPart*>(data); TPart* end = parts; if (stored) { - new (end++) TPart(Buf(), stored); + new (end++) TPart(Buf(), stored); } if (write_from_buf) { - new (end++) TPart(buf, write_from_buf); + new (end++) TPart(buf, write_from_buf); } Slave_->Write(parts, end - parts); @@ -217,16 +217,16 @@ public: } } - inline void Write(char c) { - if (Y_UNLIKELY(MemOut_.Avail() == 0)) { - Slave_->Write(Buf(), Stored()); - OnBufferExhausted(); - Reset(); - } - - MemOut_.Write(c); - } - + inline void Write(char c) { + if (Y_UNLIKELY(MemOut_.Avail() == 0)) { + Slave_->Write(Buf(), Stored()); + OnBufferExhausted(); + Reset(); + } + + MemOut_.Write(c); + } + inline void SetFlushPropagateMode(bool mode) noexcept { PropagateFlush_ = mode; } @@ -382,11 +382,11 @@ void TBufferedOutputBase::DoWrite(const void* data, size_t len) { Impl_->Write(data, len); } -void TBufferedOutputBase::DoWriteC(char c) { +void TBufferedOutputBase::DoWriteC(char c) { Y_ENSURE(Impl_.Get(), "cannot write to finished stream"); Impl_->Write(c); -} - +} + void TBufferedOutputBase::DoFlush() { if (Impl_.Get()) { Impl_->Flush(); |