- TransactionContextWrapper contextAdapter = getContextAdapter(path);
- contextAdapter.maybeExecuteTransactionOperation(new TransactionOperation() {
- @Override
- public void invoke(TransactionContext transactionContext) {
- transactionContext.mergeData(path, data);
- }
- });
+ private void mergeAllData(final ContainerNode rootData) {
+ // Populate requests for individual shards that are being touched
+ final Map<String, DataContainerNodeBuilder<NodeIdentifier, ContainerNode>> rootBuilders = new HashMap<>();
+ for (DataContainerChild child : rootData.body()) {
+ final String shardName = shardNameFromRootChild(child);
+ rootBuilders.computeIfAbsent(shardName,
+ unused -> Builders.containerBuilder().withNodeIdentifier(rootData.getIdentifier()))
+ .addChild(child);
+ }
+
+ // Now dispatch all merges
+ for (Entry<String, DataContainerNodeBuilder<NodeIdentifier, ContainerNode>> entry : rootBuilders.entrySet()) {
+ getContextWrapper(entry.getKey()).maybeExecuteTransactionOperation(new MergeOperation(
+ YangInstanceIdentifier.empty(), entry.getValue().build()));
+ }