f

apache · Oct 1, 2024 · f43b7c8 · f43b7c8
1 parent c3a0796
commit f43b7c8
Showing 1 changed file with 5 additions and 5 deletions.
diff --git a/be/src/service/internal_service.h b/be/src/service/internal_service.h
@@ -41,11 +41,11 @@ class RuntimeState;
 template <typename T>
 concept CanCancel = requires(T* response) { response->mutable_status(); };
 
-//template <typename T>
-//void offer_failed(T* response, google::protobuf::Closure* done, const FifoThreadPool& pool) {
-// brpc::ClosureGuard closure_guard(done);
-// LOG(WARNING) << "fail to offer request to the work pool, pool=" << pool.get_info();
-//}
+template <typename T>
+void offer_failed(T* response, google::protobuf::Closure* done, const FifoThreadPool& pool) {
+ brpc::ClosureGuard closure_guard(done);
+ LOG(WARNING) << "fail to offer request to the work pool, pool=" << pool.get_info();
+}
 
 template <CanCancel T>
 void offer_failed(T* response, google::protobuf::Closure* done, const FifoThreadPool& pool) {