Commit c46e8e15 authored by Tom Evans's avatar Tom Evans

Merge pull request #288 from AlphaGit/patch-1

OF-943: Timeout issues on synchronous cluster tasks
parents 0a31d495 775e466c
...@@ -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