From: Erik Brakkee Date: Sun, 26 Mar 2006 21:31:53 +0000 (+0000) Subject: (no commit message) X-Git-Tag: wamblee-utils-0.7~1065 X-Git-Url: http://wamblee.org/gitweb/?a=commitdiff_plain;h=4e8048733c71f1c9674ac942a4e436f396adb0d5;p=utils --- diff --git a/support/src/org/wamblee/xml/ClasspathUriResolver.java b/support/src/org/wamblee/xml/ClasspathUriResolver.java new file mode 100644 index 00000000..ba2d875c --- /dev/null +++ b/support/src/org/wamblee/xml/ClasspathUriResolver.java @@ -0,0 +1,60 @@ +/* + * Copyright 2005 the original author or authors. + * + * Licensed 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.wamblee.xml; + +import java.io.IOException; + +import javax.xml.transform.Source; +import javax.xml.transform.TransformerException; +import javax.xml.transform.URIResolver; +import javax.xml.transform.stream.StreamSource; + +import org.wamblee.io.ClassPathResource; +import org.wamblee.io.InputResource; + +/** + * URI resolver that resolves stylesheets through the classpath. + */ +public class ClasspathUriResolver implements URIResolver { + + /** + * Constructs the resolver. + * + */ + public ClasspathUriResolver() { + // Empty. + } + + /* + * (non-Javadoc) + * + * @see javax.xml.transform.URIResolver#resolve(java.lang.String, + * java.lang.String) + */ + public Source resolve(String aHref, String aBase) + throws TransformerException { + InputResource xslt = new ClassPathResource(aHref); + try { + return new StreamSource(xslt.getInputStream()); + } catch (IOException e) { + throw new TransformerException( + "Could not get XSLT style sheet in classpath '" + aHref + + "'", e); + } + } + +} diff --git a/support/test/org/wamblee/concurrency/JvmLockTest.java b/support/test/org/wamblee/concurrency/JvmLockTest.java new file mode 100644 index 00000000..7d12b381 --- /dev/null +++ b/support/test/org/wamblee/concurrency/JvmLockTest.java @@ -0,0 +1,95 @@ +/* + * Copyright 2005 the original author or authors. + * + * Licensed 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.wamblee.concurrency; + +import org.wamblee.test.EventTracker; +import org.wamblee.test.TimingUtils; + +import junit.framework.TestCase; + +/** + * Tests for the JVMLock. + */ +public class JvmLockTest extends TestCase { + + private static final int SLEEP_TIME = 1000; + + private static final String STARTED = "started"; + + private static final String ACQUIRED = "acquired"; + + private static final String RELEASED = "released"; + + private JvmLock _lock; + + private EventTracker _tracker; + + /* + * (non-Javadoc) + * + * @see junit.framework.TestCase#setUp() + */ + @Override + protected void setUp() throws Exception { + _lock = new JvmLock(); + _tracker = new EventTracker(); + } + + private Thread runThread() { + Thread t = new Thread(new Runnable() { + public void run() { + _tracker.eventOccurred(STARTED); + _lock.acquire(); + _tracker.eventOccurred(ACQUIRED); + TimingUtils.sleep(SLEEP_TIME); + _lock.release(); + _tracker.eventOccurred(RELEASED); + }; + }); + t.start(); + return t; + } + + /** + * Tests the operation of the lock. + */ + public void testLock() throws InterruptedException { + Thread t1 = runThread(); + Thread t2 = runThread(); + TimingUtils.sleep(SLEEP_TIME / 10); // give threads a chance to start + // up. + assertEquals(2, _tracker.getEventCount(STARTED)); // both threads + // should have + // started. + assertEquals(1, _tracker.getEventCount(ACQUIRED)); // one thread has + // acquired the + // lock. + TimingUtils.sleep(SLEEP_TIME); + assertEquals(2, _tracker.getEventCount(ACQUIRED)); // now the other + // thread could also + // acquire the lock + assertEquals(1, _tracker.getEventCount(RELEASED)); // and the first + // thread has + // released it. + TimingUtils.sleep(SLEEP_TIME); + assertEquals(2, _tracker.getEventCount(RELEASED)); // both threads + // should be + // finished. + t1.join(); + t2.join(); + } +} diff --git a/support/test/org/wamblee/test/TimingUtils.java b/support/test/org/wamblee/test/TimingUtils.java new file mode 100644 index 00000000..98e89514 --- /dev/null +++ b/support/test/org/wamblee/test/TimingUtils.java @@ -0,0 +1,46 @@ +/* + * Copyright 2005 the original author or authors. + * + * Licensed 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.wamblee.test; + +import junit.framework.TestCase; + +/** + * Timing utilities. + */ +public final class TimingUtils { + + /** + * Disabled constructor. + * + */ + private TimingUtils() { + // Empty + } + + /** + * Sleeps for a time. + * @param aMillis Number of milliseconds to sleep. + */ + public static void sleep(int aMillis) { + try { + Thread.sleep(aMillis); + } catch (InterruptedException e) { + TestCase.fail("Who interrupted my sleep?"); + } + } + +}