diff options
author | kostik <kostik@yandex-team.ru> | 2022-02-10 16:49:22 +0300 |
---|---|---|
committer | Daniil Cherednik <dcherednik@yandex-team.ru> | 2022-02-10 16:49:22 +0300 |
commit | f7619e21ba894db354477390e8fe96256a6eb14a (patch) | |
tree | b69d940766676eea8fd8d90570ed4f2783014d58 | |
parent | a6f6b22bda21d53d07bd2e0ff63a2b2abf69ede9 (diff) | |
download | ydb-f7619e21ba894db354477390e8fe96256a6eb14a.tar.gz |
Restoring authorship annotation for <kostik@yandex-team.ru>. Commit 1 of 2.
-rw-r--r-- | library/cpp/messagebus/oldmodule/module.h | 6 | ||||
-rw-r--r-- | library/cpp/messagebus/ybus.h | 2 | ||||
-rw-r--r-- | library/cpp/yson/parser.cpp | 14 | ||||
-rw-r--r-- | library/cpp/yson/parser.h | 10 | ||||
-rw-r--r-- | library/cpp/yson/parser_detail.h | 8 | ||||
-rw-r--r-- | util/generic/ptr.h | 8 | ||||
-rw-r--r-- | util/system/event.cpp | 16 | ||||
-rw-r--r-- | util/system/event.h | 4 | ||||
-rw-r--r-- | util/system/file.cpp | 16 |
9 files changed, 42 insertions, 42 deletions
diff --git a/library/cpp/messagebus/oldmodule/module.h b/library/cpp/messagebus/oldmodule/module.h index 8d1c4a5d52b..050f9c92ed8 100644 --- a/library/cpp/messagebus/oldmodule/module.h +++ b/library/cpp/messagebus/oldmodule/module.h @@ -8,7 +8,7 @@ /// modules that communicate with multiple external or local sessions /// NBus::TBusSession. -/// To implement the module some virtual functions needs to be overridden: +/// To implement the module some virtual functions needs to be overridden: /// NBus::TBusModule::CreateExtSession() creates and registers an /// external session that receives incoming messages as input for module @@ -25,11 +25,11 @@ /// factory method NBus::IJobFactory::CreateJobInstance() to create your instances. /// Processing of a given message starts with a call to NBus::TBusModule::Start() -/// handler that should be overridden in the module implementation. Within +/// handler that should be overridden in the module implementation. Within /// the callback handler module can perform any computation and access any /// datastore tables that it needs. The handler can also access any module /// variables. However, same handler can be called from multiple threads so, -/// it is recommended that handler only access read-only module level variables. +/// it is recommended that handler only access read-only module level variables. /// Handler should use NBus::TBusJob::Send() to send messages to other client /// sessions and it can use NBus::TBusJob::Reply() to send reply to the main diff --git a/library/cpp/messagebus/ybus.h b/library/cpp/messagebus/ybus.h index de21ad85216..94f12de7c51 100644 --- a/library/cpp/messagebus/ybus.h +++ b/library/cpp/messagebus/ybus.h @@ -1,6 +1,6 @@ #pragma once -/// Asynchronous Messaging Library implements framework for sending and +/// Asynchronous Messaging Library implements framework for sending and /// receiving messages between loosely connected processes. #include "coreconn.h" diff --git a/library/cpp/yson/parser.cpp b/library/cpp/yson/parser.cpp index 783f9b90479..95cfbb13b1f 100644 --- a/library/cpp/yson/parser.cpp +++ b/library/cpp/yson/parser.cpp @@ -161,19 +161,19 @@ namespace NYson { TYsonListParser::TYsonListParser( NYT::NYson::IYsonConsumer* consumer, IInputStream* stream, - bool enableLinePositionInfo, + bool enableLinePositionInfo, TMaybe<ui64> memoryLimit) : Impl(new TImpl(consumer, stream, enableLinePositionInfo, memoryLimit)) - { - } - + { + } + TYsonListParser::~TYsonListParser() { } - + bool TYsonListParser::Parse() { return Impl->Parse(); } - + //////////////////////////////////////////////////////////////////////////////// - + } // namespace NYson diff --git a/library/cpp/yson/parser.h b/library/cpp/yson/parser.h index dce35a8cd40..c83fd921f4e 100644 --- a/library/cpp/yson/parser.h +++ b/library/cpp/yson/parser.h @@ -61,23 +61,23 @@ namespace NYson { TMaybe<ui64> memoryLimit = Nothing()); ~TYsonListParser(); - + bool Parse(); // Returns false, if there is no more list items - + private: class TImpl; THolder<TImpl> Impl; }; - + //////////////////////////////////////////////////////////////////////////////// - + void ParseYsonStringBuffer( const TStringBuf& buffer, NYT::NYson::IYsonConsumer* consumer, EYsonType type = ::NYson::EYsonType::Node, bool enableLinePositionInfo = false, TMaybe<ui64> memoryLimit = Nothing()); - + //////////////////////////////////////////////////////////////////////////////// } // namespace NYson diff --git a/library/cpp/yson/parser_detail.h b/library/cpp/yson/parser_detail.h index 44223caf125..c4820f5ca71 100644 --- a/library/cpp/yson/parser_detail.h +++ b/library/cpp/yson/parser_detail.h @@ -58,7 +58,7 @@ namespace NYson { TBase::SkipCharToken(EndAttributesSymbol); Consumer->OnEndAttributes(); } - + void ParseMap() { Consumer->OnBeginMap(); ParseMapFragment(EndMapSymbol); @@ -323,11 +323,11 @@ namespace NYson { class TStatelessYsonParserImplBase { public: virtual void Parse(const TStringBuf& data, EYsonType type = ::NYson::EYsonType::Node) = 0; - + virtual ~TStatelessYsonParserImplBase() { - } + } }; - + template <class TConsumer, bool EnableLinePositionInfo> class TStatelessYsonParserImpl : public TStatelessYsonParserImplBase { diff --git a/util/generic/ptr.h b/util/generic/ptr.h index 19db0e3ec55..36b5438e58d 100644 --- a/util/generic/ptr.h +++ b/util/generic/ptr.h @@ -548,8 +548,8 @@ public: // Reset(TIntrusivePtr&&) inline void Reset(TIntrusivePtr t) noexcept { Swap(t); - } - + } + inline void Reset() noexcept { Drop(); } @@ -668,8 +668,8 @@ public: // Reset(TIntrusiveConstPtr&&) inline void Reset(TIntrusiveConstPtr t) noexcept { Swap(t); - } - + } + inline void Reset() noexcept { Drop(); } diff --git a/util/system/event.cpp b/util/system/event.cpp index 79b3cdb2917..998ca978ab8 100644 --- a/util/system/event.cpp +++ b/util/system/event.cpp @@ -113,15 +113,15 @@ TSystemEvent::TSystemEvent(ResetMode rmode) } TSystemEvent::TSystemEvent(const TSystemEvent& other) noexcept - : EvImpl_(other.EvImpl_) -{ -} - + : EvImpl_(other.EvImpl_) +{ +} + TSystemEvent& TSystemEvent::operator=(const TSystemEvent& other) noexcept { - EvImpl_ = other.EvImpl_; - return *this; -} - + EvImpl_ = other.EvImpl_; + return *this; +} + TSystemEvent::~TSystemEvent() = default; void TSystemEvent::Reset() noexcept { diff --git a/util/system/event.h b/util/system/event.h index cab2fc478ab..6424d3352be 100644 --- a/util/system/event.h +++ b/util/system/event.h @@ -21,7 +21,7 @@ public: TSystemEvent(ResetMode rmode = rManual); TSystemEvent(const TSystemEvent& other) noexcept; TSystemEvent& operator=(const TSystemEvent& other) noexcept; - + ~TSystemEvent(); void Reset() noexcept; @@ -59,7 +59,7 @@ public: private: class TEvImpl; - TIntrusivePtr<TEvImpl> EvImpl_; + TIntrusivePtr<TEvImpl> EvImpl_; }; class TAutoEvent: public TSystemEvent { diff --git a/util/system/file.cpp b/util/system/file.cpp index 4a261d020cb..847be59b6c2 100644 --- a/util/system/file.cpp +++ b/util/system/file.cpp @@ -470,11 +470,11 @@ i32 TFileHandle::Read(void* buffer, ui32 byteCount) noexcept { } return -1; #elif defined(_unix_) - i32 ret; + i32 ret; do { ret = ::read(Fd_, buffer, byteCount); } while (ret == -1 && errno == EINTR); - return ret; + return ret; #else #error unsupported platform #endif @@ -491,11 +491,11 @@ i32 TFileHandle::Write(const void* buffer, ui32 byteCount) noexcept { } return -1; #elif defined(_unix_) - i32 ret; + i32 ret; do { ret = ::write(Fd_, buffer, byteCount); } while (ret == -1 && errno == EINTR); - return ret; + return ret; #else #error unsupported platform #endif @@ -516,11 +516,11 @@ i32 TFileHandle::Pread(void* buffer, ui32 byteCount, i64 offset) const noexcept } return -1; #elif defined(_unix_) - i32 ret; + i32 ret; do { ret = ::pread(Fd_, buffer, byteCount, offset); } while (ret == -1 && errno == EINTR); - return ret; + return ret; #else #error unsupported platform #endif @@ -538,11 +538,11 @@ i32 TFileHandle::Pwrite(const void* buffer, ui32 byteCount, i64 offset) const no } return -1; #elif defined(_unix_) - i32 ret; + i32 ret; do { ret = ::pwrite(Fd_, buffer, byteCount, offset); } while (ret == -1 && errno == EINTR); - return ret; + return ret; #else #error unsupported platform #endif |