X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?p=controller.git;a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-distributed-datastore%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fcluster%2Fsharding%2FDistributedShardFrontend.java;h=21725d2c67840c3587cbeeea2832e5b907a3db89;hp=31bc8b6949156662cecdc9a62f116458b589eaad;hb=127042ea7e148d9dc0282acc3780b4754ca69e12;hpb=1e8d188e98614a1f3d781b2f80d61fcd0afde368 diff --git a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/sharding/DistributedShardFrontend.java b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/sharding/DistributedShardFrontend.java index 31bc8b6949..21725d2c67 100644 --- a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/sharding/DistributedShardFrontend.java +++ b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/sharding/DistributedShardFrontend.java @@ -5,16 +5,16 @@ * terms of the Eclipse Public License v1.0 which accompanies this distribution, * and is available at http://www.eclipse.org/legal/epl-v10.html */ - package org.opendaylight.controller.cluster.sharding; -import com.google.common.base.Preconditions; +import static com.google.common.base.Preconditions.checkArgument; +import static java.util.Objects.requireNonNull; + import java.util.ArrayList; import java.util.Collection; import java.util.HashMap; import java.util.List; import java.util.Map; -import javax.annotation.Nonnull; import javax.annotation.concurrent.GuardedBy; import org.opendaylight.controller.cluster.databroker.actors.dds.DataStoreClient; import org.opendaylight.controller.cluster.datastore.AbstractDataStore; @@ -51,18 +51,18 @@ class DistributedShardFrontend implements ReadableWriteableDOMDataTreeShard { DistributedShardFrontend(final AbstractDataStore distributedDataStore, final DataStoreClient client, final DOMDataTreeIdentifier shardRoot) { - this.client = Preconditions.checkNotNull(client); - this.shardRoot = Preconditions.checkNotNull(shardRoot); + this.client = requireNonNull(client); + this.shardRoot = requireNonNull(shardRoot); - publisher = new DistributedShardChangePublisher(client, Preconditions.checkNotNull(distributedDataStore), - shardRoot, childShards); + publisher = new DistributedShardChangePublisher(client, requireNonNull(distributedDataStore), shardRoot, + childShards); } @Override public synchronized DOMDataTreeShardProducer createProducer(final Collection paths) { for (final DOMDataTreeIdentifier prodPrefix : paths) { - Preconditions.checkArgument(shardRoot.contains(prodPrefix), "Prefix %s is not contained under shard root", - prodPrefix, paths); + checkArgument(shardRoot.contains(prodPrefix), "Prefix %s is not contained under shard root", prodPrefix, + paths); } final ShardProxyProducer ret = @@ -74,7 +74,7 @@ class DistributedShardFrontend implements ReadableWriteableDOMDataTreeShard { @Override public synchronized void onChildAttached(final DOMDataTreeIdentifier prefix, final DOMDataTreeShard child) { LOG.debug("{} : Child shard attached at {}", shardRoot, prefix); - Preconditions.checkArgument(child != this, "Attempted to attach child %s onto self", this); + checkArgument(child != this, "Attempted to attach child %s onto self", this); addChildShard(prefix, child); updateProducers(); } @@ -88,7 +88,7 @@ class DistributedShardFrontend implements ReadableWriteableDOMDataTreeShard { } private void addChildShard(final DOMDataTreeIdentifier prefix, final DOMDataTreeShard child) { - Preconditions.checkArgument(child instanceof WriteableDOMDataTreeShard); + checkArgument(child instanceof WriteableDOMDataTreeShard); childShards.put(prefix, new ChildShardContext(prefix, (WriteableDOMDataTreeShard) child)); } @@ -132,7 +132,6 @@ class DistributedShardFrontend implements ReadableWriteableDOMDataTreeShard { } } - @Nonnull @Override public ListenerRegistration registerTreeChangeListener( final YangInstanceIdentifier treeId, final L listener) {