diff options
author | nikitamorozov <[email protected]> | 2022-02-10 16:49:20 +0300 |
---|---|---|
committer | Daniil Cherednik <[email protected]> | 2022-02-10 16:49:20 +0300 |
commit | 523d26598d9784601932189f7fceb34d61bf7641 (patch) | |
tree | 5d5cb817648f650d76cf1076100726fd9b8448e8 /util/stream/buffered.cpp | |
parent | 2342f2b56e674c21307fcb92a37853f950224d31 (diff) |
Restoring authorship annotation for <[email protected]>. Commit 2 of 2.
Diffstat (limited to 'util/stream/buffered.cpp')
-rw-r--r-- | util/stream/buffered.cpp | 58 |
1 files changed, 29 insertions, 29 deletions
diff --git a/util/stream/buffered.cpp b/util/stream/buffered.cpp index 770b183af97..a00e592e1c4 100644 --- a/util/stream/buffered.cpp +++ b/util/stream/buffered.cpp @@ -163,21 +163,21 @@ public: MemOut_.Reset(Buf(), Len()); } - inline size_t Next(void** ptr) { - if (MemOut_.Avail() == 0) { - Slave_->Write(Buf(), Stored()); - OnBufferExhausted(); - Reset(); - } - - return MemOut_.Next(ptr); - } - - inline void Undo(size_t len) { - Y_VERIFY(len <= Stored(), "trying to undo more bytes than actually written"); - MemOut_.Undo(len); - } - + inline size_t Next(void** ptr) { + if (MemOut_.Avail() == 0) { + Slave_->Write(Buf(), Stored()); + OnBufferExhausted(); + Reset(); + } + + return MemOut_.Next(ptr); + } + + inline void Undo(size_t len) { + Y_VERIFY(len <= Stored(), "trying to undo more bytes than actually written"); + MemOut_.Undo(len); + } + inline void Write(const void* buf, size_t len) { if (len <= MemOut_.Avail()) { /* @@ -367,24 +367,24 @@ TBufferedOutputBase::~TBufferedOutputBase() { } } -size_t TBufferedOutputBase::DoNext(void** ptr) { - Y_ENSURE(Impl_.Get(), "cannot call next in finished stream"); - return Impl_->Next(ptr); -} - -void TBufferedOutputBase::DoUndo(size_t len) { - Y_ENSURE(Impl_.Get(), "cannot call undo in finished stream"); - Impl_->Undo(len); -} - +size_t TBufferedOutputBase::DoNext(void** ptr) { + Y_ENSURE(Impl_.Get(), "cannot call next in finished stream"); + return Impl_->Next(ptr); +} + +void TBufferedOutputBase::DoUndo(size_t len) { + Y_ENSURE(Impl_.Get(), "cannot call undo in finished stream"); + Impl_->Undo(len); +} + void TBufferedOutputBase::DoWrite(const void* data, size_t len) { - Y_ENSURE(Impl_.Get(), "cannot write to finished stream"); - Impl_->Write(data, len); + Y_ENSURE(Impl_.Get(), "cannot write to finished stream"); + Impl_->Write(data, len); } void TBufferedOutputBase::DoWriteC(char c) { - Y_ENSURE(Impl_.Get(), "cannot write to finished stream"); - Impl_->Write(c); + Y_ENSURE(Impl_.Get(), "cannot write to finished stream"); + Impl_->Write(c); } void TBufferedOutputBase::DoFlush() { |