Browse Source

Restoring authorship annotation for <kostik@yandex-team.ru>. Commit 2 of 2.

kostik 3 years ago
parent
commit
89516f2fd8

+ 3 - 3
library/cpp/messagebus/oldmodule/module.h

@@ -8,7 +8,7 @@
 /// modules that communicate with multiple external or local sessions
 /// modules that communicate with multiple external or local sessions
 /// NBus::TBusSession.
 /// 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
 /// NBus::TBusModule::CreateExtSession() creates and registers an
 /// external session that receives incoming messages as input for module
 /// external session that receives incoming messages as input for module
@@ -25,11 +25,11 @@
 /// factory method NBus::IJobFactory::CreateJobInstance() to create your instances.
 /// factory method NBus::IJobFactory::CreateJobInstance() to create your instances.
 
 
 /// Processing of a given message starts with a call to NBus::TBusModule::Start()
 /// 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
 /// the callback handler module can perform any computation and access any
 /// datastore tables that it needs. The handler can also access any module
 /// datastore tables that it needs. The handler can also access any module
 /// variables. However, same handler can be called from multiple threads so,
 /// 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
 /// 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
 /// sessions and it can use NBus::TBusJob::Reply() to send reply to the main

+ 1 - 1
library/cpp/messagebus/ybus.h

@@ -1,6 +1,6 @@
 #pragma once
 #pragma once
 
 
-/// Asynchronous Messaging Library implements framework for sending and 
+/// Asynchronous Messaging Library implements framework for sending and
 /// receiving messages between loosely connected processes.
 /// receiving messages between loosely connected processes.
 
 
 #include "coreconn.h"
 #include "coreconn.h"

+ 7 - 7
library/cpp/yson/parser.cpp

@@ -161,19 +161,19 @@ namespace NYson {
     TYsonListParser::TYsonListParser(
     TYsonListParser::TYsonListParser(
         NYT::NYson::IYsonConsumer* consumer,
         NYT::NYson::IYsonConsumer* consumer,
         IInputStream* stream,
         IInputStream* stream,
-        bool enableLinePositionInfo, 
+        bool enableLinePositionInfo,
         TMaybe<ui64> memoryLimit)
         TMaybe<ui64> memoryLimit)
         : Impl(new TImpl(consumer, stream, enableLinePositionInfo, memoryLimit))
         : Impl(new TImpl(consumer, stream, enableLinePositionInfo, memoryLimit))
-    { 
+    {
-    } 
+    }
- 
+
     TYsonListParser::~TYsonListParser() {
     TYsonListParser::~TYsonListParser() {
     }
     }
- 
+
     bool TYsonListParser::Parse() {
     bool TYsonListParser::Parse() {
         return Impl->Parse();
         return Impl->Parse();
     }
     }
- 
+
     ////////////////////////////////////////////////////////////////////////////////
     ////////////////////////////////////////////////////////////////////////////////
- 
+
 } // namespace NYson
 } // namespace NYson

+ 5 - 5
library/cpp/yson/parser.h

@@ -61,23 +61,23 @@ namespace NYson {
             TMaybe<ui64> memoryLimit = Nothing());
             TMaybe<ui64> memoryLimit = Nothing());
 
 
         ~TYsonListParser();
         ~TYsonListParser();
- 
+
         bool Parse(); // Returns false, if there is no more list items
         bool Parse(); // Returns false, if there is no more list items
- 
+
     private:
     private:
         class TImpl;
         class TImpl;
         THolder<TImpl> Impl;
         THolder<TImpl> Impl;
     };
     };
- 
+
     ////////////////////////////////////////////////////////////////////////////////
     ////////////////////////////////////////////////////////////////////////////////
