[infinispan-commits] Infinispan SVN: r948 - in trunk/core/src: test/resources/stacks and 1 other directory.

[infinispan-commits at lists.jboss.org]

Author: vblagojevic at jboss.com
Date: 2009-10-14 15:18:39 -0400 (Wed, 14 Oct 2009)
New Revision: 948

Modified:
   trunk/core/src/main/java/org/infinispan/remoting/transport/jgroups/CommandAwareRpcDispatcher.java
   trunk/core/src/test/resources/stacks/tcp.xml
   trunk/core/src/test/resources/stacks/udp.xml
Log:
[ISPN-192] - Use JGroups 2.8 feature: flag to override message bundling at the transport level
bundling on

Modified: trunk/core/src/main/java/org/infinispan/remoting/transport/jgroups/CommandAwareRpcDispatcher.java
===================================================================
--- trunk/core/src/main/java/org/infinispan/remoting/transport/jgroups/CommandAwareRpcDispatcher.java	2009-10-14 19:17:16 UTC (rev 947)
+++ trunk/core/src/main/java/org/infinispan/remoting/transport/jgroups/CommandAwareRpcDispatcher.java	2009-10-14 19:18:39 UTC (rev 948)
@@ -228,7 +228,14 @@
          // if there is a JOIN in progress, wait for this to complete.
          // See ISPN-83 for more details.  Once ISPN-83 is addressed, this may no longer be needed.
          distributedSync.blockUntilNoJoinsInProgress();
-
+         
+         //Use JGroups 2.8 feature Message.DONT_BUNDLE flag to override message bundling at the transport level
+         //for asynchronous calls
+         //See ISPN-192 for more details
+         if (mode == GroupRequest.GET_NONE) {
+            msg.setFlag(Message.DONT_BUNDLE);
+         }
+         
          RspList retval = castMessage(dests, msg, mode, timeout, anycasting, filter);
          if (trace) log.trace("responses: {0}", retval);
 

Modified: trunk/core/src/test/resources/stacks/tcp.xml
===================================================================
--- trunk/core/src/test/resources/stacks/tcp.xml	2009-10-14 19:17:16 UTC (rev 947)
+++ trunk/core/src/test/resources/stacks/tcp.xml	2009-10-14 19:18:39 UTC (rev 948)
@@ -9,7 +9,7 @@
         discard_incompatible_packets="true"
         max_bundle_size="64000"
         max_bundle_timeout="30"
-        enable_bundling="false"
+        enable_bundling="true"
         use_send_queues="false"
         sock_conn_timeout="300"
         enable_diagnostics="false"

Modified: trunk/core/src/test/resources/stacks/udp.xml
===================================================================
--- trunk/core/src/test/resources/stacks/udp.xml	2009-10-14 19:17:16 UTC (rev 947)
+++ trunk/core/src/test/resources/stacks/udp.xml	2009-10-14 19:18:39 UTC (rev 948)
@@ -13,8 +13,8 @@
          discard_incompatible_packets="true"
          max_bundle_size="64000"
          max_bundle_timeout="30"
-         ip_ttl="${jgroups.udp.ip_ttl:0}"
-         enable_bundling="false"
+         ip_ttl="${jgroups.udp.ip_ttl:2}"
+         enable_bundling="true"
          enable_diagnostics="false"
 
          thread_naming_pattern="pl"