Author: mircea.markus Date: 2008-12-18 21:32:29 -0500 (Thu, 18 Dec 2008) New Revision: 7337 Modified: core/trunk/pom.xml core/trunk/src/main/resources/config-samples/buddy-replication.xml core/trunk/src/test/java/org/jboss/cache/UnitTestCacheFactory.java core/trunk/src/test/java/org/jboss/cache/buddyreplication/Buddy3NodesNoPoolWithDataGravitationTest.java core/trunk/src/test/java/org/jboss/cache/factories/UnitTestCacheConfigurationFactory.java core/trunk/src/test/java/org/jboss/cache/multiplexer/ChannelInjectionPreferenceTest.java core/trunk/src/test/java/org/jboss/cache/testng/Base.java core/trunk/src/test/java/org/jboss/cache/testng/Other.java core/trunk/src/test/resources/configs/buddy-replication-cache.xml core/trunk/src/test/resources/configs/conf2x/buddy-replication-cache.xml Log: run tests on TCP Modified: core/trunk/pom.xml =================================================================== --- core/trunk/pom.xml 2008-12-18 21:56:44 UTC (rev 7336) +++ core/trunk/pom.xml 2008-12-19 02:32:29 UTC (rev 7337) @@ -141,6 +141,12 @@ <parallel>tests</parallel> <threadCount>10</threadCount> <forkMode>none</forkMode> + <systemProperties> + <property> + <name>jgroups.stack</name> + <value>${protocol.stack}</value> + </property> + </systemProperties> <trimStackTrace>false</trimStackTrace> <properties> <property> @@ -398,6 +404,7 @@ <id>test-hudson</id> <properties> <defaultTestGroup>functional,unit</defaultTestGroup> + <protocol.stack>udp</protocol.stack> </properties> </profile> @@ -405,6 +412,7 @@ <id>test-functional</id> <properties> <defaultTestGroup>functional</defaultTestGroup> + <protocol.stack>tcp</protocol.stack> </properties> </profile> @@ -440,6 +448,7 @@ <id>test-integration</id> <properties> <defaultTestGroup>integration</defaultTestGroup> + <protocol.stack>udp</protocol.stack> </properties> </profile> Modified: core/trunk/src/main/resources/config-samples/buddy-replication.xml =================================================================== --- core/trunk/src/main/resources/config-samples/buddy-replication.xml 2008-12-18 21:56:44 UTC (rev 7336) +++ core/trunk/src/main/resources/config-samples/buddy-replication.xml 2008-12-19 02:32:29 UTC (rev 7337) @@ -14,7 +14,7 @@ <!-- JGroups protocol stack properties. --> <jgroupsConfig> - <TCP discard_incompatible_packets="true" enable_bundling="false" enable_diagnostics="true" + <TCP start_port="7800" discard_incompatible_packets="true" enable_bundling="false" enable_diagnostics="true" enable_unicast_bundling="false" loopback="false" max_bundle_size="64000" max_bundle_timeout="30" oob_thread_pool.enabled="true" oob_thread_pool.keep_alive_time="10000" oob_thread_pool.max_threads="8" oob_thread_pool.min_threads="2" oob_thread_pool.queue_enabled="false" oob_thread_pool.queue_max_size="10" Modified: core/trunk/src/test/java/org/jboss/cache/UnitTestCacheFactory.java =================================================================== --- core/trunk/src/test/java/org/jboss/cache/UnitTestCacheFactory.java 2008-12-18 21:56:44 UTC (rev 7336) +++ core/trunk/src/test/java/org/jboss/cache/UnitTestCacheFactory.java 2008-12-19 02:32:29 UTC (rev 7337) @@ -55,6 +55,17 @@ } }; + private static final ThreadLocal<String> threadTcpStartPort = new ThreadLocal<String>() + { + private final AtomicInteger uniqueAddr = new AtomicInteger(7800); + + @Override + protected String initialValue() + { + return uniqueAddr.getAndAdd(10) + ""; + } + }; + /** * Holds unique mcast_port for each thread used for JGroups channel construction. */ @@ -166,7 +177,7 @@ break; default: log.info("Unknown cache mode!"); - System.exit(0); + throw new IllegalStateException("Unknown cache mode!"); } Cache<K, V> cache = new DefaultCacheFactory<K, V>().createCache(configuration, start); @@ -240,7 +251,9 @@ */ public void mangleConfiguration(Configuration configuration) { - configuration.setClusterConfig(mangleClusterConfiguration(configuration.getClusterConfig())); + String clusterConfig = configuration.getClusterConfig(); + clusterConfig = mangleClusterConfiguration(clusterConfig); + configuration.setClusterConfig(clusterConfig); // Check if the cluster name contains thread id. If not, append. // We can not just append the threadId, since some of the tests are crating instances // using configurations derived from configurations returned by this factory. @@ -256,10 +269,29 @@ } + public String mangleClusterConfiguration(String clusterConfig) + { + if (clusterConfig == null) + { + if (UnitTestCacheConfigurationFactory.JGROUPS_CHANNEL.equals("udp")) + return mangleClusterConfigurationUdp(clusterConfig); + else + return mangleClusterConfigurationTcp(clusterConfig); + } + if (clusterConfig.contains("UDP(")) + { + clusterConfig = mangleClusterConfigurationUdp(clusterConfig); + } else + { + clusterConfig = mangleClusterConfigurationTcp(clusterConfig); + } + return clusterConfig; + } + /** * Updates cluster configuration to ensure mutual thread isolation. */ - public String mangleClusterConfiguration(String clusterConfig) + public String mangleClusterConfigurationUdp(String clusterConfig) { if (clusterConfig == null) { @@ -272,18 +304,17 @@ } - // replace mcast_addr + // replace mcast_addr Pattern pattern = Pattern.compile("mcast_addr=[^;]*"); Matcher m = pattern.matcher(clusterConfig); if (m.find()) { - String origAddr = m.group().substring(m.group().indexOf("=") + 1); String newAddr = threadMcastIP.get(); clusterConfig = m.replaceFirst("mcast_addr=" + newAddr); } else { Thread.dumpStack(); - System.exit(1); + throw new IllegalStateException(); } // replace mcast_port @@ -299,6 +330,43 @@ return clusterConfig; } + /** + * Updates cluster configuration to ensure mutual thread isolation. + */ + public String mangleClusterConfigurationTcp(String clusterConfig) + { + if (clusterConfig == null) + { + clusterConfig = UnitTestCacheConfigurationFactory.createConfiguration(Configuration.CacheMode.REPL_SYNC).getClusterConfig(); + } + + // replace mcast_addr + Pattern pattern = Pattern.compile("start_port=[^;]*"); + Matcher m = pattern.matcher(clusterConfig); + String newStartPort = null; + if (m.find()) + { + newStartPort = threadTcpStartPort.get(); + clusterConfig = m.replaceFirst("start_port=" + newStartPort); + } + else + { + System.out.println("Config is;" + clusterConfig); + Thread.dumpStack(); + throw new IllegalStateException(); + } + + // replace mcast_port + pattern = Pattern.compile("initial_hosts=[^;]*"); + m = pattern.matcher(clusterConfig); + if (m.find()) + { + clusterConfig = m.replaceFirst("initial_hosts=" + "127.0.0.1["+ newStartPort +"]"); + } + + return clusterConfig; + } + // private String getThreadId() // { // return "[" + Thread.currentThread().getName() + "]"; @@ -339,4 +407,4 @@ } return null; } -} +} \ No newline at end of file Modified: core/trunk/src/test/java/org/jboss/cache/buddyreplication/Buddy3NodesNoPoolWithDataGravitationTest.java =================================================================== --- core/trunk/src/test/java/org/jboss/cache/buddyreplication/Buddy3NodesNoPoolWithDataGravitationTest.java 2008-12-18 21:56:44 UTC (rev 7336) +++ core/trunk/src/test/java/org/jboss/cache/buddyreplication/Buddy3NodesNoPoolWithDataGravitationTest.java 2008-12-19 02:32:29 UTC (rev 7337) @@ -88,59 +88,7 @@ } - public void testCompleteStateSurvival() throws Exception - { - CacheBlockListener blockListener = new CacheBlockListener(); - caches.get(0).addCacheListener(blockListener); - caches.get(1).addCacheListener(blockListener); - caches.get(2).addCacheListener(blockListener); - - caches.get(0).put("/0", "key", "value"); - caches.get(1).put("/1", "key", "value"); - caches.get(2).put("/2", "key", "value"); - -// TestingUtil.sleepThread(getSleepTimeout()); - //TestingUtil.sleepThread(caches.get(0).getConfiguration().getStateRetrievalTimeout() * 3); - blockListener.blockUntilAllCachesAreUnblocked(caches.get(0).getConfiguration().getStateRetrievalTimeout() * 3); - - caches.get(2).stop(); - - blockListener.blockUntilAllCachesAreUnblocked(caches.get(0).getConfiguration().getStateRetrievalTimeout() * 5); - - assertEquals("value", caches.get(0).get("/2", "key")); - - blockListener.blockUntilAllCachesAreUnblocked(caches.get(0).getConfiguration().getStateRetrievalTimeout() * 5); - - caches.get(1).stop(); - - // cache[0] is all thats left!! - - assertEquals("value", caches.get(0).get("/0", "key")); - - try - { - assertEquals("value", caches.get(0).get("/1", "key")); - } - catch (RuntimeException e) - { - // may barf the first time around since we are unable to contact our buddy and store this data. - assertEquals(IllegalArgumentException.class, e.getCause().getClass()); - } - - // now try the assertion again since the local gravitation would have worked. - - assertEquals("value", caches.get(0).get("/1", "key")); - assertEquals("value", caches.get(0).get("/2", "key")); - caches.get(1).start(); - caches.get(2).start(); - caches.get(0).removeCacheListener(blockListener); - caches.get(1).removeCacheListener(blockListener); - caches.get(2).removeCacheListener(blockListener); - - waitForSingleBuddy(caches); - } - public void testTransactionsCommit() throws Exception { @@ -506,4 +454,57 @@ } } } + + @Test (enabled = true, dependsOnMethods = {"testConcurrency","testStaleRegionOnBuddy","testStaleRegionOnDataOwner", "testDataGravitationDontKillOwner", "testTransactionsCommit", "testTransactionsRollback", "testSubtreeRetrieval"}) + public void testCompleteStateSurvival() throws Exception + { + CacheBlockListener blockListener = new CacheBlockListener(); + + caches.get(0).addCacheListener(blockListener); + caches.get(1).addCacheListener(blockListener); + caches.get(2).addCacheListener(blockListener); + + caches.get(0).put("/0", "key", "value"); + caches.get(1).put("/1", "key", "value"); + caches.get(2).put("/2", "key", "value"); + +// TestingUtil.sleepThread(getSleepTimeout()); + //TestingUtil.sleepThread(caches.get(0).getConfiguration().getStateRetrievalTimeout() * 3); + blockListener.blockUntilAllCachesAreUnblocked(caches.get(0).getConfiguration().getStateRetrievalTimeout() * 3); + + caches.get(2).stop(); + + blockListener.blockUntilAllCachesAreUnblocked(caches.get(0).getConfiguration().getStateRetrievalTimeout() * 5); + + assertEquals("value", caches.get(0).get("/2", "key")); + + blockListener.blockUntilAllCachesAreUnblocked(caches.get(0).getConfiguration().getStateRetrievalTimeout() * 5); + + caches.get(1).stop(); + + // cache[0] is all thats left!! + + assertEquals("value", caches.get(0).get("/0", "key")); + + try + { + assertEquals("value", caches.get(0).get("/1", "key")); + } + catch (RuntimeException e) + { + // may barf the first time around since we are unable to contact our buddy and store this data. + assertEquals(IllegalArgumentException.class, e.getCause().getClass()); + } + + // now try the assertion again since the local gravitation would have worked. + + assertEquals("value", caches.get(0).get("/1", "key")); + assertEquals("value", caches.get(0).get("/2", "key")); + caches.get(0).stop(); + + caches = createCaches(3, false, true); + + waitForSingleBuddy(caches); + } + } Modified: core/trunk/src/test/java/org/jboss/cache/factories/UnitTestCacheConfigurationFactory.java =================================================================== --- core/trunk/src/test/java/org/jboss/cache/factories/UnitTestCacheConfigurationFactory.java 2008-12-18 21:56:44 UTC (rev 7336) +++ core/trunk/src/test/java/org/jboss/cache/factories/UnitTestCacheConfigurationFactory.java 2008-12-19 02:32:29 UTC (rev 7337) @@ -37,6 +37,7 @@ static { JGROUPS_CHANNEL = System.getProperty(JGROUPS_STACK_TYPE, "tcp"); + System.out.println("IN USE JGROUPS_CHANNEL = " + JGROUPS_CHANNEL); } public static Configuration createConfiguration(CacheMode mode) throws ConfigurationException @@ -232,13 +233,13 @@ if (stackName.startsWith(JGROUPS_CHANNEL)) { Element jgroupsStack = (Element) stack.getElementsByTagNameNS("*", "config").item(0); - if (mode == CacheMode.REPL_ASYNC && !stackName.contains("-")) + if (!mode.isSynchronous() && !stackName.contains("-")) { conf.setClusterConfig(jgroupsStack); conf.setCacheMode(CacheMode.REPL_ASYNC); break; } - else if (mode == CacheMode.REPL_SYNC && stackName.contains("-")) + else if (mode.isSynchronous() && stackName.contains("-")) { conf.setClusterConfig(jgroupsStack); conf.setCacheMode(CacheMode.REPL_SYNC); Modified: core/trunk/src/test/java/org/jboss/cache/multiplexer/ChannelInjectionPreferenceTest.java =================================================================== --- core/trunk/src/test/java/org/jboss/cache/multiplexer/ChannelInjectionPreferenceTest.java 2008-12-18 21:56:44 UTC (rev 7336) +++ core/trunk/src/test/java/org/jboss/cache/multiplexer/ChannelInjectionPreferenceTest.java 2008-12-19 02:32:29 UTC (rev 7337) @@ -63,7 +63,7 @@ { muxHelper.configureCacheForMux(cache); - Channel channel = new JChannel(new UnitTestCacheFactory().mangleClusterConfiguration( + Channel channel = new JChannel(new UnitTestCacheFactory().mangleClusterConfigurationUdp( UnitTestCacheConfigurationFactory.getClusterConfigFromProperties(JChannel.DEFAULT_PROTOCOL_STACK))); RuntimeConfig rtcfg = cache.getConfiguration().getRuntimeConfig(); Modified: core/trunk/src/test/java/org/jboss/cache/testng/Base.java =================================================================== --- core/trunk/src/test/java/org/jboss/cache/testng/Base.java 2008-12-18 21:56:44 UTC (rev 7336) +++ core/trunk/src/test/java/org/jboss/cache/testng/Base.java 2008-12-19 02:32:29 UTC (rev 7337) @@ -1,33 +1,72 @@ package org.jboss.cache.testng; import org.testng.annotations.*; +import org.jboss.cache.Cache; +import org.jboss.cache.UnitTestCacheFactory; +import org.jboss.cache.config.*; +import org.jboss.cache.config.Configuration; +import org.jboss.cache.factories.UnitTestCacheConfigurationFactory; /** * @author Mircea.Markus(a)jboss.com */ -@Test(groups = "functional") -public abstract class Base +@Test(groups = "functional", testName = "Base") +public class Base { + Cache cache; + @BeforeClass public void beforeTest() { - System.out.println("Base.beforeTest"); +// System.out.println("Base.beforeTest"); + Configuration config = UnitTestCacheConfigurationFactory.createConfiguration(Configuration.CacheMode.REPL_SYNC, true); + cache = new UnitTestCacheFactory().createCache(config, true, getClass()); + System.out.println("Base:::" + cache.getConfiguration().getClusterConfig()); } @AfterClass public void afterTest() { - System.out.println("Base.afterTest"); +// System.out.println("Base.afterTest"); + cache.stop(); } @BeforeMethod public void beforeMethod() { - System.out.println("Base.beforeMethod"); +// System.out.println("Base.beforeMethod"); } + public void testNoTest() {} protected String getThreadName() { return "[" + getClass() + " ************ -> " + Thread.currentThread().getName() + "] "; } } + +//Base:::UDP(discard_incompatible_packets=true;enable_bundling=false;enable_diagnostics=true;ip_ttl=2;loopback=false;m +//ax_bundle_size=64000;max_bundle_timeout=30;mcast_addr=228.10.10.11;mcast_port=45589;mcast_recv_buf_size=25000000;mca +//st_send_buf_size=640000;oob_thread_pool.enabled=true;oob_thread_pool.keep_alive_time=10000;oob_thread_pool.max_threa +//ds=4;oob_thread_pool.min_threads=1;oob_thread_pool.queue_enabled=false;oob_thread_pool.queue_max_size=10;oob_thread_ +//pool.rejection_policy=Run;thread_naming_pattern=pl;thread_pool.enabled=true;thread_pool.keep_alive_time=30000;thread +//_pool.max_threads=25;thread_pool.min_threads=1;thread_pool.queue_enabled=false;thread_pool.queue_max_size=100;thread +//_pool.rejection_policy=Run;tos=8;ucast_recv_buf_size=20000000;ucast_send_buf_size=640000;use_concurrent_stack=true;u +//se_incoming_packet_handler=true):PING(num_initial_members=3;timeout=2000):MERGE2(max_interval=30000;min_interval=100 +//00):FD_SOCK:FD(max_tries=2;shun=true;timeout=1000):VERIFY_SUSPECT(timeout=250):pbcast.NAKACK(discard_delivered_msgs= +//true;gc_lag=0;retransmit_timeout=300,600,900,1200;use_mcast_xmit=false):UNICAST(timeout=300,600,900,1200):pbcast.STA +//BLE(desired_avg_gossip=50000;max_bytes=400000;stability_delay=1000):pbcast.GMS(join_timeout=1000;print_local_addr=fa +//lse;shun=false;view_ack_collection_timeout=1000;view_bundling=true):FRAG2(frag_size=60000):pbcast.STREAMING_STATE_TR +//ANSFER:pbcast.FLUSH(timeout=0) +//Other:::UDP(discard_incompatible_packets=true;enable_bundling=false;enable_diagnostics=true;ip_ttl=2;loopback=false; +//max_bundle_size=64000;max_bundle_timeout=30;mcast_addr=228.10.10.12;mcast_port=45590;mcast_recv_buf_size=25000000;mc +//ast_send_buf_size=640000;oob_thread_pool.enabled=true;oob_thread_pool.keep_alive_time=10000;oob_thread_pool.max_thre +//ads=4;oob_thread_pool.min_threads=1;oob_thread_pool.queue_enabled=false;oob_thread_pool.queue_max_size=10;oob_thread +//_pool.rejection_policy=Run;thread_naming_pattern=pl;thread_pool.enabled=true;thread_pool.keep_alive_time=30000;threa +//d_pool.max_threads=25;thread_pool.min_threads=1;thread_pool.queue_enabled=false;thread_pool.queue_max_size=100;threa +//d_pool.rejection_policy=Run;tos=8;ucast_recv_buf_size=20000000;ucast_send_buf_size=640000;use_concurrent_stack=true; +//use_incoming_packet_handler=true):PING(num_initial_members=3;timeout=2000):MERGE2(max_interval=30000;min_interval=10 +//000):FD_SOCK:FD(max_tries=2;shun=true;timeout=1000):VERIFY_SUSPECT(timeout=250):pbcast.NAKACK(discard_delivered_msgs +//=true;gc_lag=0;retransmit_timeout=300,600,900,1200;use_mcast_xmit=false):UNICAST(timeout=300,600,900,1200):pbcast.ST +//ABLE(desired_avg_gossip=50000;max_bytes=400000;stability_delay=1000):pbcast.GMS(join_timeout=1000;print_local_addr=f +//alse;shun=false;view_ack_collection_timeout=1000;view_bundling=true):FRAG2(frag_size=60000):pbcast.STREAMING_STATE_T +//RANSFER:pbcast.FLUSH(timeout=0) \ No newline at end of file Modified: core/trunk/src/test/java/org/jboss/cache/testng/Other.java =================================================================== --- core/trunk/src/test/java/org/jboss/cache/testng/Other.java 2008-12-18 21:56:44 UTC (rev 7336) +++ core/trunk/src/test/java/org/jboss/cache/testng/Other.java 2008-12-19 02:32:29 UTC (rev 7337) @@ -1,23 +1,51 @@ package org.jboss.cache.testng; import org.testng.annotations.Test; +import org.testng.annotations.BeforeClass; +import org.testng.annotations.AfterClass; +import org.jboss.cache.Cache; +import org.jboss.cache.UnitTestCacheFactory; +import org.jboss.cache.config.Configuration; +import org.jboss.cache.factories.UnitTestCacheConfigurationFactory; /** * @author Mircea.Markus(a)jboss.com */ -@Test(groups = "functional", enabled = false, testName = "Same") +@Test(groups = "functional", testName = "Same") public class Other { - public void eeeeeeeeeeee() { - System.out.println(getThreadName() + " eeeeeeeeeeee"); + Cache cache; + + @BeforeClass + public void beforeTest() + { +// System.out.println("Base.beforeTest"); + Configuration config = UnitTestCacheConfigurationFactory.createConfiguration(Configuration.CacheMode.REPL_SYNC, true); + cache = new UnitTestCacheFactory().createCache(config, true, getClass()); + System.out.println("Other:::" + cache.getConfiguration().getClusterConfig()); } - public void ffffffffffff() { - System.out.println(getThreadName() + " ffffffffffff"); - } - protected String getThreadName() + @AfterClass + public void afterTest() { - return "[" + getClass() + " ************ -> " + Thread.currentThread().getName() + "] "; +// System.out.println("Base.afterTest"); + cache.stop(); } + public void testNoTest(){} } + + +//One:::UDP(discard_incompatible_packets=true;enable_bundling=false;enable_diagnostics=true;ip_ttl=2;loopback=false;ma +//x_bundle_size=64000;max_bundle_timeout=30;mcast_addr=228.10.10.11;mcast_port=45589;mcast_recv_buf_size=25000000;mcas +//t_send_buf_size=640000;oob_thread_pool.enabled=true;oob_thread_pool.keep_alive_time=10000;oob_thread_pool.max_thread +//s=4;oob_thread_pool.min_threads=1;oob_thread_pool.queue_enabled=false;oob_thread_pool.queue_max_size=10;oob_thread_p +//ool.rejection_policy=Run;thread_naming_pattern=pl;thread_pool.enabled=true;thread_pool.keep_alive_time=30000;thread_ +//pool.max_threads=25;thread_pool.min_threads=1;thread_pool.queue_enabled=false;thread_pool.queue_max_size=100;thread_ +//pool.rejection_policy=Run;tos=8;ucast_recv_buf_size=20000000;ucast_send_buf_size=640000;use_concurrent_stack=true;us +//e_incoming_packet_handler=true):PING(num_initial_members=3;timeout=2000):MERGE2(max_interval=30000;min_interval=1000 +//0):FD_SOCK:FD(max_tries=2;shun=true;timeout=1000):VERIFY_SUSPECT(timeout=250):pbcast.NAKACK(discard_delivered_msgs=t +//rue;gc_lag=0;retransmit_timeout=300,600,900,1200;use_mcast_xmit=false):UNICAST(timeout=300,600,900,1200):pbcast.STAB +//LE(desired_avg_gossip=50000;max_bytes=400000;stability_delay=1000):pbcast.GMS(join_timeout=1000;print_local_addr=fal +//se;shun=false;view_ack_collection_timeout=1000;view_bundling=true):FRAG2(frag_size=60000):pbcast.STREAMING_STATE_TRA +//NSFER:pbcast.FLUSH(timeout=0) Modified: core/trunk/src/test/resources/configs/buddy-replication-cache.xml =================================================================== --- core/trunk/src/test/resources/configs/buddy-replication-cache.xml 2008-12-18 21:56:44 UTC (rev 7336) +++ core/trunk/src/test/resources/configs/buddy-replication-cache.xml 2008-12-19 02:32:29 UTC (rev 7337) @@ -18,7 +18,7 @@ </buddy> <stateRetrieval timeout="20000"/> <jgroupsConfig> - <TCP recv_buf_size="20000000" use_send_queues="false" loopback="false" discard_incompatible_packets="true" + <TCP start_port="7800" recv_buf_size="20000000" use_send_queues="false" loopback="false" discard_incompatible_packets="true" max_bundle_size="64000" max_bundle_timeout="30" use_incoming_packet_handler="true" enable_bundling="true" enable_unicast_bundling="true" enable_diagnostics="true" use_concurrent_stack="true" thread_naming_pattern="pl" thread_pool.enabled="true" thread_pool.min_threads="1" Modified: core/trunk/src/test/resources/configs/conf2x/buddy-replication-cache.xml =================================================================== --- core/trunk/src/test/resources/configs/conf2x/buddy-replication-cache.xml 2008-12-18 21:56:44 UTC (rev 7336) +++ core/trunk/src/test/resources/configs/conf2x/buddy-replication-cache.xml 2008-12-19 02:32:29 UTC (rev 7337) @@ -65,7 +65,7 @@ --> <attribute name="ClusterConfig"> <config> - <TCP recv_buf_size="20000000" use_send_queues="false" + <TCP start_port="7800" recv_buf_size="20000000" use_send_queues="false" loopback="false" discard_incompatible_packets="true" max_bundle_size="64000"