aboutsummaryrefslogtreecommitdiffstats
path: root/util/stream
diff options
context:
space:
mode:
authormelkov <melkov@yandex-team.ru>2022-02-10 16:48:14 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:48:14 +0300
commit2c532b38e6aeb4fd88531027c7335690fd34c4e5 (patch)
treeb222e5ac2e2e98872661c51ccceee5da0d291e13 /util/stream
parent438546c8737d5c1fdeb31157dcf999717d930eec (diff)
downloadydb-2c532b38e6aeb4fd88531027c7335690fd34c4e5.tar.gz
Restoring authorship annotation for <melkov@yandex-team.ru>. Commit 2 of 2.
Diffstat (limited to 'util/stream')
-rw-r--r--util/stream/direct_io_ut.cpp14
-rw-r--r--util/stream/input_ut.cpp8
2 files changed, 11 insertions, 11 deletions
diff --git a/util/stream/direct_io_ut.cpp b/util/stream/direct_io_ut.cpp
index 29f7858ecf..01d09db232 100644
--- a/util/stream/direct_io_ut.cpp
+++ b/util/stream/direct_io_ut.cpp
@@ -8,8 +8,8 @@
#include "direct_io.h"
Y_UNIT_TEST_SUITE(TDirectIOTests) {
- // Decrease numBufToWrite further if tests continue to time out
- static void Y_NO_INLINE Test(EOpenMode mode, size_t numBufToWrite) {
+ // Decrease numBufToWrite further if tests continue to time out
+ static void Y_NO_INLINE Test(EOpenMode mode, size_t numBufToWrite) {
const char TEMPLATE[] = "qwertyuiopQWERTYUIOPasdfghjklASD";
const auto TEMPLATE_SIZE = Y_ARRAY_SIZE(TEMPLATE) - 1;
static_assert(TEMPLATE_SIZE > 0, "must be greater than zero");
@@ -33,7 +33,7 @@ Y_UNIT_TEST_SUITE(TDirectIOTests) {
auto&& directIOBuffer = TDirectIOBufferedFile{fileName, RdWr | CreateAlways | mode};
{
auto&& output = TRandomAccessFileOutput{directIOBuffer};
- for (size_t i = 0; i < numBufToWrite; ++i) {
+ for (size_t i = 0; i < numBufToWrite; ++i) {
output.Write(buffer.Data(), BUFFER_SIZE);
}
}
@@ -54,18 +54,18 @@ Y_UNIT_TEST_SUITE(TDirectIOTests) {
}
}
- UNIT_ASSERT_VALUES_EQUAL(bytesRead, numBufToWrite * BUFFER_SIZE);
+ UNIT_ASSERT_VALUES_EQUAL(bytesRead, numBufToWrite * BUFFER_SIZE);
}
Y_UNIT_TEST(ReadWriteTest) {
- Test(0, 100 * 32);
+ Test(0, 100 * 32);
}
Y_UNIT_TEST(ReadWriteDirectTest) {
- Test(Direct, 100 * 4);
+ Test(Direct, 100 * 4);
}
Y_UNIT_TEST(ReadWriteDirectSeqTest) {
- Test(Direct | Seq, 100 * 4);
+ Test(Direct | Seq, 100 * 4);
}
}
diff --git a/util/stream/input_ut.cpp b/util/stream/input_ut.cpp
index 20469cf551..4a93f5458e 100644
--- a/util/stream/input_ut.cpp
+++ b/util/stream/input_ut.cpp
@@ -6,10 +6,10 @@
#include <util/system/file.h>
#include <util/system/yassert.h>
-#ifdef _win_
+#ifdef _win_
#include <io.h>
-#endif
-
+#endif
+
class TMockStdIn {
public:
TMockStdIn()
@@ -28,7 +28,7 @@ public:
tempFile.Seek(0, sSet);
TFileHandle tempFh(tempFile.GetHandle());
- tempFh.Duplicate2Posix(0);
+ tempFh.Duplicate2Posix(0);
tempFh.Release();
func();