Author: jmesnil Date: 2010-09-03 05:46:44 -0400 (Fri, 03 Sep 2010) New Revision: 9640 Added: branches/2_2_0_HA_Improvements/tests/src/org/hornetq/tests/integration/cluster/LockFileImplTest.java Log: test for LockFileImpl Added: branches/2_2_0_HA_Improvements/tests/src/org/hornetq/tests/integration/cluster/LockFileImplTest.java =================================================================== --- branches/2_2_0_HA_Improvements/tests/src/org/hornetq/tests/integration/cluster/LockFileImplTest.java (rev 0) +++ branches/2_2_0_HA_Improvements/tests/src/org/hornetq/tests/integration/cluster/LockFileImplTest.java 2010-09-03 09:46:44 UTC (rev 9640) @@ -0,0 +1,140 @@ +/* + * Copyright 2010 Red Hat, Inc. + * Red Hat 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.hornetq.tests.integration.cluster; + +import java.io.IOException; + +import org.hornetq.core.server.cluster.impl.LockFileImpl; +import org.hornetq.tests.util.RandomUtil; +import org.hornetq.tests.util.UnitTestCase; + +/** + * A LockFileImplTest + * + * @author jmesnil + * + * + */ +public class LockFileImplTest extends UnitTestCase +{ + + // Constants ----------------------------------------------------- + + /** + * A ThreadExtension + * + * @author jmesnil + * + * + */ + private final class Activation extends Thread + { + private LockFileImpl backupLock; + private LockFileImpl liveLock; + + public void run() { + backupLock = new LockFileImpl(RandomUtil.randomString(), System.getProperty("java.io.tmpdir")); + try + { + backupLock.lock(); + } + catch (IOException e) + { + e.printStackTrace(); + } + + liveLock = new LockFileImpl(liveLockFileName, System.getProperty("java.io.tmpdir")); + try + { + liveLock.lock(); + } + catch (IOException e) + { + e.printStackTrace(); + } + } + + public void close() throws IOException + { + if (liveLock != null) + { + liveLock.unlock(); + } + if (backupLock != null) + { + backupLock.unlock(); + } + } + } + + public static final String liveLockFileName = "liveLock"; + // Attributes ---------------------------------------------------- + + // Static -------------------------------------------------------- + + // Constructors -------------------------------------------------- + + // Public -------------------------------------------------------- + + public static void main(String[] args) + { + try + { + final LockFileImpl liveLock = new LockFileImpl(liveLockFileName, System.getProperty("java.io.tmpdir")); + liveLock.lock(); + Thread.sleep(1000000); + } + catch (Exception e) + { + e.printStackTrace(); + } + } + + // 1. Run the class as a Java application to execute the main() in a separate VM + // 2. Run this test + public void _testInterrupt() throws Exception + { + Activation t = new Activation(); + t.start(); + + System.out.println("sleep"); + Thread.sleep(5000); + + t.close(); + + long timeout = 10000; + long start = System.currentTimeMillis(); + while (t.isAlive() && System.currentTimeMillis() - start < timeout) + { + System.out.println("before interrupt"); + t.interrupt(); + System.out.println("after interrupt"); + + Thread.sleep(1000); + } + + assertFalse(t.isAlive()); + + t.join(); + + } + // Package protected --------------------------------------------- + + // Protected ----------------------------------------------------- + + // Private ------------------------------------------------------- + + // Inner classes ------------------------------------------------- + +}