Support XDC streams

1 files changed, 10 insertions, 5 deletions

diff --git a/library/cpp/actors/interconnect/interconnect_tcp_proxy.cpp b/library/cpp/actors/interconnect/interconnect_tcp_proxy.cpp
index 7ca2453f6c5..13f2f2dd838 100644
--- a/library/cpp/actors/interconnect/interconnect_tcp_proxy.cpp
+++ b/library/cpp/actors/interconnect/interconnect_tcp_proxy.cpp
@@ -294,7 +294,7 @@ namespace NActors {
                 Send(ev->Sender, new TEvHandshakeReplyError("duplicate serial"));
                 return;
             } else if (serial == *LastSerialFromIncomingHandshake) {
-                LOG_NOTICE_IC("ICP15", "Handshake# %s is obsolete, serial# %" PRIu64
+                LOG_NOTICE_IC("ICP00", "Handshake# %s is obsolete, serial# %" PRIu64
                     " LastSerialFromIncomingHandshake# %" PRIu64, ev->Sender.ToString().data(),
                     serial, *LastSerialFromIncomingHandshake);
                 Send(ev->Sender, new TEvents::TEvPoisonPill);
@@ -731,11 +731,16 @@ namespace NActors {
             }
         }
 
-        if (Session != nullptr) {
-            Session->GenerateHttpInfo(str);
+        TAutoPtr<IEventHandle> h(new IEventHandle(ev->Sender, ev->Recipient, new NMon::TEvHttpInfoRes(str.Str())));
+        if (Session) {
+            switch (auto& ev = h; ev->GetTypeRewrite()) {
+                hFunc(NMon::TEvHttpInfoRes, Session->GenerateHttpInfo);
+                default:
+                    Y_FAIL();
+            }
+        } else {
+            TActivationContext::Send(h.Release());
         }
-
-        Send(ev->Sender, new NMon::TEvHttpInfoRes(str.Str()));
     }
 
     void TInterconnectProxyTCP::TransitToErrorState(TString explanation, bool updateErrorLog) {