f

yiguolei · Jan 29, 2025 · 5da8434 · 5da8434
1 parent 70dbb6f
commit 5da8434
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/be/src/util/brpc_client_cache.h b/be/src/util/brpc_client_cache.h
@@ -113,8 +113,9 @@ class FailureDetectChannel : public ::brpc::Channel {
             failure_detect_closure = new FailureDetectClosure(_channel_st, controller, done);
         }
         ::brpc::Channel::CallMethod(method, controller, request, response, failure_detect_closure);
+        // Done == nullptr, it is a sync call, should also deal with the bad channel.
         if (done == nullptr) {
-            auto* cntl = static_cast<brpc::Controller*>(_controller);
+            auto* cntl = static_cast<brpc::Controller*>(controller);
             if (cntl->Failed() && cntl->ErrorCode() == EHOSTDOWN) {
                 Status error_st = Status::NetworkError(
                         "Failed to send brpc, error={}, error_text={}, client: {}, latency = {}",