Repository: activemq Updated Branches: refs/heads/master cfb4ca9f5 -> 144b711a9
add some additional trace debug to investigate linear store usage, this test has been failing in ci for the past 7 builds but work ok locally. This additional trace will help diagnose Project: http://git-wip-us.apache.org/repos/asf/activemq/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq/commit/144b711a Tree: http://git-wip-us.apache.org/repos/asf/activemq/tree/144b711a Diff: http://git-wip-us.apache.org/repos/asf/activemq/diff/144b711a Branch: refs/heads/master Commit: 144b711a9afa412b481ef359f03fc44013e4b0be Parents: cfb4ca9 Author: gtully <gary.tu...@gmail.com> Authored: Mon Nov 30 14:03:48 2015 +0000 Committer: gtully <gary.tu...@gmail.com> Committed: Mon Nov 30 14:04:27 2015 +0000 ---------------------------------------------------------------------- .../bugs/TransactedStoreUsageSuspendResumeTest.java | 12 +++++++++++- 1 file changed, 11 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/activemq/blob/144b711a/activemq-unit-tests/src/test/java/org/apache/activemq/bugs/TransactedStoreUsageSuspendResumeTest.java ---------------------------------------------------------------------- diff --git a/activemq-unit-tests/src/test/java/org/apache/activemq/bugs/TransactedStoreUsageSuspendResumeTest.java b/activemq-unit-tests/src/test/java/org/apache/activemq/bugs/TransactedStoreUsageSuspendResumeTest.java index 6b11f71..ebc3e37 100644 --- a/activemq-unit-tests/src/test/java/org/apache/activemq/bugs/TransactedStoreUsageSuspendResumeTest.java +++ b/activemq-unit-tests/src/test/java/org/apache/activemq/bugs/TransactedStoreUsageSuspendResumeTest.java @@ -33,6 +33,8 @@ import org.apache.activemq.ActiveMQConnectionFactory; import org.apache.activemq.TestSupport; import org.apache.activemq.broker.BrokerService; import org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter; +import org.apache.activemq.store.kahadb.MessageDatabase; +import org.apache.log4j.Level; import org.junit.After; import org.junit.Assert; import org.junit.Before; @@ -103,6 +105,9 @@ public class TransactedStoreUsageSuspendResumeTest { @Before public void setup() throws Exception { + // investigate liner gc issue - store usage not getting released + org.apache.log4j.Logger.getLogger(MessageDatabase.class).setLevel(Level.TRACE); + broker = new BrokerService(); broker.setDeleteAllMessagesOnStartup(true); broker.setPersistent(true); @@ -141,8 +146,13 @@ public class TransactedStoreUsageSuspendResumeTest { sendExecutor.shutdown(); sendExecutor.awaitTermination(5, TimeUnit.MINUTES); - boolean allMessagesReceived = messagesReceivedCountDown.await(10, TimeUnit.MINUTES); + boolean allMessagesReceived = messagesReceivedCountDown.await(5, TimeUnit.MINUTES); if (!allMessagesReceived) { + LOG.info("Giving up - not all received on time..."); + LOG.info("System Mem Usage: " + broker.getSystemUsage().getMemoryUsage()); + LOG.info("System Store Usage: " +broker.getSystemUsage().getStoreUsage()); + LOG.info("Producer sent: " + messagesSentCountDown.getCount()); + LOG.info("Consumer remaining to receive: " + messagesReceivedCountDown.getCount()); TestSupport.dumpAllThreads("StuckConsumer!"); } assertTrue("Got all messages: " + messagesReceivedCountDown, allMessagesReceived);
