hcq/oceanbase
hcq/oceanbase
1
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases Wiki Activity

[Election] adjust invalid priority compare bahavior

Browse Source
This commit is contained in:
fengdeyiji 2023-07-13 12:54:28 +00:00 committed by ob-robot
parent c0135ba735
commit 63d1fb2cb8
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/logservice/leader_coordinator/election_priority_impl/election_priority_impl.cpp
View File

@ -210,11 +210,11 @@ int ElectionPriorityImpl::compare_with(const ElectionPriority &rhs,
result = 0;
COORDINATOR_LOG(WARN, "compare between invalid priority");
} else if (functor1.get_closest_priority()->is_valid() && !functor2.get_closest_priority()->is_valid()) {
result = 0;
result = 1;
(void) reason.assign("compare with invalid rhs priority");
COORDINATOR_LOG(WARN, "rhs priority is invalid", KR(ret), K(MTL_ID()), K(*this), K(rhs), K(compare_version), K(result), K(reason));
} else if (!functor1.get_closest_priority()->is_valid() && functor2.get_closest_priority()->is_valid()) {
result = 0;
result = -1;
(void) reason.assign("compare with invalid lhs priority");
COORDINATOR_LOG(WARN, "lhs priority is invalid", KR(ret), K(MTL_ID()), K(*this), K(rhs), K(compare_version), K(result), K(reason));
} else if (CLICK_FAIL(functor1.get_closest_priority()->compare(*functor2.get_closest_priority(), result, reason))) {