6 Replies Latest reply on Oct 12, 2011 3:55 AM by Galder Zamarreño

    There's no atomicmap replication in this configuration

    Nikolay Kondrashov Newbie

      Hi,

       

      inifinispan                5.1.0 Beta1

      JAVA                       1.6.0_23

      useLockStriping            false

      isolationLevel             REPEATABLE_READ

      stateRetrieval             fetchInMemoryState="true"

      clustering mode            replication async asyncMarshalling="true" useReplQueue="true" replQueueInterval="200"

      networking                 TCP

      TM                         JBossStandaloneJTAManager

      deadlockDetection          false

       

       

      Here's a simple test.

      The same code is used by both nodes.

       

      Each node runs loop of iterations, each iteration modifies only one element randomly chosen from 2 elements with the keys: '0' and '1'

      and then prints immediately values of both elements key: '0' or key: '1'. Node puts random value 0-9 and its name A or B.

      2 nodes competes for these elements with keys 0 and 1.

      Output like this "2-A,7-B" means element key 0 has been updated by node A with value 2, key 1 has been updated by node B with value 7

       

       

      1st phase - Map is being updated

      2nd phase - cache itself is used to store elements

       

      during 1st phase changes made by nodes are NOT propagated to the opposite node. This is wrong behaviour. Why is it happening?

      during 2nd phase changes made by nodes are being properly propagated to the opposite node. This is correct behaviour.

       

      Code, logs and ouputs are zipped and attached.

       

      Thank you.

       

           [java] Fri Oct 07 21:49:16 EDT 2011 *******************************************
           [java] Fri Oct 07 21:49:16 EDT 2011 ************* PHASE 1     MAP   ***********
           [java] Fri Oct 07 21:49:16 EDT 2011 *******************************************
           [java] Fri Oct 07 21:49:17 EDT 2011 null,7-A,
           [java] Fri Oct 07 21:49:17 EDT 2011 4-A,7-A,
           [java] Fri Oct 07 21:49:17 EDT 2011 4-A,8-A,
           [java] Fri Oct 07 21:49:17 EDT 2011 3-A,8-A,
           [java] Fri Oct 07 21:49:18 EDT 2011 4-A,8-A,
           [java] Fri Oct 07 21:49:18 EDT 2011 4-A,6-A,
           [java] Fri Oct 07 21:49:18 EDT 2011 4-A,4-A,
      ...skipped
      
           [java] Fri Oct 07 21:49:27 EDT 2011 *******************************************
           [java] Fri Oct 07 21:49:27 EDT 2011 ************* PHASE 2     CACHE ***********
           [java] Fri Oct 07 21:49:27 EDT 2011 *******************************************
           [java] Fri Oct 07 21:49:27 EDT 2011 null,4-A,
           [java] Fri Oct 07 21:49:27 EDT 2011 null,4-A,
           [java] Fri Oct 07 21:49:27 EDT 2011 null,0-A,
           [java] Fri Oct 07 21:49:28 EDT 2011 null,2-A,
      ...skipped
      
           [java] Fri Oct 07 21:49:30 EDT 2011 1-A,0-A,
           [java] Fri Oct 07 21:49:30 EDT 2011 5-A,0-A,
           [java] Fri Oct 07 21:49:30 EDT 2011 5-A,0-A,
           [java] Fri Oct 07 21:49:31 EDT 2011 6-B,8-A,
           [java] Fri Oct 07 21:49:31 EDT 2011 1-B,5-A,
           [java] Fri Oct 07 21:49:31 EDT 2011 4-A,5-A,
           [java] Fri Oct 07 21:49:31 EDT 2011 4-A,2-A,
           [java] Fri Oct 07 21:49:32 EDT 2011 8-B,3-A,
           [java] Fri Oct 07 21:49:32 EDT 2011 1-B,6-A,
      ...skipped