X-Git-Url: http://wamblee.org/gitweb/?a=blobdiff_plain;f=system%2Fgeneral%2Fsrc%2Ftest%2Fjava%2Forg%2Fwamblee%2Fsystem%2Fcore%2FContainerTest.java;h=27a1937ff59f4f7e845022f1bb056397d3c3aa20;hb=971e905b3afccdf5b17e9303cee353a33a6db030;hp=9bb53a6a6c1a615c7bd4c0218e90a4bc78921679;hpb=4845c677310814de4c98e22aad483e49b9dfc594;p=utils diff --git a/system/general/src/test/java/org/wamblee/system/core/ContainerTest.java b/system/general/src/test/java/org/wamblee/system/core/ContainerTest.java index 9bb53a6a..27a1937f 100644 --- a/system/general/src/test/java/org/wamblee/system/core/ContainerTest.java +++ b/system/general/src/test/java/org/wamblee/system/core/ContainerTest.java @@ -12,13 +12,16 @@ * 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.system.core; import java.io.Serializable; import java.util.ArrayList; import java.util.Arrays; +import org.easymock.classextension.ConstructorArgs; +import org.easymock.classextension.EasyMock; +import org.easymock.classextension.IMocksControl; import org.wamblee.system.core.Component; import org.wamblee.system.core.Container; import org.wamblee.system.core.DefaultProvidedInterface; @@ -61,11 +64,11 @@ public class ContainerTest extends TestCase { ProvidedInterface prov3 = new DefaultProvidedInterface("name", MyMultiple.class); - AssertionUtils.assertEquals(new RequiredInterface[] { req1 }, - Container.filterRequiredServices(prov1, Arrays + AssertionUtils.assertEquals(new RequiredInterface[] { req1 }, Container + .filterRequiredServices(prov1, Arrays .asList(new RequiredInterface[] { req1 }))); - AssertionUtils.assertEquals(new RequiredInterface[] { req1 }, - Container.filterRequiredServices(prov1, Arrays + AssertionUtils.assertEquals(new RequiredInterface[] { req1 }, Container + .filterRequiredServices(prov1, Arrays .asList(new RequiredInterface[] { req1, req2 }))); AssertionUtils.assertEquals(new RequiredInterface[] { req1, req2 }, Container.filterRequiredServices(prov3, Arrays @@ -88,27 +91,25 @@ public class ContainerTest extends TestCase { Container container = new Container("root", new Component[] { environment, application }, new ProvidedInterface[0], new RequiredInterface[0]); - + container.start(); AssertionUtils.assertEquals(new String[] { "start.environment", "start.application" }, _tracker.getEvents( Thread.currentThread()).toArray(new String[0])); - ProvidedInterface[] envServices = environment.getRunningServices(); + ProvidedInterface[] envServices = environment.getRunningInterfaces(); assertEquals(2, envServices.length); - ProvidedInterface[] appServices = environment.getRunningServices(); - assertEquals(2, appServices.length); - + ProvidedInterface[] appServices = application.getRunningInterfaces(); + assertEquals(0, appServices.length); + } public void testApplicationEnvironment() { try { Component environment = new Environment(); Component application = new Application(); - Container container = new Container( - "root", - new Component[] { - application, environment }, - new ProvidedInterface[0], new RequiredInterface[0]); + Container container = new Container("root", new Component[] { + application, environment }, new ProvidedInterface[0], + new RequiredInterface[0]); container.start(); } catch (SystemAssemblyException e) { // e.printStackTrace(); @@ -123,35 +124,34 @@ public class ContainerTest extends TestCase { assertEquals(0, _tracker.getEventCount()); assertEquals(Status.NOT_STARTED, environment.getStatus()); assertEquals(Status.NOT_STARTED, application.getStatus()); - + Container system = new Container("all", new Component[] { environment, application }, new ProvidedInterface[0], new RequiredInterface[0]); assertEquals(Status.NOT_STARTED, system.getStatus()); system.start(); - RequiredInterface[] required = system.getRequiredServices(); + RequiredInterface[] required = system.getRequiredInterfaces(); assertEquals(0, required.length); - ProvidedInterface[] provided = system.getProvidedServices(); + ProvidedInterface[] provided = system.getProvidedInterfaces(); assertEquals(0, provided.length); assertEquals(Status.RUNNING, environment.getStatus()); assertEquals(Status.RUNNING, application.getStatus()); assertEquals(Status.RUNNING, system.getStatus()); - - AssertionUtils.assertEquals( - new String[] { "start.environment", "start.application" }, - _tracker.getEvents(Thread.currentThread()).toArray(new String[0])); - _tracker.clear(); - + + AssertionUtils.assertEquals(new String[] { "start.environment", + "start.application" }, _tracker.getEvents( + Thread.currentThread()).toArray(new String[0])); + _tracker.clear(); + system.stop(); assertEquals(Status.STOPPED, environment.getStatus()); assertEquals(Status.STOPPED, application.getStatus()); assertEquals(Status.STOPPED, system.getStatus()); - - AssertionUtils.assertEquals( - new String[] { "stop.application", "stop.environment" }, - _tracker.getEvents(Thread.currentThread()).toArray(new String[0])); - - + + AssertionUtils.assertEquals(new String[] { "stop.application", + "stop.environment" }, _tracker + .getEvents(Thread.currentThread()).toArray(new String[0])); + } public void testCompositeWithWrongProvidedInfo() { @@ -191,12 +191,12 @@ public class ContainerTest extends TestCase { application }, new ProvidedInterface[0], new RequiredInterface[] { new DefaultRequiredInterface( "string", String.class) }); - system.getRequiredServices()[0] + system.getRequiredInterfaces()[0] .setProvider(new DefaultProvidedInterface("hallo", String.class)); system.start(); - RequiredInterface[] required = system.getRequiredServices(); + RequiredInterface[] required = system.getRequiredInterfaces(); assertEquals(1, required.length); - ProvidedInterface[] provided = system.getProvidedServices(); + ProvidedInterface[] provided = system.getProvidedInterfaces(); assertEquals(0, provided.length); } @@ -206,7 +206,7 @@ public class ContainerTest extends TestCase { Component application = new Application(); Container system = new Container("all", new Component[] { application }, new ProvidedInterface[0], - application.getRequiredServices()); + application.getRequiredInterfaces()); system.start(); } catch (SystemAssemblyException e) { return; @@ -221,17 +221,17 @@ public class ContainerTest extends TestCase { Component application = new Application(); Container system = new Container("all", new Component[] { application }, new ProvidedInterface[0], - application.getRequiredServices()); + application.getRequiredInterfaces()); environment.start(); - system.getRequiredServices()[0].setProvider(environment - .getProvidedServices()[0]); - system.getRequiredServices()[1].setProvider(environment - .getProvidedServices()[1]); + system.getRequiredInterfaces()[0].setProvider(environment + .getProvidedInterfaces()[0]); + system.getRequiredInterfaces()[1].setProvider(environment + .getProvidedInterfaces()[1]); system.start(); - RequiredInterface[] required = system.getRequiredServices(); + RequiredInterface[] required = system.getRequiredInterfaces(); assertEquals(2, required.length); - ProvidedInterface[] provided = system.getProvidedServices(); + ProvidedInterface[] provided = system.getProvidedInterfaces(); assertEquals(0, provided.length); } @@ -265,4 +265,123 @@ public class ContainerTest extends TestCase { fail(); } + public void testEnvironmentApplicationRollbackOnException() + throws Exception { + IMocksControl control = EasyMock.createStrictControl(); + + Environment environment = new Environment(_tracker); + Application application = control.createMock(Application.class, + new ConstructorArgs(Application.class.getConstructor()), + Application.class.getDeclaredMethod("doStart")); + + application.doStart(); + EasyMock.expectLastCall().andThrow(new RuntimeException()); + control.replay(); + + try { + Container container = new Container("root", new Component[] { + environment, application }, new ProvidedInterface[0], + new RequiredInterface[0]); + + container.start(); + } catch (RuntimeException e) { + AssertionUtils.assertEquals(new String[] { "start.environment", + "stop.environment" }, _tracker.getEvents( + Thread.currentThread()).toArray(new String[0])); + ProvidedInterface[] envServices = environment.getRunningInterfaces(); + assertEquals(0, envServices.length); + assertNull(environment.getProvidedInterfaces()[0].getImplementation()); + assertNull(environment.getProvidedInterfaces()[0].getImplementation()); + return; + } + fail(); + } + + public void testEnvironmentApplicationRollbackOnExceptionWithExceptionOnStop() + throws Exception { + IMocksControl control = EasyMock.createControl(); + + Environment environment = new Environment(_tracker); + // Application 1 will throw an exception while stopping. + Application application1 = control.createMock(Application.class, + new ConstructorArgs(Application.class.getConstructor()), + Application.class.getDeclaredMethod("doStop")); + + application1.doStop(); + EasyMock.expectLastCall().andThrow(new RuntimeException()); + + // application 2 will throw an exception while starting + Application application2 = control.createMock(Application.class, + new ConstructorArgs(Application.class.getConstructor()), + Application.class.getDeclaredMethod("doStart")); + + application2.doStart(); + EasyMock.expectLastCall().andThrow(new RuntimeException()); + + control.replay(); + + try { + Container container = new Container("root", new Component[] { + environment, application1, application2 }, new ProvidedInterface[0], + new RequiredInterface[0]); + + container.start(); + } catch (RuntimeException e) { + AssertionUtils.assertEquals(new String[] { "start.environment", + "stop.environment" }, _tracker.getEvents( + Thread.currentThread()).toArray(new String[0])); + ProvidedInterface[] envServices = environment.getRunningInterfaces(); + assertEquals(0, envServices.length); + assertNull(environment.getProvidedInterfaces()[0].getImplementation()); + assertNull(environment.getProvidedInterfaces()[0].getImplementation()); + return; + } + fail(); + } + + public void testOptionalRequiredInterfaceProvidedOptionalInternal() { + Application application = new Application(true); + Container container = new Container("top", new Component[] { application }, + new ProvidedInterface[0], Application.required(true)); + Environment env = new Environment(); + container.getRequiredInterfaces()[0].setProvider( + env.getProvidedInterfaces()[0]); + container.getRequiredInterfaces()[1].setProvider( + env.getProvidedInterfaces()[1]); + container.start(); + assertSame(env.getProvidedInterfaces()[0], container.getRequiredInterfaces()[0].getProvider()); + assertSame(env.getProvidedInterfaces()[1], container.getRequiredInterfaces()[1].getProvider()); + assertSame(env.getProvidedInterfaces()[0], application.getRequiredInterfaces()[0].getProvider()); + assertSame(env.getProvidedInterfaces()[1], application.getRequiredInterfaces()[1].getProvider()); + } + + public void testOptionalRequiredInterfaceNotProvidedOptionalInternal() { + Application application = new Application(true); + Container container = new Container("top", new Component[] { application }, + new ProvidedInterface[0], Application.required(true)); + Environment env = new Environment(); + container.getRequiredInterfaces()[0].setProvider( + env.getProvidedInterfaces()[0]); + container.start(); + assertSame(env.getProvidedInterfaces()[0], container.getRequiredInterfaces()[0].getProvider()); + assertNull(container.getRequiredInterfaces()[1].getProvider()); + assertSame(env.getProvidedInterfaces()[0], application.getRequiredInterfaces()[0].getProvider()); + assertNull(application.getRequiredInterfaces()[1].getProvider()); + } + + public void testOptionalRequiredInterfaceProvidedMandatoryInternal() { + Application application = new Application(); + Container container = new Container("top", new Component[] { application }, + new ProvidedInterface[0], Application.required(true)); + Environment env = new Environment(); + container.getRequiredInterfaces()[0].setProvider( + env.getProvidedInterfaces()[0]); + container.getRequiredInterfaces()[1].setProvider( + env.getProvidedInterfaces()[1]); + container.start(); + assertSame(env.getProvidedInterfaces()[0], container.getRequiredInterfaces()[0].getProvider()); + assertSame(env.getProvidedInterfaces()[1], container.getRequiredInterfaces()[1].getProvider()); + assertSame(env.getProvidedInterfaces()[0], application.getRequiredInterfaces()[0].getProvider()); + assertSame(env.getProvidedInterfaces()[1], application.getRequiredInterfaces()[1].getProvider()); + } }