- 
+
     void ParseYsonStringBuffer(
     void ParseYsonStringBuffer(
         const TStringBuf& buffer,
         const TStringBuf& buffer,
         NYT::NYson::IYsonConsumer* consumer,
         NYT::NYson::IYsonConsumer* consumer,
         EYsonType type = ::NYson::EYsonType::Node,
         EYsonType type = ::NYson::EYsonType::Node,
         bool enableLinePositionInfo = false,
         bool enableLinePositionInfo = false,
         TMaybe<ui64> memoryLimit = Nothing());
         TMaybe<ui64> memoryLimit = Nothing());
- 
+
     ////////////////////////////////////////////////////////////////////////////////
     ////////////////////////////////////////////////////////////////////////////////
 
 
 } // namespace NYson
 } // namespace NYson

+ 4 - 4
library/cpp/yson/parser_detail.h

@@ -58,7 +58,7 @@ namespace NYson {
                 TBase::SkipCharToken(EndAttributesSymbol);
                 TBase::SkipCharToken(EndAttributesSymbol);
                 Consumer->OnEndAttributes();
                 Consumer->OnEndAttributes();
             }
             }
- 
+
             void ParseMap() {
             void ParseMap() {
                 Consumer->OnBeginMap();
                 Consumer->OnBeginMap();
                 ParseMapFragment(EndMapSymbol);
                 ParseMapFragment(EndMapSymbol);
@@ -323,11 +323,11 @@ namespace NYson {
     class TStatelessYsonParserImplBase {
     class TStatelessYsonParserImplBase {
     public:
     public:
         virtual void Parse(const TStringBuf& data, EYsonType type = ::NYson::EYsonType::Node) = 0;
         virtual void Parse(const TStringBuf& data, EYsonType type = ::NYson::EYsonType::Node) = 0;
- 
+
         virtual ~TStatelessYsonParserImplBase() {
         virtual ~TStatelessYsonParserImplBase() {
-        } 
+        }
     };
     };
- 
+
     template <class TConsumer, bool EnableLinePositionInfo>
     template <class TConsumer, bool EnableLinePositionInfo>
     class TStatelessYsonParserImpl
     class TStatelessYsonParserImpl
        : public TStatelessYsonParserImplBase {
        : public TStatelessYsonParserImplBase {

+ 4 - 4
util/generic/ptr.h

@@ -548,8 +548,8 @@ public:
     // Reset(TIntrusivePtr&&)
     // Reset(TIntrusivePtr&&)
     inline void Reset(TIntrusivePtr t) noexcept {
     inline void Reset(TIntrusivePtr t) noexcept {
         Swap(t);
         Swap(t);
-    } 
+    }
- 
+
     inline void Reset() noexcept {
     inline void Reset() noexcept {
         Drop();
         Drop();
     }
     }
@@ -668,8 +668,8 @@ public:
     // Reset(TIntrusiveConstPtr&&)
     // Reset(TIntrusiveConstPtr&&)
     inline void Reset(TIntrusiveConstPtr t) noexcept {
     inline void Reset(TIntrusiveConstPtr t) noexcept {
         Swap(t);
         Swap(t);
-    } 
+    }
- 
+
     inline void Reset() noexcept {
     inline void Reset() noexcept {
         Drop();
         Drop();
     }
     }

+ 8 - 8
util/system/event.cpp

@@ -113,15 +113,15 @@ TSystemEvent::TSystemEvent(ResetMode rmode)
 }
 }
 
 
 TSystemEvent::TSystemEvent(const TSystemEvent& other) noexcept
 TSystemEvent::TSystemEvent(const TSystemEvent& other) noexcept
-    : EvImpl_(other.EvImpl_) 
+    : EvImpl_(other.EvImpl_)
-{ 
+{
-} 
+}
- 
+
 TSystemEvent& TSystemEvent::operator=(const TSystemEvent& other) noexcept {
 TSystemEvent& TSystemEvent::operator=(const TSystemEvent& other) noexcept {
-    EvImpl_ = other.EvImpl_; 
+    EvImpl_ = other.EvImpl_;
-    return *this; 
+    return *this;
-} 
+}
- 
+
 TSystemEvent::~TSystemEvent() = default;
 TSystemEvent::~TSystemEvent() = default;
 
 
 void TSystemEvent::Reset() noexcept {
 void TSystemEvent::Reset() noexcept {

+ 2 - 2
util/system/event.h

@@ -21,7 +21,7 @@ public:
     TSystemEvent(ResetMode rmode = rManual);
     TSystemEvent(ResetMode rmode = rManual);
     TSystemEvent(const TSystemEvent& other) noexcept;
     TSystemEvent(const TSystemEvent& other) noexcept;
     TSystemEvent& operator=(const TSystemEvent& other) noexcept;
     TSystemEvent& operator=(const TSystemEvent& other) noexcept;
- 
+
     ~TSystemEvent();
     ~TSystemEvent();
 
 
     void Reset() noexcept;
     void Reset() noexcept;
@@ -59,7 +59,7 @@ public:
 
 
 private:
 private:
     class TEvImpl;
     class TEvImpl;
-    TIntrusivePtr<TEvImpl> EvImpl_; 
+    TIntrusivePtr<TEvImpl> EvImpl_;
 };
 };
 
 
 class TAutoEvent: public TSystemEvent {
 class TAutoEvent: public TSystemEvent {

+ 8 - 8
util/system/file.cpp

@@ -470,11 +470,11 @@ i32 TFileHandle::Read(void* buffer, ui32 byteCount) noexcept {
     }
     }
     return -1;
     return -1;
 #elif defined(_unix_)
 #elif defined(_unix_)
-    i32 ret; 
+    i32 ret;
     do {
     do {
         ret = ::read(Fd_, buffer, byteCount);
         ret = ::read(Fd_, buffer, byteCount);
     } while (ret == -1 && errno == EINTR);
     } while (ret == -1 && errno == EINTR);
-    return ret; 
+    return ret;
 #else
 #else
     #error unsupported platform
     #error unsupported platform
 #endif
 #endif
@@ -491,11 +491,11 @@ i32 TFileHandle::Write(const void* buffer, ui32 byteCount) noexcept {
     }
     }
     return -1;
     return -1;
 #elif defined(_unix_)
 #elif defined(_unix_)
-    i32 ret; 
+    i32 ret;
     do {
     do {
         ret = ::write(Fd_, buffer, byteCount);
         ret = ::write(Fd_, buffer, byteCount);
     } while (ret == -1 && errno == EINTR);
     } while (ret == -1 && errno == EINTR);
-    return ret; 
+    return ret;
 #else
 #else
     #error unsupported platform
     #error unsupported platform
 #endif
 #endif
@@ -516,11 +516,11 @@ i32 TFileHandle::Pread(void* buffer, ui32 byteCount, i64 offset) const noexcept
     }
     }
     return -1;
     return -1;
 #elif defined(_unix_)
 #elif defined(_unix_)
-    i32 ret; 
+    i32 ret;
     do {
     do {
         ret = ::pread(Fd_, buffer, byteCount, offset);
         ret = ::pread(Fd_, buffer, byteCount, offset);
     } while (ret == -1 && errno == EINTR);
     } while (ret == -1 && errno == EINTR);
-    return ret; 
+    return ret;
 #else
 #else
     #error unsupported platform
     #error unsupported platform
 #endif
 #endif
@@ -538,11 +538,11 @@ i32 TFileHandle::Pwrite(const void* buffer, ui32 byteCount, i64 offset) const no
     }
     }
     return -1;
     return -1;
 #elif defined(_unix_)
 #elif defined(_unix_)
-    i32 ret; 
+    i32 ret;
     do {
     do {
         ret = ::pwrite(Fd_, buffer, byteCount, offset);
         ret = ::pwrite(Fd_, buffer, byteCount, offset);
     } while (ret == -1 && errno == EINTR);
     } while (ret == -1 && errno == EINTR);
-    return ret; 
+    return ret;
 #else
 #else
     #error unsupported platform
     #error unsupported platform
 #endif
 #endif