diff options
| author | alexvru <alexvru@ydb.tech> | 2023-04-13 17:44:21 +0300 |
|---|---|---|
| committer | alexvru <alexvru@ydb.tech> | 2023-04-13 17:44:21 +0300 |
| commit | edbc6cad1fc50b1237b88cd16a78fd44777a6601 (patch) | |
| tree | e708ea5a81108faed9173c71c1f37e09b29cef53 /library/cpp/actors/interconnect/interconnect_tcp_proxy.cpp | |
| parent | 782ed55b35b9805318a8d26ef040ff62a3875b42 (diff) | |
| download | ydb-edbc6cad1fc50b1237b88cd16a78fd44777a6601.tar.gz | |
Implement external data channel: connection
Diffstat (limited to 'library/cpp/actors/interconnect/interconnect_tcp_proxy.cpp')
| -rw-r--r-- | library/cpp/actors/interconnect/interconnect_tcp_proxy.cpp | 5 |
1 files changed, 4 insertions, 1 deletions
diff --git a/library/cpp/actors/interconnect/interconnect_tcp_proxy.cpp b/library/cpp/actors/interconnect/interconnect_tcp_proxy.cpp index 8562f6a440..d70ea1aa73 100644 --- a/library/cpp/actors/interconnect/interconnect_tcp_proxy.cpp +++ b/library/cpp/actors/interconnect/interconnect_tcp_proxy.cpp @@ -339,6 +339,9 @@ namespace NActors { return; } + // drop any pending XDC subscriptions + ConnectionSubscriptions.clear(); + Y_VERIFY(!IncomingHandshakeActor && !OutgoingHandshakeActor); SwitchToState(__LINE__, "StateWork", &TThis::StateWork); @@ -886,7 +889,7 @@ namespace NActors { stats.LastSessionDieTime = LastSessionDieTime; stats.TotalOutputQueueSize = Session ? Session->TotalOutputQueueSize : 0; stats.Connected = Session ? (bool)Session->Socket : false; - stats.ExternalDataChannel = Session && Session->Params.UseExternalDataChannel; + stats.ExternalDataChannel = Session && Session->XdcSocket; stats.Host = TechnicalPeerHostName; stats.Port = 0; ui32 rep = 0; |