diff options
author | Daniil Cherednik <dcherednik@ydb.tech> | 2023-10-23 20:34:16 +0000 |
---|---|---|
committer | Daniil Cherednik <dcherednik@ydb.tech> | 2023-10-23 20:34:16 +0000 |
commit | e84c813452e9ed62415b2d17a117008fce909a3d (patch) | |
tree | 998632d6f08419de5b644940799f3be9408ab46b /library/cpp/actors | |
parent | df6e99640a1489cde9b7cc5b58a3747c6ec28921 (diff) | |
download | ydb-stable-23-3.tar.gz |
Intermediate changesstable-23-3
x-stable-origin-commit: 8b96eef194d7fb3b315816b97322e8dd90bf3d94
Diffstat (limited to 'library/cpp/actors')
-rw-r--r-- | library/cpp/actors/interconnect/interconnect_handshake.cpp | 5 | ||||
-rw-r--r-- | library/cpp/actors/util/rope.h | 15 |
2 files changed, 4 insertions, 16 deletions
diff --git a/library/cpp/actors/interconnect/interconnect_handshake.cpp b/library/cpp/actors/interconnect/interconnect_handshake.cpp index 4a57fc226c..cb4788a33c 100644 --- a/library/cpp/actors/interconnect/interconnect_handshake.cpp +++ b/library/cpp/actors/interconnect/interconnect_handshake.cpp @@ -491,8 +491,11 @@ namespace NActors { s << ", errorReason# " << errorReason; errorCallback(s.Str()); } - } else { + } else if (proto.HasVersionTag()) { ValidateVersionTag(proto, std::forward<TCallback>(errorCallback)); + } else { + LOG_LOG_IC_X(NActorsServices::INTERCONNECT, "ICH09", NLog::PRI_WARN, + "Neither CompatibilityInfo nor VersionTag of the peer can be validated, accepting by default"); } } diff --git a/library/cpp/actors/util/rope.h b/library/cpp/actors/util/rope.h index 201ce06f0d..6d424ce58b 100644 --- a/library/cpp/actors/util/rope.h +++ b/library/cpp/actors/util/rope.h @@ -915,8 +915,6 @@ class TRopeArena { TAllocateCallback Allocator; TRope Arena; - size_t Size = 0; - THashSet<const void*> AccountedBuffers; public: TRopeArena(TAllocateCallback&& allocator) @@ -949,16 +947,6 @@ public: return res; } - - size_t GetSize() const { - return Size; - } - - void AccountChunk(const TRcBuf& chunk) { - if (AccountedBuffers.insert(chunk.Backend.UniqueId()).second) { - Size += chunk.GetOccupiedMemorySize(); - } - } }; struct TRopeUtils { @@ -1131,9 +1119,6 @@ inline TRope TRope::CopySpaceOptimized(TRope&& origin, size_t worstRatioPer1k, T } res.Size = origin.Size; origin = TRope(); - for (const TRcBuf& chunk : res.Chain) { - arena.AccountChunk(chunk); - } return res; } |