diff options
| author | a-romanov <[email protected]> | 2022-02-10 16:48:11 +0300 | 
|---|---|---|
| committer | Daniil Cherednik <[email protected]> | 2022-02-10 16:48:11 +0300 | 
| commit | 0f4c5d1e8c0672bf0a1f2f2d8acac5ba24772435 (patch) | |
| tree | b222e5ac2e2e98872661c51ccceee5da0d291e13 /library/cpp/actors/core | |
| parent | aa2986a34bde73b2cdcea5080c4443b7cf2ba686 (diff) | |
Restoring authorship annotation for <[email protected]>. Commit 2 of 2.
Diffstat (limited to 'library/cpp/actors/core')
| -rw-r--r-- | library/cpp/actors/core/buffer.cpp | 98 | ||||
| -rw-r--r-- | library/cpp/actors/core/buffer.h | 84 | ||||
| -rw-r--r-- | library/cpp/actors/core/event.h | 8 | ||||
| -rw-r--r-- | library/cpp/actors/core/events.h | 14 | ||||
| -rw-r--r-- | library/cpp/actors/core/interconnect.h | 6 | 
5 files changed, 105 insertions, 105 deletions
diff --git a/library/cpp/actors/core/buffer.cpp b/library/cpp/actors/core/buffer.cpp index a949e2ab0f8..48128d76ef7 100644 --- a/library/cpp/actors/core/buffer.cpp +++ b/library/cpp/actors/core/buffer.cpp @@ -1,93 +1,93 @@ -#include "buffer.h"  -  -#include <util/system/yassert.h>  -  +#include "buffer.h" + +#include <util/system/yassert.h> +  #include <algorithm> -  -TBufferBase::TBufferBase(size_t size) noexcept  -    : Size(size)  + +TBufferBase::TBufferBase(size_t size) noexcept +    : Size(size)  {  } -  -size_t  + +size_t  TBufferBase::GetSize() const noexcept {      return Size; -}  -  +} +  void TBufferBase::SetSize(size_t size) noexcept {      Size = size; -}  -  -/////////////////////////////////////////////////////////////////////  -  +} + +///////////////////////////////////////////////////////////////////// +  template <typename PointerType> -TBufferBaseT<PointerType>::TBufferBaseT(PointerType data, size_t size) noexcept  +TBufferBaseT<PointerType>::TBufferBaseT(PointerType data, size_t size) noexcept      : TBufferBase(size)      , Data(data)  {  } -  +  template <typename PointerType> -PointerType  +PointerType  TBufferBaseT<PointerType>::GetPointer() const noexcept {      return Data; -}  -  +} +  template <typename PointerType>  void TBufferBaseT<PointerType>::Assign(PointerType data, size_t size) noexcept {      Data = data;      Size = size; -}  -  +} +  template <>  void TBufferBaseT<void*>::Cut(size_t offset) noexcept {      Y_VERIFY_DEBUG(offset <= Size);      Data = static_cast<char*>(Data) + offset;      TBufferBase::Size -= offset; -}  -  +} +  template <>  void TBufferBaseT<const void*>::Cut(size_t offset) noexcept {      Y_VERIFY_DEBUG(offset <= Size);      Data = static_cast<const char*>(Data) + offset;      TBufferBase::Size -= offset; -}  -  -template class TBufferBaseT<void*>;  -template class TBufferBaseT<const void*>;  -  -/////////////////////////////////////////////////////////////////////  -  -TConstBuffer::TConstBuffer(const void* data, size_t size) noexcept  -    : TBufferBaseT<const void*>(data, size)  +} + +template class TBufferBaseT<void*>; +template class TBufferBaseT<const void*>; + +///////////////////////////////////////////////////////////////////// + +TConstBuffer::TConstBuffer(const void* data, size_t size) noexcept +    : TBufferBaseT<const void*>(data, size)  {  } -  -TConstBuffer::TConstBuffer(const TMutableBuffer& buffer) noexcept  -    : TBufferBaseT<const void*>(buffer.GetPointer(), buffer.GetSize())  + +TConstBuffer::TConstBuffer(const TMutableBuffer& buffer) noexcept +    : TBufferBaseT<const void*>(buffer.GetPointer(), buffer.GetSize())  {  } -  -TConstBuffer  + +TConstBuffer  TConstBuffer::Offset(ptrdiff_t offset, size_t size) const noexcept {      return TConstBuffer(static_cast<const char*>(Data) + offset, std::min(Size - offset, size)); -}  -  -////////////////////////////////////////////////////////////////////////////////  -  -TMutableBuffer::TMutableBuffer(void* data, size_t size) noexcept  +} + +//////////////////////////////////////////////////////////////////////////////// + +TMutableBuffer::TMutableBuffer(void* data, size_t size) noexcept      : TBufferBaseT<void*>(data, size)  {  } -  -TMutableBuffer  + +TMutableBuffer  TMutableBuffer::Offset(ptrdiff_t offset, size_t size) const noexcept {      return TMutableBuffer(static_cast<char*>(Data) + offset, std::min(Size - offset, size)); -}  -  -size_t  +} + +size_t  TMutableBuffer::CopyFrom(const TConstBuffer& buffer) const noexcept {      const auto size = std::min(Size, buffer.Size);      std::memcpy(Data, buffer.Data, size);      return size; -}  +} diff --git a/library/cpp/actors/core/buffer.h b/library/cpp/actors/core/buffer.h index 459b788b27e..95425046d69 100644 --- a/library/cpp/actors/core/buffer.h +++ b/library/cpp/actors/core/buffer.h @@ -1,62 +1,62 @@ -#pragma once  -  +#pragma once +  #include <limits> -  -class TConstBuffer;  -class TMutableBuffer;  -  + +class TConstBuffer; +class TMutableBuffer; +  class TBufferBase { -public:  -    size_t GetSize() const noexcept;  -  -    void SetSize(size_t newSize) noexcept;  -  -protected:  -    TBufferBase(size_t size = 0) noexcept;  -  -    size_t Size;  -};  -  +public: +    size_t GetSize() const noexcept; + +    void SetSize(size_t newSize) noexcept; + +protected: +    TBufferBase(size_t size = 0) noexcept; + +    size_t Size; +}; +  template <typename PointerType>  class TBufferBaseT: public TBufferBase { -public:  -    PointerType GetPointer() const noexcept;  -  -    void Cut(size_t offset) noexcept;  -  -    void Assign(PointerType data = nullptr, size_t size = 0U) noexcept;  -  -protected:  -    TBufferBaseT(PointerType data, size_t size) noexcept;  -  -    PointerType Data;  -};  -  -/// Represents constant memory buffer, but do not owns it.  +public: +    PointerType GetPointer() const noexcept; + +    void Cut(size_t offset) noexcept; + +    void Assign(PointerType data = nullptr, size_t size = 0U) noexcept; + +protected: +    TBufferBaseT(PointerType data, size_t size) noexcept; + +    PointerType Data; +}; + +/// Represents constant memory buffer, but do not owns it.  class TConstBuffer: public TBufferBaseT<const void*> {      friend class TMutableBuffer; -public:  +public:      TConstBuffer(const TMutableBuffer& buffer) noexcept; -  +      TConstBuffer(const void* data = nullptr, size_t size = 0U) noexcept; -  +      TConstBuffer Offset(ptrdiff_t offset, size_t size = std::numeric_limits<size_t>::max()) const noexcept; -};  -  -/// Represents mutable memory buffer, but do not owns it.  +}; + +/// Represents mutable memory buffer, but do not owns it.  class TMutableBuffer: public TBufferBaseT<void*> {      friend class TConstBuffer; -public:  +public:      TMutableBuffer(void* data = nullptr, size_t size = 0U) noexcept; -  +      TMutableBuffer(const TMutableBuffer& value) noexcept          : TBufferBaseT<void*>(value)      {      } -  +      TMutableBuffer Offset(ptrdiff_t offset, size_t size = std::numeric_limits<size_t>::max()) const noexcept; -  +      size_t CopyFrom(const TConstBuffer& buffer) const noexcept; -};  +}; diff --git a/library/cpp/actors/core/event.h b/library/cpp/actors/core/event.h index 17edf0d436f..6ff02aaf943 100644 --- a/library/cpp/actors/core/event.h +++ b/library/cpp/actors/core/event.h @@ -116,18 +116,18 @@ namespace NActors {          static const size_t ChannelBits = 12;          static const size_t ChannelShift = (sizeof(ui32) << 3) - ChannelBits; -  +  #ifdef USE_ACTOR_CALLSTACK          TCallstack Callstack;  #endif          ui16 GetChannel() const noexcept {              return Flags >> ChannelShift;          } -  +          ui64 GetSubChannel() const noexcept {              return Flags & FlagUseSubChannel ? Sender.LocalId() : 0ULL;          } -  +          static ui32 MakeFlags(ui32 channel, ui32 flags) {              Y_VERIFY(channel < (1 << ChannelBits));              Y_VERIFY(flags < (1 << ChannelShift)); @@ -249,7 +249,7 @@ namespace NActors {                  return 0;              }          } -  +          bool HasBuffer() const {              return bool(Buffer);          } diff --git a/library/cpp/actors/core/events.h b/library/cpp/actors/core/events.h index 12d7b6899fc..702cf50fadf 100644 --- a/library/cpp/actors/core/events.h +++ b/library/cpp/actors/core/events.h @@ -58,15 +58,15 @@ namespace NActors {                  : Blob(blob)              {              } -  +              TString ToStringHeader() const noexcept override {                  return "THelloWorld::Blob";              } -  +              bool SerializeToArcadiaStream(TChunkSerializer *serializer) const override {                  return serializer->WriteString(&Blob);              } -  +              static IEventBase* Load(TEventSerializedData* bufs) noexcept {                  return new TEvBlob(bufs->GetString());              } @@ -75,7 +75,7 @@ namespace NActors {                  return true;              }          }; -  +          struct TSystem {              enum {                  Start = EventSpaceBegin(ES_SYSTEM), @@ -103,7 +103,7 @@ namespace NActors {                  PoisonPill = Poison,                  ActorDied = Gone,              }; -  +              static_assert(End < EventSpaceEnd(ES_SYSTEM), "expect End < EventSpaceEnd(ES_SYSTEM)");          }; @@ -130,7 +130,7 @@ namespace NActors {          struct TEvUnsubscribe: public TEventBase<TEvUnsubscribe, TSystem::Unsubscribe> {              DEFINE_SIMPLE_LOCAL_EVENT(TEvUnsubscribe, "System: TEvUnsubscribe")          }; -  +          struct TEvUndelivered: public TEventBase<TEvUndelivered, TSystem::Undelivered> {              enum EReason {                  ReasonUnknown, @@ -141,7 +141,7 @@ namespace NActors {              const EReason Reason;              const bool Unsure;              const TString Data; -  +              TEvUndelivered(ui32 sourceType, ui32 reason, bool unsure = false)                  : SourceType(sourceType)                  , Reason(static_cast<EReason>(reason)) diff --git a/library/cpp/actors/core/interconnect.h b/library/cpp/actors/core/interconnect.h index 81dbde2c4d4..679a4b8cc6f 100644 --- a/library/cpp/actors/core/interconnect.h +++ b/library/cpp/actors/core/interconnect.h @@ -162,7 +162,7 @@ namespace NActors {              }              const ui32 NodeId;          }; -  +          struct TEvNodeDisconnected: public TEventLocal<TEvNodeDisconnected, EvNodeDisconnected> {              DEFINE_SIMPLE_LOCAL_EVENT(TEvNodeDisconnected, "TEvInterconnect::TEvNodeDisconnected")              TEvNodeDisconnected(ui32 node) noexcept @@ -171,10 +171,10 @@ namespace NActors {              }              const ui32 NodeId;          }; -  +          struct TEvRegisterNode;          struct TEvRegisterNodeResult; -  +          struct TEvListNodes: public TEventLocal<TEvListNodes, EvListNodes> {          };  | 
