update

Signed-off-by: luohaha <[email protected]>
StarRocks · Sep 20, 2024 · 3ddd99f · 3ddd99f
1 parent 5700435
commit 3ddd99f
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/be/src/util/internal_service_recoverable_stub.cpp b/be/src/util/internal_service_recoverable_stub.cpp
@@ -49,12 +49,12 @@ PInternalService_RecoverableStub::PInternalService_RecoverableStub(const butil::
 
 PInternalService_RecoverableStub::~PInternalService_RecoverableStub() = default;
 
-Status PInternalService_RecoverableStub::reset_channel(const std::string& protocal) {
+Status PInternalService_RecoverableStub::reset_channel(const std::string& protocol) {
     std::lock_guard<std::mutex> l(_mutex);
     brpc::ChannelOptions options;
     options.connect_timeout_ms = config::rpc_connect_timeout_ms;
-    if (protocal == "http") {
-        options.protocol = protocal;
+    if (protocol == "http") {
+        options.protocol = protocol;
     } else {
         // http does not support these.
         options.connection_type = config::brpc_connection_type;

diff --git a/be/src/util/internal_service_recoverable_stub.h b/be/src/util/internal_service_recoverable_stub.h
@@ -29,7 +29,7 @@ class PInternalService_RecoverableStub : public PInternalService,
     PInternalService_RecoverableStub(const butil::EndPoint& endpoint);
     ~PInternalService_RecoverableStub();
 
-    Status reset_channel(const std::string& protocal = "");
+    Status reset_channel(const std::string& protocol = "");
 
 #ifdef BE_TEST
     PInternalService_Stub* stub() { return _stub.get(); }