Disabled forward of transaction to make sure that tests run correctly, will be re-enabled when the rest of refactor is done
@@ -490,6 +490,10 @@ public class ODatabaseDocumentDistributed extends ODatabaseDocumentEmbedded {
if (OScenarioThreadLocal.INSTANCE.isRunModeDistributed()) {
//Exclusive for handling schema manipulation, remove after refactor for distributed schema
super.internalCommit(iTx);
+ } else {
+ //Disabled forward of transaction to make sure that tests run correctly, will be re-enabled when the rest of refactor is done
+ if (true) {
+ realCommit(iTx);
} else {
OToLeaderTransactionTask message = new OToLeaderTransactionTask(iTx.getRecordOperations());
ODistributedServerManager dManager = getStorageDistributed().getDistributedManager();
@@ -510,12 +514,14 @@ public class ODatabaseDocumentDistributed extends ODatabaseDocumentEmbedded {
for (OToLeaderTransactionTaskResponse.ODeletedRecordResponse entry : ((OToLeaderTransactionTaskResponse) response
.getPayload()).getDeleted()) {
this.getLocalCache().deleteRecord(entry.getRid());
- }for (OToLeaderTransactionTaskResponse.OUpdatedRecordResponse entry : ((OToLeaderTransactionTaskResponse) response
+ }
+ for (OToLeaderTransactionTaskResponse.OUpdatedRecordResponse entry : ((OToLeaderTransactionTaskResponse) response
.getPayload()).getUpdated()) {
ORecordInternal.setVersion(iTx.getRecordEntry(entry.getRid()).getRecord(), entry.getVersion());
}
}
}
+ }
public void realCommit(OTransactionInternal iTx) {
//This is future may handle a retry
