summaryrefslogtreecommitdiffstats
path: root/library/cpp/actors/core
diff options
context:
space:
mode:
authora-romanov <[email protected]>2022-02-10 16:48:11 +0300
committerDaniil Cherednik <[email protected]>2022-02-10 16:48:11 +0300
commit0f4c5d1e8c0672bf0a1f2f2d8acac5ba24772435 (patch)
treeb222e5ac2e2e98872661c51ccceee5da0d291e13 /library/cpp/actors/core
parentaa2986a34bde73b2cdcea5080c4443b7cf2ba686 (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.cpp98
-rw-r--r--library/cpp/actors/core/buffer.h84
-rw-r--r--library/cpp/actors/core/event.h8
-rw-r--r--library/cpp/actors/core/events.h14
-rw-r--r--library/cpp/actors/core/interconnect.h6
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> {
};