summaryrefslogtreecommitdiffstats
path: root/library/cpp/actors/interconnect/interconnect_tcp_input_session.cpp
diff options
context:
space:
mode:
authoralexvru <[email protected]>2023-01-23 17:26:05 +0300
committeralexvru <[email protected]>2023-01-23 17:26:05 +0300
commita65aef1c0441efcfc8721c8a67fd25195f34d402 (patch)
treeede200d3dbf5baebd15de4fdf792341a7c5b9618 /library/cpp/actors/interconnect/interconnect_tcp_input_session.cpp
parent4395852866f7a69b06e307b0f9fcd8ef950c200b (diff)
Fix serialization for external data channel,
Diffstat (limited to 'library/cpp/actors/interconnect/interconnect_tcp_input_session.cpp')
-rw-r--r--library/cpp/actors/interconnect/interconnect_tcp_input_session.cpp5
1 files changed, 4 insertions, 1 deletions
diff --git a/library/cpp/actors/interconnect/interconnect_tcp_input_session.cpp b/library/cpp/actors/interconnect/interconnect_tcp_input_session.cpp
index fdf035499f9..b1212b89140 100644
--- a/library/cpp/actors/interconnect/interconnect_tcp_input_session.cpp
+++ b/library/cpp/actors/interconnect/interconnect_tcp_input_session.cpp
@@ -327,12 +327,15 @@ namespace NActors {
return ReestablishConnection(TDisconnectReason::ChecksumError());
}
}
+ TEventSerializationInfo serializationInfo{
+ .IsExtendedFormat = bool(descr.Flags & IEventHandle::FlagExtendedFormat),
+ };
auto ev = std::make_unique<IEventHandle>(SessionId,
descr.Type,
descr.Flags & ~IEventHandle::FlagExtendedFormat,
descr.Recipient,
descr.Sender,
- MakeIntrusive<TEventSerializedData>(std::move(data), bool(descr.Flags & IEventHandle::FlagExtendedFormat)),
+ MakeIntrusive<TEventSerializedData>(std::move(data), std::move(serializationInfo)),
descr.Cookie,
Params.PeerScopeId,
std::move(descr.TraceId));