September 2009 - jbosscache-commits

by jbosscache-commits＠lists.jboss.org

Author: mircea.markus Date: 2009-09-17 11:14:44 -0400 (Thu, 17 Sep 2009) New Revision: 8234 Added: core/tags/3.2.1.BETA3/ Log: JBoss Cache Release Script: Tagging 3.2.1.BETA3 Copied: core/tags/3.2.1.BETA3 (from rev 8233, core/trunk)

14 years, 7 months

1
0
0 / 0

JBoss Cache SVN: r8233 - in core/trunk/src: test/java/org/jboss/cache/statetransfer and 1 other directory.

by jbosscache-commits＠lists.jboss.org

Author: mircea.markus Date: 2009-09-17 10:55:54 -0400 (Thu, 17 Sep 2009) New Revision: 8233 Modified: core/trunk/src/main/java/org/jboss/cache/RPCManagerImpl.java core/trunk/src/test/java/org/jboss/cache/statetransfer/NBSTCacheLoaderTest.java core/trunk/src/test/java/org/jboss/cache/statetransfer/NonBlockingStateTransferTest.java core/trunk/src/test/java/org/jboss/cache/statetransfer/StateTransfer200Test.java Log: [JBCACHE-1538] - removed endless loop and re-enabled tests Modified: core/trunk/src/main/java/org/jboss/cache/RPCManagerImpl.java =================================================================== --- core/trunk/src/main/java/org/jboss/cache/RPCManagerImpl.java 2009-09-17 13:50:31 UTC (rev 8232) +++ core/trunk/src/main/java/org/jboss/cache/RPCManagerImpl.java 2009-09-17 14:55:54 UTC (rev 8233) @@ -231,20 +231,9 @@ public void lockProcessingLock() throws InterruptedException { - while (true) - { - try - { - if (!coordinationLock.readLock().tryLock(configuration.getStateRetrievalTimeout(), TimeUnit.MILLISECONDS)) - throw new TimeoutException("Could not obtain processing lock"); + if (!coordinationLock.readLock().tryLock(configuration.getStateRetrievalTimeout(), TimeUnit.MILLISECONDS)) + throw new TimeoutException("Could not obtain processing lock"); - return; - } - catch (InterruptedException ie) - { - Thread.currentThread().interrupt(); - } - } } public void unlockProcessingLock() Modified: core/trunk/src/test/java/org/jboss/cache/statetransfer/NBSTCacheLoaderTest.java =================================================================== --- core/trunk/src/test/java/org/jboss/cache/statetransfer/NBSTCacheLoaderTest.java 2009-09-17 13:50:31 UTC (rev 8232) +++ core/trunk/src/test/java/org/jboss/cache/statetransfer/NBSTCacheLoaderTest.java 2009-09-17 14:55:54 UTC (rev 8233) @@ -12,7 +12,7 @@ import java.io.IOException; -@Test(groups = "functional", testName = "statetransfer.NBSTCacheLoaderTest", enabled = false) +@Test(groups = "functional", testName = "statetransfer.NBSTCacheLoaderTest", enabled = true) public class NBSTCacheLoaderTest extends NonBlockingStateTransferTest { int id; Modified: core/trunk/src/test/java/org/jboss/cache/statetransfer/NonBlockingStateTransferTest.java =================================================================== --- core/trunk/src/test/java/org/jboss/cache/statetransfer/NonBlockingStateTransferTest.java 2009-09-17 13:50:31 UTC (rev 8232) +++ core/trunk/src/test/java/org/jboss/cache/statetransfer/NonBlockingStateTransferTest.java 2009-09-17 14:55:54 UTC (rev 8233) @@ -26,7 +26,7 @@ import java.io.ObjectOutputStream; import java.io.Serializable; -@Test(groups="functional", testName = "statetransfer.NonBlockingStateTransferTest", enabled = false) +@Test(groups="functional", testName = "statetransfer.NonBlockingStateTransferTest", enabled = true) public class NonBlockingStateTransferTest { public static final Fqn A = Fqn.fromString("/a"); Modified: core/trunk/src/test/java/org/jboss/cache/statetransfer/StateTransfer200Test.java =================================================================== --- core/trunk/src/test/java/org/jboss/cache/statetransfer/StateTransfer200Test.java 2009-09-17 13:50:31 UTC (rev 8232) +++ core/trunk/src/test/java/org/jboss/cache/statetransfer/StateTransfer200Test.java 2009-09-17 14:55:54 UTC (rev 8233) @@ -29,7 +29,7 @@ * @author <a href="mailto://brian.stansberry@jboss.com">Brian Stansberry</a> * @version $Revision$ */ -@Test(groups = {"functional"}, testName = "statetransfer.StateTransfer200Test", enabled = false) +@Test(groups = {"functional"}, testName = "statetransfer.StateTransfer200Test", enabled = true) public class StateTransfer200Test extends StateTransferTestBase { protected String getReplicationVersion()

14 years, 7 months

1
0
0 / 0

JBoss Cache SVN: r8232 - in core/trunk/src/main/java/org/jboss/cache: remoting/jgroups and 1 other directories.

by jbosscache-commits＠lists.jboss.org

Author: mircea.markus Date: 2009-09-17 09:50:31 -0400 (Thu, 17 Sep 2009) New Revision: 8232 Modified: core/trunk/src/main/java/org/jboss/cache/RPCManagerImpl.java core/trunk/src/main/java/org/jboss/cache/remoting/jgroups/ChannelMessageListener.java core/trunk/src/main/java/org/jboss/cache/statetransfer/LegacyStateTransferGenerator.java core/trunk/src/main/java/org/jboss/cache/statetransfer/LegacyStateTransferManager.java Log: [JBCACHE-1538] - fixed concurrent startup failure. Issue was caused by state transfer request might happen before the component registry is fully started. Modified: core/trunk/src/main/java/org/jboss/cache/RPCManagerImpl.java =================================================================== --- core/trunk/src/main/java/org/jboss/cache/RPCManagerImpl.java 2009-09-16 07:27:47 UTC (rev 8231) +++ core/trunk/src/main/java/org/jboss/cache/RPCManagerImpl.java 2009-09-17 13:50:31 UTC (rev 8232) @@ -382,7 +382,7 @@ channel.connect(configuration.getClusterName(), null, null, configuration.getStateRetrievalTimeout()); if (log.isInfoEnabled()) log.info("Cache local address is " + getLocalAddress()); - if (getMembers().size() > 1) messageListener.waitForState(); + if (getMembers().size() > 1 && !isCoordinator()) messageListener.waitForState(); } catch (ChannelException e) { @@ -637,6 +637,13 @@ throw new CacheException("Failed to create multiplexed channel using stack " + stackName, e); } } + if (trace) { + if (muxchannel == null) { + log.trace("Null mux channel!"); + } else { + log.trace("Using multiplex channel: " + muxchannel.printProtocolSpec(true)); + } + } return muxchannel; } Modified: core/trunk/src/main/java/org/jboss/cache/remoting/jgroups/ChannelMessageListener.java =================================================================== --- core/trunk/src/main/java/org/jboss/cache/remoting/jgroups/ChannelMessageListener.java 2009-09-16 07:27:47 UTC (rev 8231) +++ core/trunk/src/main/java/org/jboss/cache/remoting/jgroups/ChannelMessageListener.java 2009-09-17 13:50:31 UTC (rev 8232) @@ -153,6 +153,7 @@ public byte[] getState() { + if (log.isTraceEnabled()) log.trace("State retrieval request received"); MarshalledValueOutputStream out = null; byte[] result; ExposedByteArrayOutputStream baos = new ExposedByteArrayOutputStream(16 * 1024); Modified: core/trunk/src/main/java/org/jboss/cache/statetransfer/LegacyStateTransferGenerator.java =================================================================== --- core/trunk/src/main/java/org/jboss/cache/statetransfer/LegacyStateTransferGenerator.java 2009-09-16 07:27:47 UTC (rev 8231) +++ core/trunk/src/main/java/org/jboss/cache/statetransfer/LegacyStateTransferGenerator.java 2009-09-17 13:50:31 UTC (rev 8232) @@ -59,10 +59,11 @@ this.cache = cache; } - @Start(priority = 18) + @Start(priority = 14) void start() { this.internalFqns = cache.getInternalFqns(); + log.trace("LegacyStateTransferGenerator.start: internalFqn is " + internalFqns); } public void generateState(ObjectOutputStream out, Object rootNode, boolean generateTransient, @@ -172,6 +173,10 @@ protected void generateNodeDataList(NodeSPI<?, ?> node, List<NodeData> list) throws Exception { + if (log.isTraceEnabled()) { + log.trace("generateNodeDataList: internalFqns are:" + internalFqns + ", node is: " + node); + } + if (internalFqns.contains(node.getFqn())) { return; Modified: core/trunk/src/main/java/org/jboss/cache/statetransfer/LegacyStateTransferManager.java =================================================================== --- core/trunk/src/main/java/org/jboss/cache/statetransfer/LegacyStateTransferManager.java 2009-09-16 07:27:47 UTC (rev 8231) +++ core/trunk/src/main/java/org/jboss/cache/statetransfer/LegacyStateTransferManager.java 2009-09-17 13:50:31 UTC (rev 8232) @@ -21,17 +21,19 @@ */ package org.jboss.cache.statetransfer; +import org.apache.commons.logging.Log; +import org.apache.commons.logging.LogFactory; import org.jboss.cache.CacheException; import org.jboss.cache.Fqn; import org.jboss.cache.NodeSPI; import org.jboss.cache.RegionEmptyException; -import org.jboss.cache.util.CachePrinter; import org.jboss.cache.factories.annotations.Inject; import org.jboss.cache.factories.annotations.Start; import org.jboss.cache.lock.LockManager; import static org.jboss.cache.lock.LockType.READ; import org.jboss.cache.lock.TimeoutException; import org.jboss.cache.marshall.InactiveRegionException; +import org.jboss.cache.util.CachePrinter; import java.io.ObjectInputStream; import java.io.ObjectOutputStream; @@ -45,6 +47,8 @@ @Deprecated public class LegacyStateTransferManager extends DefaultStateTransferManager { + private static Log log = LogFactory.getLog(LegacyStateTransferManager.class); + protected LockManager lockManager; private boolean usePut; // for JBCACHE-131

14 years, 7 months

1
0
0 / 0

Barrymore's dirty panties

by Rosetta Qxyd

14 years, 7 months

1
0
0 / 0

Hudson build became unstable: jboss-cache-core-trunk-jdk1.5 » JBoss Cache - Core Edition #870

by jboss-qa-internal＠redhat.com

See http://hudson.qa.jboss.com/hudson/job/jboss-cache-core-trunk-jdk1.5/org.j...

14 years, 7 months

1
1
0 / 0

Hudson build became unstable: jboss-cache-core-trunk-jdk1.6 » JBoss Cache - Core Edition #773

by jboss-qa-internal＠redhat.com

See http://hudson.qa.jboss.com/hudson/job/jboss-cache-core-trunk-jdk1.6/org.j...

14 years, 7 months

1
1
0 / 0

Marketing bulletin

by Virgil Fovywucq

14 years, 7 months

1
0
0 / 0

JBoss Cache SVN: r8231 - in core/trunk: src/main/java/org/jboss/cache and 1 other directory.

by jbosscache-commits＠lists.jboss.org

Author: mircea.markus Date: 2009-09-16 03:27:47 -0400 (Wed, 16 Sep 2009) New Revision: 8231 Modified: core/trunk/pom.xml core/trunk/src/main/java/org/jboss/cache/Version.java Log: reverted to SPNAPSHOT version Modified: core/trunk/pom.xml =================================================================== --- core/trunk/pom.xml 2009-09-16 07:19:21 UTC (rev 8230) +++ core/trunk/pom.xml 2009-09-16 07:27:47 UTC (rev 8231) @@ -4,7 +4,7 @@ xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> <modelVersion>4.0.0</modelVersion> <properties> - <jbosscache-core-version>3.2.1.BETA2</jbosscache-core-version> + <jbosscache-core-version>3.2.1-SNAPSHOT</jbosscache-core-version>  <defaultTestGroup>unit</defaultTestGroup>  @@ -485,7 +485,7 @@ <activeByDefault>false</activeByDefault> </activation> <properties> - <jbosscache-core-version>3.2.1.BETA2-JBossAS</jbosscache-core-version> + <jbosscache-core-version>3.2.1-SNAPSHOT-JBossAS</jbosscache-core-version> <defaultTestGroup>functional,unit</defaultTestGroup> <protocol.stack>tcp</protocol.stack> </properties> Modified: core/trunk/src/main/java/org/jboss/cache/Version.java =================================================================== --- core/trunk/src/main/java/org/jboss/cache/Version.java 2009-09-16 07:19:21 UTC (rev 8230) +++ core/trunk/src/main/java/org/jboss/cache/Version.java 2009-09-16 07:27:47 UTC (rev 8231) @@ -32,10 +32,10 @@ @Immutable public class Version { - public static final String version = "3.2.1.BETA2"; + public static final String version = "3.2.1-SNAPSHOT"; public static final String codename = "Malagueta"; //public static final String cvs = "$Id$"; - static final byte[] version_id = {'0','3','2','1','B','E','T','A','2'}; + static final byte[] version_id = {'0', '3', '2', '1', 'S'}; private static final int MAJOR_SHIFT = 11; private static final int MINOR_SHIFT = 6;

14 years, 7 months

1
0
0 / 0

JBoss Cache SVN: r8230 - in core/trunk: src/main/java/org/jboss/cache and 1 other directory.

by jbosscache-commits＠lists.jboss.org

Author: mircea.markus Date: 2009-09-16 03:19:21 -0400 (Wed, 16 Sep 2009) New Revision: 8230 Modified: core/trunk/pom.xml core/trunk/src/main/java/org/jboss/cache/Version.java Log: JBoss Cache Release Script: Updating 3.2.1.BETA2 Modified: core/trunk/pom.xml =================================================================== --- core/trunk/pom.xml 2009-09-15 14:18:25 UTC (rev 8229) +++ core/trunk/pom.xml 2009-09-16 07:19:21 UTC (rev 8230) @@ -4,7 +4,7 @@ xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> <modelVersion>4.0.0</modelVersion> <properties> - <jbosscache-core-version>3.2.1-SNAPSHOT</jbosscache-core-version> + <jbosscache-core-version>3.2.1.BETA2</jbosscache-core-version>  <defaultTestGroup>unit</defaultTestGroup>  @@ -485,7 +485,7 @@ <activeByDefault>false</activeByDefault> </activation> <properties> - <jbosscache-core-version>3.2.1-SNAPSHOT-JBossAS</jbosscache-core-version> + <jbosscache-core-version>3.2.1.BETA2-JBossAS</jbosscache-core-version> <defaultTestGroup>functional,unit</defaultTestGroup> <protocol.stack>tcp</protocol.stack> </properties> Modified: core/trunk/src/main/java/org/jboss/cache/Version.java =================================================================== --- core/trunk/src/main/java/org/jboss/cache/Version.java 2009-09-15 14:18:25 UTC (rev 8229) +++ core/trunk/src/main/java/org/jboss/cache/Version.java 2009-09-16 07:19:21 UTC (rev 8230) @@ -32,10 +32,10 @@ @Immutable public class Version { - public static final String version = "3.2.1-SNAPSHOT"; + public static final String version = "3.2.1.BETA2"; public static final String codename = "Malagueta"; //public static final String cvs = "$Id$"; - static final byte[] version_id = {'0', '3', '2', '1', 'S'}; + static final byte[] version_id = {'0','3','2','1','B','E','T','A','2'}; private static final int MAJOR_SHIFT = 11; private static final int MINOR_SHIFT = 6;

14 years, 7 months

1
0
0 / 0

JBoss Cache SVN: r8229 - in core/tags/3.2.1.BETA2: src/main/java/org/jboss/cache and 1 other directory.

by jbosscache-commits＠lists.jboss.org

Author: mircea.markus Date: 2009-09-15 10:18:25 -0400 (Tue, 15 Sep 2009) New Revision: 8229 Modified: core/tags/3.2.1.BETA2/pom.xml core/tags/3.2.1.BETA2/src/main/java/org/jboss/cache/Version.java Log: JBoss Cache Release Script: Updating 3.2.1.BETA2 Modified: core/tags/3.2.1.BETA2/pom.xml =================================================================== --- core/tags/3.2.1.BETA2/pom.xml 2009-09-15 14:16:48 UTC (rev 8228) +++ core/tags/3.2.1.BETA2/pom.xml 2009-09-15 14:18:25 UTC (rev 8229) @@ -4,7 +4,7 @@ xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> <modelVersion>4.0.0</modelVersion> <properties> - <jbosscache-core-version>3.2.1-SNAPSHOT</jbosscache-core-version> + <jbosscache-core-version>3.2.1.BETA2</jbosscache-core-version>  <defaultTestGroup>unit</defaultTestGroup>  @@ -485,7 +485,7 @@ <activeByDefault>false</activeByDefault> </activation> <properties> - <jbosscache-core-version>3.2.1-SNAPSHOT-JBossAS</jbosscache-core-version> + <jbosscache-core-version>3.2.1.BETA2-JBossAS</jbosscache-core-version> <defaultTestGroup>functional,unit</defaultTestGroup> <protocol.stack>tcp</protocol.stack> </properties> Modified: core/tags/3.2.1.BETA2/src/main/java/org/jboss/cache/Version.java =================================================================== --- core/tags/3.2.1.BETA2/src/main/java/org/jboss/cache/Version.java 2009-09-15 14:16:48 UTC (rev 8228) +++ core/tags/3.2.1.BETA2/src/main/java/org/jboss/cache/Version.java 2009-09-15 14:18:25 UTC (rev 8229) @@ -32,10 +32,10 @@ @Immutable public class Version { - public static final String version = "3.2.1-SNAPSHOT"; + public static final String version = "3.2.1.BETA2"; public static final String codename = "Malagueta"; //public static final String cvs = "$Id$"; - static final byte[] version_id = {'0', '3', '2', '1', 'S'}; + static final byte[] version_id = {'0','3','2','1','B','E','T','A','2'}; private static final int MAJOR_SHIFT = 11; private static final int MINOR_SHIFT = 6;

14 years, 7 months

1
0
0 / 0

2024

2023

2022

2021

2020

2019

2018

2017

2016

2015

2014

2013

2012

2011

2010

2009

2008

2007

2006

jbosscache-commits September 2009