diff options
| author | alexvru <[email protected]> | 2023-01-23 17:26:05 +0300 |
|---|---|---|
| committer | alexvru <[email protected]> | 2023-01-23 17:26:05 +0300 |
| commit | a65aef1c0441efcfc8721c8a67fd25195f34d402 (patch) | |
| tree | ede200d3dbf5baebd15de4fdf792341a7c5b9618 /library/cpp/actors/interconnect/interconnect_tcp_input_session.cpp | |
| parent | 4395852866f7a69b06e307b0f9fcd8ef950c200b (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.cpp | 5 |
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)); |
