diff options
author | aavdonkin <aavdonkin@yandex-team.ru> | 2022-02-10 16:49:57 +0300 |
---|---|---|
committer | Daniil Cherednik <dcherednik@yandex-team.ru> | 2022-02-10 16:49:57 +0300 |
commit | efc32853c4263131bc59412eaf1a9e4aaae2a1f9 (patch) | |
tree | 5d5cb817648f650d76cf1076100726fd9b8448e8 /util | |
parent | fc8d3fe40009fab7705035e6ffdc3eb334307c80 (diff) | |
download | ydb-efc32853c4263131bc59412eaf1a9e4aaae2a1f9.tar.gz |
Restoring authorship annotation for <aavdonkin@yandex-team.ru>. Commit 2 of 2.
Diffstat (limited to 'util')
-rw-r--r-- | util/datetime/cputimer.cpp | 2 | ||||
-rw-r--r-- | util/datetime/cputimer.h | 8 | ||||
-rw-r--r-- | util/generic/buffer.h | 28 | ||||
-rw-r--r-- | util/system/event.cpp | 4 | ||||
-rw-r--r-- | util/system/file.cpp | 58 | ||||
-rw-r--r-- | util/system/file.h | 6 | ||||
-rw-r--r-- | util/system/filemap.h | 4 | ||||
-rw-r--r-- | util/system/flock.h | 2 |
8 files changed, 56 insertions, 56 deletions
diff --git a/util/datetime/cputimer.cpp b/util/datetime/cputimer.cpp index fe39face85..516d372c37 100644 --- a/util/datetime/cputimer.cpp +++ b/util/datetime/cputimer.cpp @@ -15,7 +15,7 @@ #elif defined(_win_) #include <util/system/winint.h> #endif - + TTimer::TTimer(const TStringBuf message) { static const int SMALL_DURATION_CHAR_LENGTH = 9; // strlen("0.123456s") Message_.Reserve(message.length() + SMALL_DURATION_CHAR_LENGTH + 1); // +"\n" diff --git a/util/datetime/cputimer.h b/util/datetime/cputimer.h index f2eff4dced..7d38d5bdb3 100644 --- a/util/datetime/cputimer.h +++ b/util/datetime/cputimer.h @@ -1,5 +1,5 @@ #pragma once - + #include "base.h" #include <util/system/rusage.h> @@ -11,11 +11,11 @@ private: TInstant Start_; TStringStream Message_; -public: +public: TTimer(const TStringBuf message = TStringBuf(" took: ")); ~TTimer(); -}; - +}; + class TSimpleTimer { TInstant T; diff --git a/util/generic/buffer.h b/util/generic/buffer.h index 1753fcdd64..9576467404 100644 --- a/util/generic/buffer.h +++ b/util/generic/buffer.h @@ -145,12 +145,12 @@ public: } } - inline void ReserveExactNeverCallMeInSaneCode(size_t len) { - if (len > Len_) { - Realloc(len); - } - } - + inline void ReserveExactNeverCallMeInSaneCode(size_t len) { + if (len > Len_) { + Realloc(len); + } + } + inline void ShrinkToFit() { if (Pos_ < Len_) { Realloc(Pos_); @@ -162,14 +162,14 @@ public: Pos_ = len; } - // Method works like Resize, but allocates exact specified number of bytes - // rather than rounded up to next power of 2 - // Use with care - inline void ResizeExactNeverCallMeInSaneCode(size_t len) { - ReserveExactNeverCallMeInSaneCode(len); - Pos_ = len; - } - + // Method works like Resize, but allocates exact specified number of bytes + // rather than rounded up to next power of 2 + // Use with care + inline void ResizeExactNeverCallMeInSaneCode(size_t len) { + ReserveExactNeverCallMeInSaneCode(len); + Pos_ = len; + } + inline size_t Capacity() const noexcept { return Len_; } diff --git a/util/system/event.cpp b/util/system/event.cpp index 3784f686ff..79b3cdb291 100644 --- a/util/system/event.cpp +++ b/util/system/event.cpp @@ -130,8 +130,8 @@ void TSystemEvent::Reset() noexcept { void TSystemEvent::Signal() noexcept { EvImpl_->Signal(); -} - +} + bool TSystemEvent::WaitD(TInstant deadLine) noexcept { return EvImpl_->WaitD(deadLine); } diff --git a/util/system/file.cpp b/util/system/file.cpp index 9edd8a82f2..4a261d020c 100644 --- a/util/system/file.cpp +++ b/util/system/file.cpp @@ -626,7 +626,7 @@ int TFileHandle::Flock(int op) noexcept { } bool TFileHandle::SetDirect() { -#ifdef _linux_ +#ifdef _linux_ const long flags = fcntl(Fd_, F_GETFL); const int r = fcntl(Fd_, F_SETFL, flags | O_DIRECT); @@ -634,15 +634,15 @@ bool TFileHandle::SetDirect() { #endif return false; -} - -void TFileHandle::ResetDirect() { -#ifdef _linux_ - long flags = fcntl(Fd_, F_GETFL); - fcntl(Fd_, F_SETFL, flags & ~O_DIRECT); -#endif -} - +} + +void TFileHandle::ResetDirect() { +#ifdef _linux_ + long flags = fcntl(Fd_, F_GETFL); + fcntl(Fd_, F_SETFL, flags & ~O_DIRECT); +#endif +} + i64 TFileHandle::CountCache(i64 offset, i64 length) const noexcept { #ifdef _linux_ const i64 pageSize = NSystemInfo::GetPageSize(); @@ -940,8 +940,8 @@ public: i32 RawRead(void* bufferIn, size_t numBytes) { const size_t toRead = Min(MaxReadPortion, numBytes); return Handle_.Read(bufferIn, toRead); - } - + } + size_t ReadOrFail(void* buf, size_t numBytes) { const i32 reallyRead = RawRead(buf, numBytes); @@ -1054,16 +1054,16 @@ public: } } - void SetDirect() { + void SetDirect() { if (!Handle_.SetDirect()) { ythrow TFileError() << "can't set direct mode for " << FileName_.Quote(); } - } - - void ResetDirect() { - Handle_.ResetDirect(); - } - + } + + void ResetDirect() { + Handle_.ResetDirect(); + } + i64 CountCache(i64 offset, i64 length) const noexcept { return Handle_.CountCache(offset, length); } @@ -1173,8 +1173,8 @@ size_t TFile::Read(void* buf, size_t len) { i32 TFile::RawRead(void* buf, size_t len) { return Impl_->RawRead(buf, len); -} - +} + size_t TFile::ReadOrFail(void* buf, size_t len) { return Impl_->ReadOrFail(buf, len); } @@ -1207,14 +1207,14 @@ void TFile::Flock(int op) { Impl_->Flock(op); } -void TFile::SetDirect() { - Impl_->SetDirect(); -} - -void TFile::ResetDirect() { - Impl_->ResetDirect(); -} - +void TFile::SetDirect() { + Impl_->SetDirect(); +} + +void TFile::ResetDirect() { + Impl_->ResetDirect(); +} + i64 TFile::CountCache(i64 offset, i64 length) const noexcept { return Impl_->CountCache(offset, length); } diff --git a/util/system/file.h b/util/system/file.h index 8b6086343c..9502e159b6 100644 --- a/util/system/file.h +++ b/util/system/file.h @@ -127,7 +127,7 @@ public: //very low-level methods bool SetDirect(); - void ResetDirect(); + void ResetDirect(); /* Manual file cache management, length = 0 means "as much as possible" */ @@ -197,8 +197,8 @@ public: void Flock(int op); //do not use, their meaning very platform-dependant - void SetDirect(); - void ResetDirect(); + void SetDirect(); + void ResetDirect(); /* Manual file cache management, length = 0 means "as much as possible" */ diff --git a/util/system/filemap.h b/util/system/filemap.h index 46c10dd897..11be64bff4 100644 --- a/util/system/filemap.h +++ b/util/system/filemap.h @@ -314,7 +314,7 @@ public: char* End() const noexcept { return Begin() + MappedSize(); } - size_t MappedSize() const { + size_t MappedSize() const { return Size_; } void swap(TMappedAllocation& with); @@ -342,7 +342,7 @@ public: } T* Create(size_t siz) { Y_ASSERT(MappedSize() == 0 && Ptr() == nullptr); - T* arr = (T*)Alloc((sizeof(T) * siz)); + T* arr = (T*)Alloc((sizeof(T) * siz)); if (!arr) return nullptr; Y_ASSERT(MappedSize() == sizeof(T) * siz); diff --git a/util/system/flock.h b/util/system/flock.h index 4441cad955..797b1970a1 100644 --- a/util/system/flock.h +++ b/util/system/flock.h @@ -14,7 +14,7 @@ static inline int Flock(int fd, int op) { } #else // not _unix_ - + #ifdef __cplusplus extern "C" { #endif |