[
https://issues.apache.org/jira/browse/IGNITE-3955?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15666757#comment-15666757
]
Pavel Tupitsyn commented on IGNITE-3955:
----------------------------------------
[~kdudkov] The issue is not about the test.
Our API allows invokeAll in any cache mode, and fails to return correct results
in some of them.
We should either fix this, or restrict invokeAll to certain cache modes and
throw exception in other modes (and document this accordingly).
> IgniteCache.invokeAll returns empty result set in ATOMIC cache
> --------------------------------------------------------------
>
> Key: IGNITE-3955
> URL: https://issues.apache.org/jira/browse/IGNITE-3955
> Project: Ignite
> Issue Type: Bug
> Components: cache
> Affects Versions: 1.7
> Reporter: Pavel Tupitsyn
> Assignee: Konstantin Dudkov
> Fix For: 1.8
>
>
> When entry processor is invoked from multiple threads, result set is
> sometimes empty.
> This happens with ATOMIC cache, but not with TRANSACTIONAL.
> To reproduce, paste the following into GridCacheAbstractFullApiSelfTest.java:
> {code}
> public void testInvokeAllMultithreaded() throws Exception {
> final IgniteCache<String, Integer> cache = jcache();
> final int threadCnt = 4;
> final int cnt = 90000;
> final Set<String> keys = Collections.singleton("myKey");
> GridTestUtils.runMultiThreaded(new Runnable() {
> @Override public void run() {
> for (int i = 0; i < cnt; i++) {
> final Map<String, EntryProcessorResult<Integer>> res =
> cache.invokeAll(keys, new CacheEntryProcessor<String,
> Integer, Integer>() {
> @Override
> public Integer process(MutableEntry<String,
> Integer> entry,
> Object... objects) throws
> EntryProcessorException {
> Integer val = entry.getValue();
> if (val == null)
> val = 0;
> val++;
> entry.setValue(val);
> return val;
> }
> });
> assertEquals(1, res.size());
> }
> }
> }, threadCnt, "testInvokeAllMultithreaded");
> assertEquals(cnt*threadCnt, (int)cache.get("myKey"));
> }
> {code}
> Run this test as part of GridCacheAtomicFullApiSelfTest.java.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
