fixed scheduling of task in case of re-enqueue of request
@@ -306,6 +306,7 @@ public class OTransactionPhase1Task extends OAbstractReplicatedTask {
@Override
public void received(ODistributedRequest request, ODistributedDatabase distributedDatabase) {
+ if (notYetFinishedTask == null) {
notYetFinishedTask = new TimerTask() {
@Override
public void run() {
@@ -320,3 +321,4 @@ public class OTransactionPhase1Task extends OAbstractReplicatedTask {
Orient.instance().scheduleTask(notYetFinishedTask, getDistributedTimeout(), getDistributedTimeout());
}
}
+}
