diff options
| -rw-r--r-- | yt/yt/core/rpc/overload_controller.cpp | 5 | ||||
| -rw-r--r-- | yt/yt/core/rpc/overload_controller.h | 1 |
2 files changed, 6 insertions, 0 deletions
diff --git a/yt/yt/core/rpc/overload_controller.cpp b/yt/yt/core/rpc/overload_controller.cpp index 87484a7b405..dc2dd8e2270 100644 --- a/yt/yt/core/rpc/overload_controller.cpp +++ b/yt/yt/core/rpc/overload_controller.cpp @@ -375,6 +375,11 @@ public: Periodic_->Start(); } + TFuture<void> Stop() override + { + return Periodic_->Stop(); + } + void TrackInvoker( TStringBuf name, const IInvokerPtr& invoker) override diff --git a/yt/yt/core/rpc/overload_controller.h b/yt/yt/core/rpc/overload_controller.h index 708ec833271..93ac4f57a05 100644 --- a/yt/yt/core/rpc/overload_controller.h +++ b/yt/yt/core/rpc/overload_controller.h @@ -40,6 +40,7 @@ public: DECLARE_INTERFACE_SIGNAL(void(), LoadAdjusted); virtual void Start() = 0; + virtual TFuture<void> Stop() = 0; virtual void Reconfigure(TOverloadControllerConfigPtr config) = 0; virtual void TrackInvoker( |