aboutsummaryrefslogtreecommitdiffstats
path: root/util/stream/direct_io.cpp
diff options
context:
space:
mode:
authoriddqd <iddqd@yandex-team.ru>2022-02-10 16:49:45 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:49:45 +0300
commit07fce9c5f7771600d0b3d70e1f88fd8a7e164d85 (patch)
treee4aa4750fbb864d70f8c06cf03d2750e979ea3bf /util/stream/direct_io.cpp
parentaf42068bf6cd93c976b80dd0388fa48cdf65da11 (diff)
downloadydb-07fce9c5f7771600d0b3d70e1f88fd8a7e164d85.tar.gz
Restoring authorship annotation for <iddqd@yandex-team.ru>. Commit 1 of 2.
Diffstat (limited to 'util/stream/direct_io.cpp')
-rw-r--r--util/stream/direct_io.cpp78
1 files changed, 39 insertions, 39 deletions
diff --git a/util/stream/direct_io.cpp b/util/stream/direct_io.cpp
index 649033af341..5aab0830e18 100644
--- a/util/stream/direct_io.cpp
+++ b/util/stream/direct_io.cpp
@@ -1,47 +1,47 @@
-#include "direct_io.h"
-
+#include "direct_io.h"
+
#include <util/generic/utility.h>
-size_t TRandomAccessFileInput::DoRead(void* buf, size_t len) {
- const size_t result = File.Pread(buf, len, Position);
- Position += result;
- return result;
-}
-
-TRandomAccessFileInput::TRandomAccessFileInput(TDirectIOBufferedFile& file, ui64 position)
- : File(file)
- , Position(position)
-{
-}
-
-size_t TRandomAccessFileInput::DoSkip(size_t len) {
+size_t TRandomAccessFileInput::DoRead(void* buf, size_t len) {
+ const size_t result = File.Pread(buf, len, Position);
+ Position += result;
+ return result;
+}
+
+TRandomAccessFileInput::TRandomAccessFileInput(TDirectIOBufferedFile& file, ui64 position)
+ : File(file)
+ , Position(position)
+{
+}
+
+size_t TRandomAccessFileInput::DoSkip(size_t len) {
size_t skiped = Min(len, (size_t)Min((ui64)Max<size_t>(), File.GetLength() - Position));
- Position += skiped;
- return skiped;
-}
-
-TRandomAccessFileOutput::TRandomAccessFileOutput(TDirectIOBufferedFile& file)
+ Position += skiped;
+ return skiped;
+}
+
+TRandomAccessFileOutput::TRandomAccessFileOutput(TDirectIOBufferedFile& file)
: File(&file)
-{
-}
-
-void TRandomAccessFileOutput::DoWrite(const void* buf, size_t len) {
+{
+}
+
+void TRandomAccessFileOutput::DoWrite(const void* buf, size_t len) {
File->Write(buf, len);
-}
-
-void TRandomAccessFileOutput::DoFlush() {
+}
+
+void TRandomAccessFileOutput::DoFlush() {
File->FlushData();
-}
-
+}
+
TBufferedFileOutputEx::TBufferedFileOutputEx(const TString& path, EOpenMode oMode, size_t buflen)
- : TRandomAccessFileOutput(*(new TDirectIOBufferedFile(path, oMode, buflen)))
+ : TRandomAccessFileOutput(*(new TDirectIOBufferedFile(path, oMode, buflen)))
, FileHolder(File)
-{
-}
-
-void TBufferedFileOutputEx::DoFinish() {
- FileHolder->Finish();
-}
-
-void TBufferedFileOutputEx::DoFlush() {
-}
+{
+}
+
+void TBufferedFileOutputEx::DoFinish() {
+ FileHolder->Finish();
+}
+
+void TBufferedFileOutputEx::DoFlush() {
+}