Skip to content

B
brpc
Commit af7f77e1 authored by cdjgit's avatar cdjgit
Browse files
Options

fix for ci comments

parent 0544b1fe
Show whitespace changes
Inline Side-by-side
Showing with 4 additions and 4 deletions
src/brpc/policy/consul_naming_service.cpp
View file @ af7f77e1
...@@ -214,6 +214,10 @@ int ConsulNamingService::RunNamingService(const char* service_name, ...@@ -214,6 +214,10 @@ int ConsulNamingService::RunNamingService(const char* service_name,
for (;;) { for (;;) {
servers.clear(); servers.clear();
const int rc = GetServers(service_name, &servers); const int rc = GetServers(service_name, &servers);
if (bthread_stopped(bthread_self())) {
RPC_VLOG << "Quit NamingServiceThread=" << bthread_self();
return 0;
}
if (rc == 0) { if (rc == 0) {
ever_reset = true; ever_reset = true;
actions->ResetServers(servers); actions->ResetServers(servers);
...@@ -234,10 +238,6 @@ int ConsulNamingService::RunNamingService(const char* service_name, ...@@ -234,10 +238,6 @@ int ConsulNamingService::RunNamingService(const char* service_name,
return -1; return -1;
} }
} }
if (bthread_stopped(bthread_self())) {
RPC_VLOG << "Quit NamingServiceThread=" << bthread_self();
return 0;
}
} }
CHECK(false); CHECK(false);
return -1; return -1;
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment