[ 
https://issues.apache.org/jira/browse/IGNITE-3955?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Pavel Tupitsyn updated IGNITE-3955:
-----------------------------------
    Description: 
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.

  was:
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, cache.get("myKey"));
    }
{code}

Run this test as part of GridCacheAtomicFullApiSelfTest.java.


> 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
>             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)

Reply via email to