[exo-jcr-commits] exo-jcr SVN: r1581 - in jcr/trunk/exo.jcr.component.core/src/test: resources/conf/cluster and 1 other directories.

Author: nzamosenchuk Date: 2010-01-26 10:06:28 -0500 (Tue, 26 Jan 2010) New Revision: 1581 Removed: jcr/trunk/exo.jcr.component.core/src/test/java/org/exoplatform/services/jcr/lab/cache/TestCacheReplicationDeadLock.java jcr/trunk/exo.jcr.component.core/src/test/resources/conf/cluster/test-replication-deadlock.xml jcr/trunk/exo.jcr.component.core/src/test/resources/conf/portal/cluster/test-replication-deadlock.xml Log: EXOJCR-396: remove unnecessary test and configuration for it. Deleted: jcr/trunk/exo.jcr.component.core/src/test/java/org/exoplatform/services/jcr/lab/cache/TestCacheReplicationDeadLock.java =================================================================== --- jcr/trunk/exo.jcr.component.core/src/test/java/org/exoplatform/services/jcr/lab/cache/TestCacheReplicationDeadLock.java 2010-01-26 15:01:35 UTC (rev 1580) +++ jcr/trunk/exo.jcr.component.core/src/test/java/org/exoplatform/services/jcr/lab/cache/TestCacheReplicationDeadLock.java 2010-01-26 15:06:28 UTC (rev 1581) @@ -1,142 +0,0 @@ -/* - * Copyright (C) 2010 eXo Platform SAS. - * - * This is free software; you can redistribute it and/or modify it - * under the terms of the GNU Lesser General Public License as - * published by the Free Software Foundation; either version 2.1 of - * the License, or (at your option) any later version. - * - * This software is distributed in the hope that it will be useful, - * but WITHOUT ANY WARRANTY; without even the implied warranty of - * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU - * Lesser General Public License for more details. - * - * You should have received a copy of the GNU Lesser General Public - * License along with this software; if not, write to the Free - * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA - * 02110-1301 USA, or see the FSF site: http://www.fsf.org. - */ -package org.exoplatform.services.jcr.lab.cache; - -import junit.framework.TestCase; - -import org.jboss.cache.CacheFactory; -import org.jboss.cache.CacheSPI; -import org.jboss.cache.DefaultCacheFactory; - -import java.io.Serializable; -import java.util.concurrent.CyclicBarrier; - -import javax.transaction.TransactionManager; - -/** - * This test created two caches with replication between them. Then two different thread - * are writing to the same FQN some values. Then they commit transactions (in the same - * time). - * Wait for 20s and you'll get: - * org.jboss.cache.lock.TimeoutException: Unable to acquire lock on Fqn [/fqn] after [20000] milliseconds for requestor - * [GlobalTransaction:<127.0.0.1:9601>:1]! Lock held by [GlobalTransaction:<127.0.0.1:9600>:0] - * - * org.jboss.cache.lock.TimeoutException: Unable to acquire lock on Fqn [/fqn] after [20000] milliseconds for requestor - * [GlobalTransaction:<127.0.0.1:9600>:0]! Lock held by [GlobalTransaction:<127.0.0.1:9601>:1] - * - * @author <a href="mailto:nikolazius@gmail.com">Nikolay Zamosenchuk</a> - * @version $Id: Test.java 34360 2009-07-22 23:58:59Z nzamosenchuk $ - * - */ -public class TestCacheReplicationDeadLock extends TestCase -{ - - int threadCount = 2; - - private final CyclicBarrier barrier = new CyclicBarrier(threadCount); - - private final static String LONG_TEXT = - "Compared to OHV pushrod (or I-Head) " - + "systems with the same number of valves the reciprocating components of " - + "the OHC system are fewer and have a lower total mass. Though the system" - + " that drives the cams may become more complex, most engine manufacturer" - + "s easily accept that added complexity in trade for better engine perfor" - + "mance and greater design flexibility. Another performance advantage is " - + "gained as a result of the better optimized port configurations made pos" - + "sible with overhead camshaft designs. With no intrusive pushrods the ov" - + "erhead camshaft cylinder head design can use straighter ports of more a" - + "dvantageous crossection and length."; - - public void testDeadLock() - { - // create cache - CacheFactory<Serializable, Object> factory = new DefaultCacheFactory<Serializable, Object>(); - final CacheSPI<Serializable, Object> cache1 = - (CacheSPI<Serializable, Object>)factory.createCache("conf/cluster/test-replication-deadlock.xml", false); - final CacheSPI<Serializable, Object> cache2 = - (CacheSPI<Serializable, Object>)factory.createCache("conf/cluster/test-replication-deadlock.xml", false); - - cache1.create(); - cache2.create(); - - cache1.start(); - cache2.start(); - // create threads - for (int i = 0; i < threadCount; i++) - { - new Thread(new WritingTask(barrier, i, i % 2 == 0 ? cache1 : cache2)).start(); - } - - // wait a minute and tear down - try - { - Thread.sleep(60000); - } - catch (InterruptedException e) - { - e.printStackTrace(); - } - - cache1.stop(); - cache1.destroy(); - cache2.stop(); - cache2.destroy(); - } - - class WritingTask implements Runnable - { - - private CyclicBarrier barrier; - - private int index; - - private CacheSPI<Serializable, Object> cache; - - public WritingTask(CyclicBarrier barrier, int index, CacheSPI<Serializable, Object> cache) - { - super(); - this.barrier = barrier; - this.index = index; - this.cache = cache; - } - - public void run() - { - try - { - while (true) - { - TransactionManager mgr = cache.getTransactionManager(); - mgr.begin(); - cache.put("fqn", "key", LONG_TEXT + index); - // make them save in one moment - barrier.await(); - mgr.commit(); - System.out.print(index + " "); - } - } - catch (Exception e) - { - e.printStackTrace(); - } - } - - } - -} Deleted: jcr/trunk/exo.jcr.component.core/src/test/resources/conf/cluster/test-replication-deadlock.xml =================================================================== --- jcr/trunk/exo.jcr.component.core/src/test/resources/conf/cluster/test-replication-deadlock.xml 2010-01-26 15:01:35 UTC (rev 1580) +++ jcr/trunk/exo.jcr.component.core/src/test/resources/conf/cluster/test-replication-deadlock.xml 2010-01-26 15:06:28 UTC (rev 1581) @@ -1,90 +0,0 @@ -<?xml version="1.0" encoding="UTF-8"?> -<jbosscache xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" - xmlns="urn:jboss:jbosscache-core:config:3.1"> - - <locking useLockStriping="false" concurrencyLevel="50000" lockParentForChildInsertRemove="false" lockAcquisitionTimeout="20000" /> - - <transaction transactionManagerLookupClass="org.jboss.cache.transaction.JBossStandaloneJTAManagerLookup" /> - - <clustering mode="replication" clusterName="JBoss-Cache-Cluster_db1_ws"> - <!-- - Fetch in memory state is enable, because second cluster-node - currently doesn't work properly on clear cache - --> - <stateRetrieval timeout="20000" fetchInMemoryState="false" nonBlocking="true"/> - <!-- - This JGroups configuration is taken from JBC branch, but - "enable_bundling" is set to false, because of notice, that appeared - during running - multiplexerStack="fc-fast-minimalthreads" - --> - <jgroupsConfig> - <!-- - UDP discard_incompatible_packets="true" enable_bundling="false" - enable_diagnostics="false" ip_ttl="2" loopback="false" - max_bundle_size="64000" max_bundle_timeout="30" - mcast_addr="228.10.10.10" mcast_port="45588" - mcast_recv_buf_size="25000000" mcast_send_buf_size="640000" - oob_thread_pool.enabled="true" - oob_thread_pool.keep_alive_time="10000" - oob_thread_pool.max_threads="4" oob_thread_pool.min_threads="1" - oob_thread_pool.queue_enabled="true" - 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="true" thread_pool.queue_max_size="10" - thread_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" / - --> - - <TCP bind_addr="127.0.0.1" start_port="9600" loopback="true" - recv_buf_size="20000000" send_buf_size="640000" - discard_incompatible_packets="true" max_bundle_size="64000" - max_bundle_timeout="30" use_incoming_packet_handler="true" - enable_bundling="false" use_send_queues="false" sock_conn_timeout="300" - skip_suspected_members="true" use_concurrent_stack="true" - thread_pool.enabled="true" thread_pool.min_threads="1" - thread_pool.max_threads="25" thread_pool.keep_alive_time="5000" - thread_pool.queue_enabled="false" thread_pool.queue_max_size="100" - thread_pool.rejection_policy="run" oob_thread_pool.enabled="true" - oob_thread_pool.min_threads="1" oob_thread_pool.max_threads="8" - oob_thread_pool.keep_alive_time="5000" - oob_thread_pool.queue_enabled="false" - oob_thread_pool.queue_max_size="100" - oob_thread_pool.rejection_policy="run" /> - <MPING timeout="2000" num_initial_members="2" mcast_port="34521" - bind_addr="127.0.0.1" mcast_addr="224.0.0.1" /> - - - <MERGE2 max_interval="30000" min_interval="10000" /> - <FD_SOCK /> - <FD max_tries="5" shun="true" timeout="10000" /> - <VERIFY_SUSPECT timeout="1500" /> - <pbcast.NAKACK discard_delivered_msgs="true" gc_lag="0" - retransmit_timeout="300,600,1200,2400,4800" use_mcast_xmit="false" /> - <UNICAST timeout="300,600,1200,2400,3600" /> - <pbcast.STABLE desired_avg_gossip="50000" max_bytes="400000" - stability_delay="1000" /> - <pbcast.GMS join_timeout="5000" print_local_addr="true" - shun="false" view_ack_collection_timeout="5000" view_bundling="true" /> - <FRAG2 frag_size="60000" /> - <pbcast.STREAMING_STATE_TRANSFER /> - <pbcast.FLUSH timeout="0" /> - - </jgroupsConfig> - - <sync /> - - </clustering> - - <!-- Eviction configuration --> - <eviction wakeUpInterval="5000"> - <default algorithmClass="org.jboss.cache.eviction.LRUAlgorithm" eventQueueSize="1000000"> - <property name="maxNodes" value="10000" /> - <property name="timeToLive" value="120000" /> - </default> - </eviction> -</jbosscache> Deleted: jcr/trunk/exo.jcr.component.core/src/test/resources/conf/portal/cluster/test-replication-deadlock.xml =================================================================== --- jcr/trunk/exo.jcr.component.core/src/test/resources/conf/portal/cluster/test-replication-deadlock.xml 2010-01-26 15:01:35 UTC (rev 1580) +++ jcr/trunk/exo.jcr.component.core/src/test/resources/conf/portal/cluster/test-replication-deadlock.xml 2010-01-26 15:06:28 UTC (rev 1581) @@ -1,90 +0,0 @@ -<?xml version="1.0" encoding="UTF-8"?> -<jbosscache xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" - xmlns="urn:jboss:jbosscache-core:config:3.1"> - - <locking useLockStriping="false" concurrencyLevel="50000" lockParentForChildInsertRemove="false" lockAcquisitionTimeout="20000" /> - - <transaction transactionManagerLookupClass="org.jboss.cache.transaction.JBossStandaloneJTAManagerLookup" /> - - <clustering mode="replication" clusterName="JBoss-Cache-Cluster_db1_ws"> - <!-- - Fetch in memory state is enable, because second cluster-node - currently doesn't work properly on clear cache - --> - <stateRetrieval timeout="20000" fetchInMemoryState="false" nonBlocking="true"/> - <!-- - This JGroups configuration is taken from JBC branch, but - "enable_bundling" is set to false, because of notice, that appeared - during running - multiplexerStack="fc-fast-minimalthreads" - --> - <jgroupsConfig> - <!-- - UDP discard_incompatible_packets="true" enable_bundling="false" - enable_diagnostics="false" ip_ttl="2" loopback="false" - max_bundle_size="64000" max_bundle_timeout="30" - mcast_addr="228.10.10.10" mcast_port="45588" - mcast_recv_buf_size="25000000" mcast_send_buf_size="640000" - oob_thread_pool.enabled="true" - oob_thread_pool.keep_alive_time="10000" - oob_thread_pool.max_threads="4" oob_thread_pool.min_threads="1" - oob_thread_pool.queue_enabled="true" - 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="true" thread_pool.queue_max_size="10" - thread_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" / - --> - - <TCP bind_addr="127.0.0.1" start_port="9600" loopback="true" - recv_buf_size="20000000" send_buf_size="640000" - discard_incompatible_packets="true" max_bundle_size="64000" - max_bundle_timeout="30" use_incoming_packet_handler="true" - enable_bundling="false" use_send_queues="false" sock_conn_timeout="300" - skip_suspected_members="true" use_concurrent_stack="true" - thread_pool.enabled="true" thread_pool.min_threads="1" - thread_pool.max_threads="25" thread_pool.keep_alive_time="5000" - thread_pool.queue_enabled="false" thread_pool.queue_max_size="100" - thread_pool.rejection_policy="run" oob_thread_pool.enabled="true" - oob_thread_pool.min_threads="1" oob_thread_pool.max_threads="8" - oob_thread_pool.keep_alive_time="5000" - oob_thread_pool.queue_enabled="false" - oob_thread_pool.queue_max_size="100" - oob_thread_pool.rejection_policy="run" /> - <MPING timeout="2000" num_initial_members="2" mcast_port="34521" - bind_addr="127.0.0.1" mcast_addr="224.0.0.1" /> - - - <MERGE2 max_interval="30000" min_interval="10000" /> - <FD_SOCK /> - <FD max_tries="5" shun="true" timeout="10000" /> - <VERIFY_SUSPECT timeout="1500" /> - <pbcast.NAKACK discard_delivered_msgs="true" gc_lag="0" - retransmit_timeout="300,600,1200,2400,4800" use_mcast_xmit="false" /> - <UNICAST timeout="300,600,1200,2400,3600" /> - <pbcast.STABLE desired_avg_gossip="50000" max_bytes="400000" - stability_delay="1000" /> - <pbcast.GMS join_timeout="5000" print_local_addr="true" - shun="false" view_ack_collection_timeout="5000" view_bundling="true" /> - <FRAG2 frag_size="60000" /> - <pbcast.STREAMING_STATE_TRANSFER /> - <pbcast.FLUSH timeout="0" /> - - </jgroupsConfig> - - <sync /> - - </clustering> - - <!-- Eviction configuration --> - <eviction wakeUpInterval="5000"> - <default algorithmClass="org.jboss.cache.eviction.LRUAlgorithm" eventQueueSize="1000000"> - <property name="maxNodes" value="10000" /> - <property name="timeToLive" value="120000" /> - </default> - </eviction> -</jbosscache>