import org.simantics.db.request.MultiRead;
import org.simantics.db.request.Read;
import org.simantics.db.request.ReadInterface;
-import org.simantics.db.request.UndoTraits;
import org.simantics.db.request.Write;
import org.simantics.db.request.WriteInterface;
import org.simantics.db.request.WriteOnly;
callback.run(new DatabaseException("" + name + "operation failed.", t));
}
};
- final WriteTraits writeTraits = new WriteTraits() {
- @Override
- public UndoTraits getUndoTraits() {
- return null;
- }
- @Override
- public VirtualGraph getProvider() {
- return null;
- }
- };
+ final WriteTraits writeTraits = new WriteTraits() {};
TaskHelper(String name) {
this.name = name;
}
} catch (Throwable e) {
delayedWriteState.except(e);
total.finish();
+ dwg.close();
return;
} finally {
// newGraph.state.barrier.dec();
private void maintainCluster(ClusterImpl before, ClusterI after_) {
if(after_ != null && after_ != before) {
ClusterImpl after = (ClusterImpl)after_;
- if(currentCluster == before) currentCluster = after;
+ if(currentCluster == before) {
+ currentCluster = after;
+ }
clusterTable.replaceCluster(after);
}
}
public int createResourceKey(int foreignCounter) throws DatabaseException {
- if(currentCluster == null)
+ if(currentCluster == null) {
currentCluster = getNewResourceCluster();
+ }
if(currentCluster.getNumberOfResources(clusterTranslator) == ClusterTable.CLUSTER_FILL_SIZE) {
ClusterWriteOnly newCluster = (ClusterWriteOnly)getNewResourceCluster();
newCluster.foreignLookup = new byte[foreignCounter];