commit | 30161e7abec0b2ae63d029f07f542db73cca6de3 | [log] [tgz] |
---|---|---|
author | Yuta HIGUCHI <y-higuchi@ak.jp.nec.com> | Mon Sep 11 16:38:07 2017 -0700 |
committer | Thomas Vachuska <tom@opennetworking.org> | Fri Sep 15 15:14:25 2017 +0000 |
tree | 5c74da273c482af912834304ee36cd70a46ff89e | |
parent | 9fc3d0ee3c77b22be59ca217b607903e2029e7aa [diff] [blame] |
null tolerant DocumentPath hasher - DocumentPath parent can be null Change-Id: If0daf8f05db47f532e406c9879ff94ce72693791
diff --git a/core/store/primitives/src/main/java/org/onosproject/store/primitives/impl/FederatedDistributedPrimitiveCreator.java b/core/store/primitives/src/main/java/org/onosproject/store/primitives/impl/FederatedDistributedPrimitiveCreator.java index b7bb8f6..8d5668f 100644 --- a/core/store/primitives/src/main/java/org/onosproject/store/primitives/impl/FederatedDistributedPrimitiveCreator.java +++ b/core/store/primitives/src/main/java/org/onosproject/store/primitives/impl/FederatedDistributedPrimitiveCreator.java
@@ -147,7 +147,7 @@ Map<PartitionId, AsyncDocumentTree<V>> trees = Maps.transformValues(members, partition -> partition.<V>newAsyncDocumentTree(name, serializer)); Hasher<DocumentPath> hasher = key -> { - int bucket = Math.abs(Hashing.murmur3_32().hashUnencodedChars(key.toString()).asInt()) % buckets; + int bucket = Math.abs(Hashing.murmur3_32().hashUnencodedChars(String.valueOf(key)).asInt()) % buckets; return sortedMemberPartitionIds.get(Hashing.consistentHash(bucket, sortedMemberPartitionIds.size())); }; return new PartitionedAsyncDocumentTree<>(name, trees, hasher);