Committed by
Gerrit Code Review
Fix for ONOS-1218
Change-Id: Ica7a5c251d63c301b40b9ef2c95450c0194798cf
Showing
1 changed file
with
2 additions
and
2 deletions
| ... | @@ -109,8 +109,8 @@ public class PartitionManager implements PartitionService { | ... | @@ -109,8 +109,8 @@ public class PartitionManager implements PartitionService { |
| 109 | 109 | ||
| 110 | @Override | 110 | @Override |
| 111 | public boolean isMine(Key intentKey) { | 111 | public boolean isMine(Key intentKey) { |
| 112 | - return leadershipService.getLeader(getPartitionPath(getPartitionForKey(intentKey))) | 112 | + return Objects.equal(leadershipService.getLeader(getPartitionPath(getPartitionForKey(intentKey))), |
| 113 | - .equals(clusterService.getLocalNode().id()); | 113 | + clusterService.getLocalNode().id()); |
| 114 | } | 114 | } |
| 115 | 115 | ||
| 116 | private void doRelinquish() { | 116 | private void doRelinquish() { | ... | ... |
-
Please register or login to post a comment