make infinite on worker barrier for all the cases
@@ -291,14 +291,13 @@ public class ODistributedDatabaseImpl implements ODistributedDatabase {
final CountDownLatch syncLatch = new CountDownLatch(involvedWorkerQueues.size());
final ODistributedRequest syncRequest = new ODistributedRequest(null, request.getId().getNodeId(), -1, databaseName,
new OSynchronizedTaskWrapper(syncLatch));
- int waitSize = 0;
for (int queue : involvedWorkerQueues) {
ODistributedWorker worker = workerThreads.get(queue);
- waitSize += worker.localQueue.size();
worker.processRequest(syncRequest);
}
- long taskTimeout = task.getDistributedTimeout() * waitSize;
+ // Make infinite timeout everytime
+ long taskTimeout = 0;
try {
if (taskTimeout <= 0)
syncLatch.await();
