if (!LOCKED_UPDATER.compareAndSet(this, null, newTx)) {
delegateTx.cancel();
- throw new IllegalStateException(String.format("New transaction %s raced with transacion %s", newTx, lockedTx));
+ throw new IllegalStateException(String.format("New transaction %s raced with transaction %s", newTx, lockedTx));
}
return newTx;
public DOMDataReadWriteTransaction newReadWriteTransaction() {
final PingPongTransaction tx = allocateTransaction();
final DOMDataReadWriteTransaction ret = new ForwardingDOMDataReadWriteTransaction() {
- private boolean isOpen;
+ private boolean isOpen = true;
@Override
protected DOMDataReadWriteTransaction delegate() {