+ @Override
+ public DOMDataTreeReadWriteTransaction newReadWriteTransaction() {
+ checkRunning();
+ checkWriteTxClosed();
+ checkReadTxClosed();
+ ShardedDOMReadWriteTransactionAdapter adapter = new ShardedDOMReadWriteTransactionAdapter(
+ newTransactionIdentifier(), cachedDataTreeService);
+ TransactionChainReadWriteTransaction readWriteTx = new TransactionChainReadWriteTransaction(
+ newTransactionIdentifier(), adapter, adapter.getReadAdapter(), writeTxCommitFuture, this);
+
+ writeTx = readWriteTx;
+ return readWriteTx;
+ }
+