ARTEMIS-1489 Add test for TimedBuffer Critical Analyser
Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/5a476a18 Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/5a476a18 Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/5a476a18 Branch: refs/heads/master Commit: 5a476a189defcce97987a5a5a30459646419c4cf Parents: 3bdeed8 Author: Martyn Taylor <mtay...@redhat.com> Authored: Tue Oct 31 10:10:30 2017 +0000 Committer: Justin Bertram <jbert...@apache.org> Committed: Tue Oct 31 08:33:44 2017 -0500 ---------------------------------------------------------------------- .../CriticalAnalyzerFaultInjectionTest.java | 108 +++++++++++++++++++ 1 file changed, 108 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/5a476a18/tests/extra-tests/src/test/java/org/apache/activemq/artemis/tests/extras/byteman/CriticalAnalyzerFaultInjectionTest.java ---------------------------------------------------------------------- diff --git a/tests/extra-tests/src/test/java/org/apache/activemq/artemis/tests/extras/byteman/CriticalAnalyzerFaultInjectionTest.java b/tests/extra-tests/src/test/java/org/apache/activemq/artemis/tests/extras/byteman/CriticalAnalyzerFaultInjectionTest.java new file mode 100644 index 0000000..a22702b --- /dev/null +++ b/tests/extra-tests/src/test/java/org/apache/activemq/artemis/tests/extras/byteman/CriticalAnalyzerFaultInjectionTest.java @@ -0,0 +1,108 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ +package org.apache.activemq.artemis.tests.extras.byteman; + +import javax.jms.DeliveryMode; +import javax.jms.MessageProducer; +import javax.jms.Queue; +import javax.jms.Session; + +import org.apache.activemq.artemis.api.core.RoutingType; +import org.apache.activemq.artemis.api.core.SimpleString; +import org.apache.activemq.artemis.core.config.Configuration; +import org.apache.activemq.artemis.core.server.JournalType; +import org.apache.activemq.artemis.core.server.impl.AddressInfo; +import org.apache.activemq.artemis.tests.util.JMSTestBase; +import org.apache.activemq.artemis.tests.util.Wait; +import org.apache.activemq.artemis.utils.critical.CriticalAnalyzerPolicy; +import org.jboss.byteman.contrib.bmunit.BMRule; +import org.jboss.byteman.contrib.bmunit.BMRules; +import org.jboss.byteman.contrib.bmunit.BMUnitRunner; +import org.junit.Before; +import org.junit.Test; +import org.junit.runner.RunWith; + +@RunWith(BMUnitRunner.class) +public class CriticalAnalyzerFaultInjectionTest extends JMSTestBase { + + // Critical Analyzer Settings + private static long CHECK_PERIOD = 100; + private static long TIMEOUT = 3000; + public static long TEST_TIMEOUT = 60000; + + private SimpleString address = SimpleString.toSimpleString("faultInjectionTestAddress"); + + @Override + @Before + public void setUp() throws Exception { + super.setUp(); + server.addAddressInfo(new AddressInfo(address, RoutingType.ANYCAST)); + server.createQueue(address, RoutingType.ANYCAST, address, null, true, false); + conn = nettyCf.createConnection(); + } + + /* + Checks every 100ms timesout after 3000ms. Test should wait no longer than 3100s + Shutdown time. + */ + @Override + protected Configuration createDefaultConfig(boolean netty) throws Exception { + return super.createDefaultConfig(netty) + .setCriticalAnalyzerPolicy(CriticalAnalyzerPolicy.SHUTDOWN) + .setCriticalAnalyzer(true) + .setCriticalAnalyzerCheckPeriod(CHECK_PERIOD) + .setCriticalAnalyzerTimeout(TIMEOUT) + .setJournalType(JournalType.NIO); + } + + @Override + public boolean usePersistence() { + return true; + } + + @BMRules( + rules = {@BMRule( + name = "Sync file data hangs", + targetClass = "org.apache.activemq.artemis.core.io.nio.NIOSequentialFile", + targetMethod = "sync", + targetLocation = "ENTRY", + action = "org.apache.activemq.artemis.tests.extras.byteman.CriticalAnalyzerFaultInjectionTest.methodHang();")}) + @Test(timeout = 60000) + public void testSlowDiskSync() throws Exception { + sendConsumeDurableMessage(); + Wait.waitFor(() -> !server.isStarted(), WAIT_TIMEOUT * 5); + assertFalse(server.isStarted()); + } + + private void sendConsumeDurableMessage() throws Exception { + try { + Session s = conn.createSession(false, Session.AUTO_ACKNOWLEDGE); + Queue jmsQueue = s.createQueue(address.toString()); + MessageProducer p = s.createProducer(jmsQueue); + p.setDeliveryMode(DeliveryMode.PERSISTENT); + conn.start(); + p.send(s.createTextMessage("payload")); + } finally { + if (conn != null) { + conn.close(); + } + } + } + + public static void methodHang() throws InterruptedException { + Thread.sleep(TEST_TIMEOUT); + } +}
