diff options
author | Anton Samokhvalov <pg83@yandex.ru> | 2022-02-10 16:45:15 +0300 |
---|---|---|
committer | Daniil Cherednik <dcherednik@yandex-team.ru> | 2022-02-10 16:45:15 +0300 |
commit | 72cb13b4aff9bc9cf22e49251bc8fd143f82538f (patch) | |
tree | da2c34829458c7d4e74bdfbdf85dff449e9e7fb8 /library/cpp/actors/interconnect/packet.h | |
parent | 778e51ba091dc39e7b7fcab2b9cf4dbedfb6f2b5 (diff) | |
download | ydb-72cb13b4aff9bc9cf22e49251bc8fd143f82538f.tar.gz |
Restoring authorship annotation for Anton Samokhvalov <pg83@yandex.ru>. Commit 1 of 2.
Diffstat (limited to 'library/cpp/actors/interconnect/packet.h')
-rw-r--r-- | library/cpp/actors/interconnect/packet.h | 20 |
1 files changed, 10 insertions, 10 deletions
diff --git a/library/cpp/actors/interconnect/packet.h b/library/cpp/actors/interconnect/packet.h index 4ba50a2b5f..e7cbb453f6 100644 --- a/library/cpp/actors/interconnect/packet.h +++ b/library/cpp/actors/interconnect/packet.h @@ -16,10 +16,10 @@ #define FORCE_EVENT_CHECKSUM 0 #endif -using NActors::IEventBase; -using NActors::IEventHandle; +using NActors::IEventBase; +using NActors::IEventHandle; using NActors::TActorId; -using NActors::TConstIoVec; +using NActors::TConstIoVec; using NActors::TEventSerializedData; Y_FORCE_INLINE ui32 Crc32cExtendMSanCompatible(ui32 checksum, const void *data, size_t len) { @@ -142,7 +142,7 @@ struct TEventHolder : TNonCopyable { namespace NActors { class TEventOutputChannel; -} +} struct TTcpPacketOutTask : TNonCopyable { const TSessionParams& Params; @@ -192,9 +192,9 @@ public: Orbit.Reset(); } - bool IsEmpty() const { + bool IsEmpty() const { return !DataSize; - } + } void SetMetadata(ui64 serial, ui64 confirm) { ApplyToHeader([&](auto& header) { @@ -261,7 +261,7 @@ public: bool DropBufs(size_t& amount) { while (BufferIndex != Bufs.size()) { - TConstIoVec& item = Bufs[BufferIndex]; + TConstIoVec& item = Bufs[BufferIndex]; // calculate number of bytes to the end in current buffer const size_t remain = item.Size - FirstBufferOffset; if (amount >= remain) { @@ -285,11 +285,11 @@ public: TriedWriting = false; } - template <typename TVectorType> - void AppendToIoVector(TVectorType& vector, size_t max) { + template <typename TVectorType> + void AppendToIoVector(TVectorType& vector, size_t max) { for (size_t k = BufferIndex, offset = FirstBufferOffset; k != Bufs.size() && vector.size() < max; ++k, offset = 0) { TConstIoVec v = Bufs[k]; - v.Data = static_cast<const char*>(v.Data) + offset; + v.Data = static_cast<const char*>(v.Data) + offset; v.Size -= offset; vector.push_back(v); } |