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
@GuardedBy("this")
private DOMDataTreeProducer findProducer(final DOMDataTreeIdentifier subtree) {
- for (Entry<DOMDataTreeIdentifier, DOMDataTreeProducer> e : idToProducer.entrySet()) {
+ for (final Entry<DOMDataTreeIdentifier, DOMDataTreeProducer> e : idToProducer.entrySet()) {
if (e.getKey().contains(subtree)) {
return e.getValue();
}
}
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);
+ LOG.error("Removed producer {} on subtree {} while removing {}", r, s, producer);
}
}
}
Preconditions.checkArgument(!subtrees.isEmpty(), "Subtrees may not be empty");
final Map<DOMDataTreeIdentifier, DOMDataTreeShard> 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);
Preconditions.checkNotNull(parent);
final Map<DOMDataTreeIdentifier, DOMDataTreeShard> shardMap = new HashMap<>();
- for (DOMDataTreeIdentifier s : subtrees) {
+ for (final DOMDataTreeIdentifier s : subtrees) {
shardMap.put(s, lookupShard(s).getRegistration().getInstance());
}
@Override
public synchronized <T extends DOMDataTreeListener> ListenerRegistration<T> registerListener(final T listener, final Collection<DOMDataTreeIdentifier> subtrees, final boolean allowRxMerges, final Collection<DOMDataTreeProducer> producers) {
- // TODO Auto-generated method stub
- return null;
+ // FIXME Implement this.
+ throw new UnsupportedOperationException("Not implemented yet.");
}
}