| commit | f1d87ca565182a71fc191aa9e15c9782633daeaa | [log] [tgz] |
|---|---|---|
| author | Madan Jampani <madan.jampani@gmail.com> | Tue Feb 23 17:24:24 2016 -0800 |
| committer | Madan Jampani <madan.jampani@gmail.com> | Tue Feb 23 17:24:24 2016 -0800 |
| tree | 96d6bae8b1d16961ae97c319625fe020273e3435 | |
| parent | db2afd3fab0d8b925a7efe87065d3517758f1b83 [diff] |
Use ConsistentMap (and not the local cache) when querying leader for a topic Change-Id: I979a4ab116ed68406a6702fe175ba5eab444116c
diff --git a/core/store/dist/src/main/java/org/onosproject/store/cluster/impl/DistributedLeadershipStore.java b/core/store/dist/src/main/java/org/onosproject/store/cluster/impl/DistributedLeadershipStore.java index 83d6f96..78ccc47 100644 --- a/core/store/dist/src/main/java/org/onosproject/store/cluster/impl/DistributedLeadershipStore.java +++ b/core/store/dist/src/main/java/org/onosproject/store/cluster/impl/DistributedLeadershipStore.java
@@ -219,7 +219,7 @@ @Override public Leadership getLeadership(String topic) { - InternalLeadership internalLeadership = Versioned.valueOrNull(leadershipCache.get(topic)); + InternalLeadership internalLeadership = Versioned.valueOrNull(leadershipMap.get(topic)); return internalLeadership == null ? null : internalLeadership.asLeadership(); }