- final NormalizedNode<?,?> node) throws InterruptedException, ExecutionException {
- final ReadWriteShardDataTreeTransaction transaction = store.newReadWriteTransaction(nextTransactionId());
-
- transaction.getSnapshot().write(id, node);
- final ShardDataTreeCohort cohort = transaction.ready();
- immediateCanCommit(cohort);
- immediatePreCommit(cohort);
- immediateCommit(cohort);
- }
-
- public void mergeToStore(final ShardDataTree store, final YangInstanceIdentifier id,
- final NormalizedNode<?,?> node) throws InterruptedException, ExecutionException {
- final ReadWriteShardDataTreeTransaction transaction = store.newReadWriteTransaction(nextTransactionId());
-
- transaction.getSnapshot().merge(id, node);
- final ShardDataTreeCohort cohort = transaction.ready();
- immediateCanCommit(cohort);
- immediatePreCommit(cohort);
- immediateCommit(cohort);
+ final NormalizedNode<?,?> node) throws DataValidationFailedException {
+ BatchedModifications batched = newBatchedModifications(nextTransactionId(), id, node, true, true, 1);
+ DataTreeModification modification = store.getDataTree().takeSnapshot().newModification();
+ batched.apply(modification);
+ store.notifyListeners(commitTransaction(store.getDataTree(), modification));