summaryrefslogtreecommitdiffstats
path: root/util/stream/buffered.cpp
diff options
context:
space:
mode:
authornikitamorozov <[email protected]>2022-02-10 16:49:20 +0300
committerDaniil Cherednik <[email protected]>2022-02-10 16:49:20 +0300
commit523d26598d9784601932189f7fceb34d61bf7641 (patch)
tree5d5cb817648f650d76cf1076100726fd9b8448e8 /util/stream/buffered.cpp
parent2342f2b56e674c21307fcb92a37853f950224d31 (diff)
Restoring authorship annotation for <[email protected]>. Commit 2 of 2.
Diffstat (limited to 'util/stream/buffered.cpp')
-rw-r--r--util/stream/buffered.cpp58
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() {