final Operation fop = (Operation)ops.toArray()[0];
final DataContainer<Long> id = new DataContainer<Long>(0L);
final TaskHelper th = new TaskHelper("Undo");
- session.requestManager.scheduleWrite(new SessionTask(null, 0) {
+ session.requestManager.scheduleWrite(new SessionTask(null) {
@Override
- public void run(int thread) {
+ public void run0(int thread) {
session.flushCounter = 0;
session.clusterStream.reallyFlush();
ClientChangesImpl cs = new ClientChangesImpl(session);
um.setTypeAndRange(false, ope.getId(), ope.getCSId());
writer.addMetadata(um);
}
- session.getQueryProvider2().performDirtyUpdates(writer);
+ session.getQueryProvider2().propagateChangesInQueryCache(writer);
session.fireMetadataListeners(writer, cs);
- session.getQueryProvider2().performScheduledUpdates(writer);
+ session.getQueryProvider2().listening.fireListeners(writer);
session.fireReactionsToSynchronize(cs);
session.fireSessionVariableChange(SessionVariables.QUEUED_WRITES);
session.printDiagnostics();
e.printStackTrace();
Logger.defaultLogError(e);
th.throwableSet(e);
+ } finally {
+ cs.dispose();
}
}
});