@Test public void testWriteCompletion() { completeOperation(transactionProxy -> { NormalizedNode<?, ?> nodeToWrite = ImmutableNodes.containerNode(TestModel.TEST_QNAME); expectBatchedModifications(2); transactionProxy.write(TestModel.TEST_PATH, nodeToWrite); transactionProxy.write(TestModel.TEST_PATH, nodeToWrite); }); }
@Override public void write(final YangInstanceIdentifier path, final NormalizedNode<?, ?> data) { checkModificationState("write", path); if (path.isEmpty()) { writeAllData(checkRootData(data)); } else { executeModification(new WriteOperation(path, data)); } }
TransactionProxy extends AbstractDOMStoreTransaction<TransactionIdentifier> implements DOMStoreReadWriteTransaction { @Override public void write(final YangInstanceIdentifier path, final NormalizedNode<?, ?> data) { checkModificationState("write", path); if (path.isEmpty()) { writeAllData(checkRootData(data)); } else { executeModification(new WriteOperation(path, data)); } } }
TransactionProxy extends AbstractDOMStoreTransaction<TransactionIdentifier> implements DOMStoreReadWriteTransaction { @Override public void write(final YangInstanceIdentifier path, final NormalizedNode<?, ?> data) { checkModificationState("write", path); if (path.isEmpty()) { writeAllData(checkRootData(data)); } else { executeModification(new WriteOperation(path, data)); } } @VisibleForTesting  TransactionProxy(final AbstractTransactionContextFactory<?> txContextFactory, final TransactionType type); }
TransactionProxy extends AbstractDOMStoreTransaction<TransactionIdentifier> implements DOMStoreReadWriteTransaction { @Override public void write(final YangInstanceIdentifier path, final NormalizedNode<?, ?> data) { checkModificationState("write", path); if (path.isEmpty()) { writeAllData(checkRootData(data)); } else { executeModification(new WriteOperation(path, data)); } } @VisibleForTesting  TransactionProxy(final AbstractTransactionContextFactory<?> txContextFactory, final TransactionType type); @Override FluentFuture<Boolean> exists(final YangInstanceIdentifier path); @Override FluentFuture<Optional<NormalizedNode<?, ?>>> read(final YangInstanceIdentifier path); @Override void delete(final YangInstanceIdentifier path); @Override void merge(final YangInstanceIdentifier path, final NormalizedNode<?, ?> data); @Override void write(final YangInstanceIdentifier path, final NormalizedNode<?, ?> data); @Override final void close(); @Override final AbstractThreePhaseCommitCohort<?> ready(); }
TransactionProxy extends AbstractDOMStoreTransaction<TransactionIdentifier> implements DOMStoreReadWriteTransaction { @Override public void write(final YangInstanceIdentifier path, final NormalizedNode<?, ?> data) { checkModificationState("write", path); if (path.isEmpty()) { writeAllData(checkRootData(data)); } else { executeModification(new WriteOperation(path, data)); } } @VisibleForTesting  TransactionProxy(final AbstractTransactionContextFactory<?> txContextFactory, final TransactionType type); @Override FluentFuture<Boolean> exists(final YangInstanceIdentifier path); @Override FluentFuture<Optional<NormalizedNode<?, ?>>> read(final YangInstanceIdentifier path); @Override void delete(final YangInstanceIdentifier path); @Override void merge(final YangInstanceIdentifier path, final NormalizedNode<?, ?> data); @Override void write(final YangInstanceIdentifier path, final NormalizedNode<?, ?> data); @Override final void close(); @Override final AbstractThreePhaseCommitCohort<?> ready();  }