From 93a8bbb01d574d1c55ea51172eca469785df35e3 Mon Sep 17 00:00:00 2001
From: robot-piglet <robot-piglet@yandex-team.com>
Date: Fri, 30 Jun 2023 14:22:26 +0300
Subject: Intermediate changes
---
library/cpp/neh/neh.cpp | 8 ++++----
1 file changed, 4 insertions(+), 4 deletions(-)
(limited to 'library/cpp/neh/neh.cpp')
diff --git a/library/cpp/neh/neh.cpp b/library/cpp/neh/neh.cpp
index dded731bb7..f669ea3757 100644
--- a/library/cpp/neh/neh.cpp
+++ b/library/cpp/neh/neh.cpp
@@ -104,18 +104,18 @@ namespace {
const TString svcFail = "service status: failed";
}
-THandleRef NNeh::Request(const TMessage& msg, IOnRecv* fallback, bool useAsyncSendRequest) {
+THandleRef NNeh::Request(const TMessage& msg, IOnRecv* fallback) {
TServiceStatRef ss;
if (TServiceStat::Disabled()) {
- return ProtocolForMessage(msg)->ScheduleAsyncRequest(msg, fallback, ss, useAsyncSendRequest);
+ return ProtocolForMessage(msg)->ScheduleRequest(msg, fallback, ss);
}
ss = GetServiceStat(msg.Addr);
TServiceStat::EStatus es = ss->GetStatus();
if (es == TServiceStat::Ok) {
- return ProtocolForMessage(msg)->ScheduleAsyncRequest(msg, fallback, ss, useAsyncSendRequest);
+ return ProtocolForMessage(msg)->ScheduleRequest(msg, fallback, ss);
}
if (es == TServiceStat::ReTry) {
@@ -124,7 +124,7 @@ THandleRef NNeh::Request(const TMessage& msg, IOnRecv* fallback, bool useAsyncSe
validator.Addr = msg.Addr;
- ProtocolForMessage(msg)->ScheduleAsyncRequest(validator, nullptr, ss, useAsyncSendRequest);
+ ProtocolForMessage(msg)->ScheduleRequest(validator, nullptr, ss);
}
TNotifyHandleRef h(new TNotifyHandle(fallback, msg));
--
cgit v1.2.3