From 79d7cc9bdb75fa015c8cadc0bd02314d646f2d57 Mon Sep 17 00:00:00 2001 From: Tony Tkacik Date: Thu, 23 Apr 2015 16:09:28 +0200 Subject: [PATCH 1/1] Fixed wrong format in ShardedDOMDataTree Change-Id: Ie32ff9ad72e4bbae9a5ef1290ff63d5780c92313 Signed-off-by: Tony Tkacik --- .../dom/broker/impl/ShardedDOMDataTree.java | 18 +++++++++--------- 1 file changed, 9 insertions(+), 9 deletions(-) diff --git a/opendaylight/md-sal/sal-dom-broker/src/main/java/org/opendaylight/controller/md/sal/dom/broker/impl/ShardedDOMDataTree.java b/opendaylight/md-sal/sal-dom-broker/src/main/java/org/opendaylight/controller/md/sal/dom/broker/impl/ShardedDOMDataTree.java index 11eae5d833..c882d5c522 100644 --- a/opendaylight/md-sal/sal-dom-broker/src/main/java/org/opendaylight/controller/md/sal/dom/broker/impl/ShardedDOMDataTree.java +++ b/opendaylight/md-sal/sal-dom-broker/src/main/java/org/opendaylight/controller/md/sal/dom/broker/impl/ShardedDOMDataTree.java @@ -95,7 +95,7 @@ public final class ShardedDOMDataTree implements DOMDataTreeService, DOMDataTree final ShardingTableEntry parent = lookupShard(prefix); parentReg = parent.getRegistration(); if (parentReg != null && prefix.equals(parentReg.getPrefix())) { - throw new DOMDataTreeShardingConflictException(String.format("Prefix %s is already occupied by shard {}", prefix, parentReg.getInstance())); + throw new DOMDataTreeShardingConflictException(String.format("Prefix %s is already occupied by shard %s", prefix, parentReg.getInstance())); } // FIXME: wrap the shard in a proper adaptor based on implemented interface @@ -117,7 +117,7 @@ public final class ShardedDOMDataTree implements DOMDataTreeService, DOMDataTree @GuardedBy("this") private DOMDataTreeProducer findProducer(final DOMDataTreeIdentifier subtree) { - for (Entry e : idToProducer.entrySet()) { + for (final Entry e : idToProducer.entrySet()) { if (e.getKey().contains(subtree)) { return e.getValue(); } @@ -127,8 +127,8 @@ public final class ShardedDOMDataTree implements DOMDataTreeService, DOMDataTree } synchronized void destroyProducer(final ShardedDOMDataTreeProducer producer) { - for (DOMDataTreeIdentifier s : producer.getSubtrees()) { - DOMDataTreeProducer r = idToProducer.remove(s); + for (final DOMDataTreeIdentifier s : producer.getSubtrees()) { + final DOMDataTreeProducer r = idToProducer.remove(s); if (!producer.equals(r)) { LOG.error("Removed producer %s on subtree %s while removing %s", r, s, producer); } @@ -139,7 +139,7 @@ public final class ShardedDOMDataTree implements DOMDataTreeService, DOMDataTree private DOMDataTreeProducer createProducer(final Map shardMap) { // Record the producer's attachment points final DOMDataTreeProducer ret = ShardedDOMDataTreeProducer.create(this, shardMap); - for (DOMDataTreeIdentifier s : shardMap.keySet()) { + for (final DOMDataTreeIdentifier s : shardMap.keySet()) { idToProducer.put(s, ret); } @@ -151,7 +151,7 @@ public final class ShardedDOMDataTree implements DOMDataTreeService, DOMDataTree Preconditions.checkArgument(!subtrees.isEmpty(), "Subtrees may not be empty"); final Map shardMap = new HashMap<>(); - for (DOMDataTreeIdentifier s : subtrees) { + for (final DOMDataTreeIdentifier s : subtrees) { // Attempting to create a disconnected producer -- all subtrees have to be unclaimed final DOMDataTreeProducer producer = findProducer(s); Preconditions.checkArgument(producer == null, "Subtree %s is attached to producer %s", s, producer); @@ -166,7 +166,7 @@ public final class ShardedDOMDataTree implements DOMDataTreeService, DOMDataTree Preconditions.checkNotNull(parent); final Map shardMap = new HashMap<>(); - for (DOMDataTreeIdentifier s : subtrees) { + for (final DOMDataTreeIdentifier s : subtrees) { shardMap.put(s, lookupShard(s).getRegistration().getInstance()); } @@ -175,7 +175,7 @@ public final class ShardedDOMDataTree implements DOMDataTreeService, DOMDataTree @Override public synchronized ListenerRegistration registerListener(final T listener, final Collection subtrees, final boolean allowRxMerges, final Collection producers) { - // TODO Auto-generated method stub - return null; + // FIXME Implement this. + throw new UnsupportedOperationException("Not implemented yet."); } } -- 2.36.6