diff options
| -rw-r--r-- | library/cpp/actors/interconnect/interconnect_counters.cpp | 6 | ||||
| -rw-r--r-- | library/cpp/actors/interconnect/load.cpp | 4 |
2 files changed, 8 insertions, 2 deletions
diff --git a/library/cpp/actors/interconnect/interconnect_counters.cpp b/library/cpp/actors/interconnect/interconnect_counters.cpp index 408f86cae95..0a1a7255701 100644 --- a/library/cpp/actors/interconnect/interconnect_counters.cpp +++ b/library/cpp/actors/interconnect/interconnect_counters.cpp @@ -29,6 +29,7 @@ namespace { {} TOutputChannel(const TOutputChannel&) = default; + TOutputChannel &operator=(const TOutputChannel& other) = default; }; struct TInputChannel { @@ -52,6 +53,7 @@ namespace { {} TInputChannel(const TInputChannel&) = default; + TInputChannel &operator=(const TInputChannel& other) = default; }; struct TInputChannels : std::unordered_map<ui16, TInputChannel> { @@ -72,6 +74,7 @@ namespace { } TInputChannels(const TInputChannels&) = default; + TInputChannels &operator=(const TInputChannels& other) = default; const TInputChannel& Get(ui16 id) const { const auto it = find(id); @@ -361,6 +364,7 @@ namespace { {} TOutputChannel(const TOutputChannel&) = default; + TOutputChannel &operator=(const TOutputChannel& other) = default; }; struct TInputChannel { @@ -383,6 +387,7 @@ namespace { {} TInputChannel(const TInputChannel&) = default; + TInputChannel &operator=(const TInputChannel& other) = default; }; struct TInputChannels : std::unordered_map<ui16, TInputChannel> { @@ -404,6 +409,7 @@ namespace { } TInputChannels(const TInputChannels&) = default; + TInputChannels &operator=(const TInputChannels& other) = default; const TInputChannel& Get(ui16 id) const { const auto it = find(id); diff --git a/library/cpp/actors/interconnect/load.cpp b/library/cpp/actors/interconnect/load.cpp index 2a8443da71f..d460903f35d 100644 --- a/library/cpp/actors/interconnect/load.cpp +++ b/library/cpp/actors/interconnect/load.cpp @@ -306,10 +306,10 @@ namespace NInterconnect { } void HandleWakeup(const TActorContext& ctx) { - ui32 numDropped = 0; + // ui32 numDropped = 0; while (TimeoutQueue && TimeoutQueue.front().first <= ctx.Now()) { - numDropped += InFly.erase(TimeoutQueue.front().second); + /*numDropped += */InFly.erase(TimeoutQueue.front().second); TimeoutQueue.pop(); } if (TimeoutQueue) { |
