[
https://issues.jboss.org/browse/ISPN-1129?page=com.atlassian.jira.plugin....
]
Mikhail Khludnev updated ISPN-1129:
-----------------------------------
Steps to Reproduce:
org.infinispan.distexec.DistributedExecutorTest
public void testInvokeAny() throws Exception {
DistributedExecutorService des = new DefaultExecutorService(c1);
Integer r = des.invokeAny(Arrays.<Callable<Integer>>asList(
new SimpleCallable(),new SimpleCallable(),new SimpleCallable()),
100, TimeUnit.MILLISECONDS);
assert r == 1;
}
as result I have timeout exception, avoiding the time boundary leads to an infinite
invokeAny().
was:
org.infinispan.distexec.DistributedExecutorTest
public void testInvokeAny() throws Exception {
DistributedExecutorService des = new DefaultExecutorService(c1);
Integer r = des.invokeAny(Arrays.<Callable<Integer>>asList(
new SimpleCallable(),new SimpleCallable(),new SimpleCallable()),
100, TimeUnit.MILLISECONDS);
assert r == 1;
}
as result I have timeout exception, avoiding time boundary leads to infinite invokeAny().
method o.i.distexec.DefaultExecutorService.invokeAny(Collection
tasks) never returns
------------------------------------------------------------------------------------
Key: ISPN-1129
URL:
https://issues.jboss.org/browse/ISPN-1129
Project: Infinispan
Issue Type: Bug
Components: Core API
Affects Versions: 5.0.0.CR3
Reporter: Mikhail Khludnev
Assignee: Manik Surtani
DefaultExecutorService.invokeAny() seems not working ever just because
DistributedExecutionCompletionService seems not working too, because it never attach
it's listener to tasks. I made a test, but didn't find an easy approach to fix it.
--
This message is automatically generated by JIRA.
For more information on JIRA, see:
http://www.atlassian.com/software/jira