} 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];