From 1f3257a53a8c53b3e9bae35d5d8872522f51b9a4 Mon Sep 17 00:00:00 2001 From: Jakub Morvay Date: Sat, 18 Mar 2017 09:44:48 +0100 Subject: [PATCH] Seal only modified modifications Change-Id: I839eaebbf367a44b17595070fdea76d1f879f204 Signed-off-by: Jakub Morvay --- .../cluster/sharding/DistributedShardModification.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/sharding/DistributedShardModification.java b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/sharding/DistributedShardModification.java index 2bd0dae76c..4a36c386b1 100644 --- a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/sharding/DistributedShardModification.java +++ b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/sharding/DistributedShardModification.java @@ -57,7 +57,9 @@ public class DistributedShardModification extends WriteableNodeWithSubshard { } DOMStoreThreePhaseCommitCohort seal() { - childShards.values().forEach(ForeignShardModificationContext::ready); + childShards.values().stream().filter(ForeignShardModificationContext::isModified) + .forEach(ForeignShardModificationContext::ready); + return context.ready(); } -- 2.36.6