summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authornadya73 <[email protected]>2025-07-12 16:46:09 +0300
committernadya73 <[email protected]>2025-07-12 17:03:25 +0300
commitd28a870061b49d7c985cd453eb01954173e4ffd0 (patch)
tree879670c39092dfcab94f79fc0a46d43b18957c27
parentb1acfe927c4ba28fce6a5cd0f36cd211f0cae5ec (diff)
YT-25642: Don't throw error in RPC client if there is no more memory
commit_hash:689c46e5c94bad44dbba650a768d9bc68e447c65
-rw-r--r--yt/yt/core/rpc/bus/channel.cpp22
1 files changed, 5 insertions, 17 deletions
diff --git a/yt/yt/core/rpc/bus/channel.cpp b/yt/yt/core/rpc/bus/channel.cpp
index e6c5dc1220b..77acf3f76a5 100644
--- a/yt/yt/core/rpc/bus/channel.cpp
+++ b/yt/yt/core/rpc/bus/channel.cpp
@@ -962,23 +962,11 @@ private:
}
if (error.IsOK()) {
message = TrackMemory(MemoryUsageTracker_, std::move(message));
- if (MemoryUsageTracker_->IsExceeded()) {
- auto error = TError(
- NRpc::EErrorCode::ResponseMemoryPressure,
- "Response is dropped due to high memory pressure");
- requestControl->ProfileError(error);
- NotifyError(
- requestControl,
- responseHandler,
- TStringBuf("Response is dropped due to high memory pressure"),
- error);
- } else {
- NotifyResponse(
- requestId,
- requestControl,
- responseHandler,
- std::move(message));
- }
+ NotifyResponse(
+ requestId,
+ requestControl,
+ responseHandler,
+ std::move(message));
} else {
requestControl->ProfileError(error);
if (error.GetCode() == EErrorCode::PoisonPill) {