}
// This will send and accept the reverse change set.
transactionToken.cancelEnd(session.writeSupport, null, session.clusterStream);
+ } else {
+ queryProvider.performDirtyUpdates(graph);
+ queryProvider.performScheduledUpdates(graph);
}
}
session.writeSupport.clearMetadata();
// deny can always remove a persistent statement.
clusterStream.reallyFlush();
- Disposable.safeDispose(session.clientChanges);
session.clientChanges = new ClientChangesImpl(session);
this.close(); // Everything is lost anyway.
throw new IllegalStateException(e);
} finally {
+ Disposable.safeDispose(cs);
lock.unlock();
}
}