Commit 775e466c authored by Alpha's avatar Alpha

Timeout issues on synchronous cluster tasks

Details: https://community.igniterealtime.org/message/252259#252259
parent 0a31d495
...@@ -333,7 +333,7 @@ public class ClusteredCacheFactory implements CacheFactoryStrategy { ...@@ -333,7 +333,7 @@ public class ClusteredCacheFactory implements CacheFactoryStrategy {
for (Future<Object> future : futures.values()) { for (Future<Object> future : futures.values()) {
long start = System.nanoTime(); long start = System.nanoTime();
result.add(future.get(nanosLeft, TimeUnit.NANOSECONDS)); result.add(future.get(nanosLeft, TimeUnit.NANOSECONDS));
nanosLeft = (System.nanoTime() - start); nanosLeft = nanosLeft - (System.nanoTime() - start);
} }
} catch (TimeoutException te) { } catch (TimeoutException te) {
logger.error("Failed to execute cluster task within " + MAX_CLUSTER_EXECUTION_TIME + " seconds", te); logger.error("Failed to execute cluster task within " + MAX_CLUSTER_EXECUTION_TIME + " seconds", te);
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment