Skip to content

Commit fd686d9

Browse files
committed
Only mark unavailable server as traversed
1 parent 7501ec0 commit fd686d9

1 file changed

Lines changed: 1 addition & 1 deletion

File tree

src/brpc/policy/weighted_randomized_load_balancer.cpp

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -139,8 +139,8 @@ int WeightedRandomizedLoadBalancer::SelectServer(const SelectIn& in, SelectOut*
139139
std::lower_bound(s->server_list.begin(), s->server_list.end(),
140140
random_server, server_compare);
141141
const SocketId id = server->id;
142-
random_traversed.insert(id);
143142
if (0 != IsServerAvailable(id, out->ptr)) {
143+
random_traversed.insert(id);
144144
continue;
145145
}
146146
if (!ExcludedServers::IsExcluded(in.excluded, id)) {

0 commit comments

Comments
 (0)