aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorkostik <kostik@yandex-team.ru>2022-02-10 16:49:22 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:49:22 +0300
commitf7619e21ba894db354477390e8fe96256a6eb14a (patch)
treeb69d940766676eea8fd8d90570ed4f2783014d58
parenta6f6b22bda21d53d07bd2e0ff63a2b2abf69ede9 (diff)
downloadydb-f7619e21ba894db354477390e8fe96256a6eb14a.tar.gz
Restoring authorship annotation for <kostik@yandex-team.ru>. Commit 1 of 2.
-rw-r--r--library/cpp/messagebus/oldmodule/module.h6
-rw-r--r--library/cpp/messagebus/ybus.h2
-rw-r--r--library/cpp/yson/parser.cpp14
-rw-r--r--library/cpp/yson/parser.h10
-rw-r--r--library/cpp/yson/parser_detail.h8
-rw-r--r--util/generic/ptr.h8
-rw-r--r--util/system/event.cpp16
-rw-r--r--util/system/event.h4
-rw-r--r--util/system/file.cpp16
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