You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@felix.apache.org by fm...@apache.org on 2009/08/24 12:37:45 UTC
svn commit: r807142 - in /felix/trunk/scr/src/test:
java/org/apache/felix/scr/integration/
java/org/apache/felix/scr/integration/components/ resources/
Author: fmeschbe
Date: Mon Aug 24 10:37:44 2009
New Revision: 807142
URL: http://svn.apache.org/viewvc?rev=807142&view=rev
Log:
Add integration tests for service binding mechanisms
Added:
felix/trunk/scr/src/test/java/org/apache/felix/scr/integration/ServiceBindTest.java (with props)
felix/trunk/scr/src/test/java/org/apache/felix/scr/integration/components/SimpleService.java (with props)
felix/trunk/scr/src/test/java/org/apache/felix/scr/integration/components/SimpleServiceImpl.java (with props)
felix/trunk/scr/src/test/resources/integration_test_simple_components_service_binding.xml (with props)
Modified:
felix/trunk/scr/src/test/java/org/apache/felix/scr/integration/ComponentTestBase.java
felix/trunk/scr/src/test/java/org/apache/felix/scr/integration/components/SimpleComponent.java
Modified: felix/trunk/scr/src/test/java/org/apache/felix/scr/integration/ComponentTestBase.java
URL: http://svn.apache.org/viewvc/felix/trunk/scr/src/test/java/org/apache/felix/scr/integration/ComponentTestBase.java?rev=807142&r1=807141&r2=807142&view=diff
==============================================================================
--- felix/trunk/scr/src/test/java/org/apache/felix/scr/integration/ComponentTestBase.java (original)
+++ felix/trunk/scr/src/test/java/org/apache/felix/scr/integration/ComponentTestBase.java Mon Aug 24 10:37:44 2009
@@ -78,6 +78,9 @@
// method include it when starting the OSGi framework JVM
protected static String paxRunnerVmOption = null;
+ // the descriptor file to use for the installed test bundle
+ protected static String descriptorFile = "/integration_test_simple_components.xml";
+
static
{
theConfig = new Hashtable<String, String>();
@@ -108,15 +111,7 @@
configAdminTracker = new ServiceTracker( bundleContext, ConfigurationAdmin.class.getName(), null );
configAdminTracker.open();
- // final InputStream bundleStream = newBundle()
- final InputStream bundleStream = new MyTinyBundle().addResource( "OSGI-INF/components.xml",
- getClass().getResource( "/integration_test_simple_components.xml" ) ).prepare(
- withBnd().set( Constants.BUNDLE_SYMBOLICNAME, "simplecomponent" ).set( Constants.BUNDLE_VERSION, "0.0.11" )
- .set( Constants.IMPORT_PACKAGE, "org.apache.felix.scr.integration.components" ).set(
- "Service-Component", "OSGI-INF/components.xml" ) ).build( TinyBundles.asStream() );
-
- bundle = bundleContext.installBundle( "test:SimpleComponent", bundleStream );
-
+ bundle = installBundle( descriptorFile );
bundle.start();
}
@@ -124,8 +119,11 @@
@After
public void tearDown() throws BundleException
{
- bundle.stop();
- bundle.uninstall();
+ if ( bundle != null && bundle.getState() != Bundle.UNINSTALLED )
+ {
+ bundle.uninstall();
+ bundle = null;
+ }
configAdminTracker.close();
configAdminTracker = null;
@@ -318,4 +316,36 @@
field.setAccessible( true );
return field;
}
+
+
+ protected Bundle installBundle( final String descriptorFile ) throws BundleException
+ {
+ final InputStream bundleStream = new MyTinyBundle()
+ .addResource( "OSGI-INF/components.xml", getClass().getResource( descriptorFile ) )
+ .prepare(
+ withBnd()
+ .set( Constants.BUNDLE_SYMBOLICNAME, "simplecomponent" )
+ .set( Constants.BUNDLE_VERSION, "0.0.11" )
+ .set( Constants.IMPORT_PACKAGE, "org.apache.felix.scr.integration.components" )
+ .set( "Service-Component", "OSGI-INF/components.xml" )
+ )
+ .build( TinyBundles.asStream() );
+
+ try
+ {
+ final String location = "test:SimpleComponent/" + System.currentTimeMillis();
+ return bundleContext.installBundle( location, bundleStream );
+ }
+ finally
+ {
+ try
+ {
+ bundleStream.close();
+ }
+ catch ( IOException ioe )
+ {
+ }
+ }
+ }
+
}
Added: felix/trunk/scr/src/test/java/org/apache/felix/scr/integration/ServiceBindTest.java
URL: http://svn.apache.org/viewvc/felix/trunk/scr/src/test/java/org/apache/felix/scr/integration/ServiceBindTest.java?rev=807142&view=auto
==============================================================================
--- felix/trunk/scr/src/test/java/org/apache/felix/scr/integration/ServiceBindTest.java (added)
+++ felix/trunk/scr/src/test/java/org/apache/felix/scr/integration/ServiceBindTest.java Mon Aug 24 10:37:44 2009
@@ -0,0 +1,1077 @@
+/*
+ * Copyright 1997-2009 Day Management AG
+ * Barfuesserplatz 6, 4001 Basel, Switzerland
+ * All Rights Reserved.
+ *
+ * This software is the confidential and proprietary information of
+ * Day Management AG, ("Confidential Information"). You shall not
+ * disclose such Confidential Information and shall use it only in
+ * accordance with the terms of the license agreement you entered into
+ * with Day.
+ */
+package org.apache.felix.scr.integration;
+
+
+import junit.framework.TestCase;
+
+import org.apache.felix.scr.Component;
+import org.apache.felix.scr.integration.components.SimpleComponent;
+import org.apache.felix.scr.integration.components.SimpleServiceImpl;
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.ops4j.pax.exam.junit.JUnit4TestRunner;
+
+
+@RunWith(JUnit4TestRunner.class)
+public class ServiceBindTest extends ComponentTestBase
+{
+ static
+ {
+ // uncomment to enable debugging of this test class
+ // paxRunnerVmOption = DEBUG_VM_OPTION;
+
+ descriptorFile = "/integration_test_simple_components_service_binding.xml";
+ }
+
+
+ @Test
+ public void test_optional_single_dynamic()
+ {
+ final Component component = findComponentByName( "test_optional_single_dynamic" );
+ TestCase.assertNotNull( component );
+ TestCase.assertEquals( Component.STATE_DISABLED, component.getState() );
+
+ final SimpleServiceImpl srv1 = SimpleServiceImpl.create( bundleContext, "srv1" );
+
+ // async enabling
+ component.enable();
+ delay();
+
+ TestCase.assertEquals( Component.STATE_ACTIVE, component.getState() );
+ final SimpleComponent comp10 = SimpleComponent.INSTANCE;
+ TestCase.assertNotNull( comp10 );
+ TestCase.assertEquals( srv1, comp10.m_singleRef );
+ TestCase.assertTrue( comp10.m_multiRef.isEmpty() );
+
+ srv1.drop();
+ // no delay, should be immediate
+
+ TestCase.assertEquals( Component.STATE_ACTIVE, component.getState() );
+ final SimpleComponent comp11 = SimpleComponent.INSTANCE;
+ TestCase.assertSame( comp10, comp11 );
+ TestCase.assertNull( comp11.m_singleRef );
+ TestCase.assertTrue( comp11.m_multiRef.isEmpty() );
+
+ final SimpleServiceImpl srv2 = SimpleServiceImpl.create( bundleContext, "srv2" );
+ delay(); // async binding
+
+ TestCase.assertEquals( Component.STATE_ACTIVE, component.getState() );
+ final SimpleComponent comp12 = SimpleComponent.INSTANCE;
+ TestCase.assertSame( comp10, comp12 );
+ TestCase.assertEquals( srv2, comp12.m_singleRef );
+ TestCase.assertTrue( comp12.m_multiRef.isEmpty() );
+
+ component.disable();
+ delay(); // async disabling
+
+ final SimpleServiceImpl srv3 = SimpleServiceImpl.create( bundleContext, "srv3" );
+
+ // enable component with two services available, expect srv2 bind
+ // async enabling
+ component.enable();
+ delay();
+
+ TestCase.assertEquals( Component.STATE_ACTIVE, component.getState() );
+ final SimpleComponent comp20 = SimpleComponent.INSTANCE;
+ TestCase.assertNotNull( comp20 );
+ TestCase.assertNotSame( comp10, comp20 );
+ TestCase.assertEquals( srv2, comp20.m_singleRef );
+ TestCase.assertTrue( comp20.m_multiRef.isEmpty() );
+
+ // drop srv2, expect rebind to srv3 (synchronously)
+ srv2.drop();
+
+ TestCase.assertEquals( Component.STATE_ACTIVE, component.getState() );
+ final SimpleComponent comp21 = SimpleComponent.INSTANCE;
+ TestCase.assertSame( comp20, comp21 );
+ TestCase.assertEquals( srv3, comp21.m_singleRef );
+ TestCase.assertTrue( comp21.m_multiRef.isEmpty() );
+
+ // create srv4, expect no rebind
+ final SimpleServiceImpl srv4 = SimpleServiceImpl.create( bundleContext, "srv4" );
+ delay();
+
+ TestCase.assertEquals( Component.STATE_ACTIVE, component.getState() );
+ final SimpleComponent comp22 = SimpleComponent.INSTANCE;
+ TestCase.assertSame( comp20, comp22 );
+ TestCase.assertEquals( srv3, comp22.m_singleRef );
+ TestCase.assertTrue( comp22.m_multiRef.isEmpty() );
+
+ // drop srv4 again, expect no rebind
+ srv4.drop();
+ delay();
+
+ TestCase.assertEquals( Component.STATE_ACTIVE, component.getState() );
+ final SimpleComponent comp23 = SimpleComponent.INSTANCE;
+ TestCase.assertSame( comp20, comp23 );
+ TestCase.assertEquals( srv3, comp23.m_singleRef );
+ TestCase.assertTrue( comp23.m_multiRef.isEmpty() );
+
+ // "reset"
+ component.disable();
+ srv3.drop();
+ delay();
+
+ // two services with service ranking (srv6 > srv5)
+ final SimpleServiceImpl srv5 = SimpleServiceImpl.create( bundleContext, "srv5", 10 );
+ final SimpleServiceImpl srv6 = SimpleServiceImpl.create( bundleContext, "srv6", 20 );
+
+ component.enable();
+ delay();
+
+ TestCase.assertEquals( Component.STATE_ACTIVE, component.getState() );
+ final SimpleComponent comp30 = SimpleComponent.INSTANCE;
+ TestCase.assertNotSame( comp20, comp30 );
+ TestCase.assertEquals( srv6, comp30.m_singleRef );
+ TestCase.assertTrue( comp30.m_multiRef.isEmpty() );
+
+ // another service with higher ranking -- no rebind !
+ final SimpleServiceImpl srv7 = SimpleServiceImpl.create( bundleContext, "srv7", 30 );
+ delay();
+
+ TestCase.assertEquals( Component.STATE_ACTIVE, component.getState() );
+ final SimpleComponent comp31 = SimpleComponent.INSTANCE;
+ TestCase.assertSame( comp30, comp31 );
+ TestCase.assertEquals( srv6, comp31.m_singleRef );
+ TestCase.assertTrue( comp31.m_multiRef.isEmpty() );
+
+ // srv6 goes, rebind to srv7
+ srv6.drop();
+ delay();
+
+ TestCase.assertEquals( Component.STATE_ACTIVE, component.getState() );
+ final SimpleComponent comp32 = SimpleComponent.INSTANCE;
+ TestCase.assertSame( comp30, comp32 );
+ TestCase.assertEquals( srv7, comp32.m_singleRef );
+ TestCase.assertTrue( comp32.m_multiRef.isEmpty() );
+ }
+
+
+ @Test
+ public void test_required_single_dynamic()
+ {
+ final Component component = findComponentByName( "test_required_single_dynamic" );
+ TestCase.assertNotNull( component );
+ TestCase.assertEquals( Component.STATE_DISABLED, component.getState() );
+
+ final SimpleServiceImpl srv1 = SimpleServiceImpl.create( bundleContext, "srv1" );
+
+ // async enabling
+ component.enable();
+ delay();
+
+ TestCase.assertEquals( Component.STATE_ACTIVE, component.getState() );
+ final SimpleComponent comp10 = SimpleComponent.INSTANCE;
+ TestCase.assertNotNull( comp10 );
+ TestCase.assertEquals( srv1, comp10.m_singleRef );
+ TestCase.assertTrue( comp10.m_multiRef.isEmpty() );
+
+ srv1.drop();
+ // no delay, should be immediate
+
+ TestCase.assertEquals( Component.STATE_UNSATISFIED, component.getState() );
+ final SimpleComponent comp11 = SimpleComponent.INSTANCE;
+ TestCase.assertNull( comp11 );
+
+ final SimpleServiceImpl srv2 = SimpleServiceImpl.create( bundleContext, "srv2" );
+ delay(); // async binding
+
+ TestCase.assertEquals( Component.STATE_ACTIVE, component.getState() );
+ final SimpleComponent comp12 = SimpleComponent.INSTANCE;
+ TestCase.assertNotSame( comp10, comp12 );
+ TestCase.assertEquals( srv2, comp12.m_singleRef );
+ TestCase.assertTrue( comp12.m_multiRef.isEmpty() );
+
+ component.disable();
+ delay(); // async disabling
+
+ final SimpleServiceImpl srv3 = SimpleServiceImpl.create( bundleContext, "srv3" );
+
+ // enable component with two services available, expect srv2 bind
+ // async enabling
+ component.enable();
+ delay();
+
+ TestCase.assertEquals( Component.STATE_ACTIVE, component.getState() );
+ final SimpleComponent comp20 = SimpleComponent.INSTANCE;
+ TestCase.assertNotNull( comp20 );
+ TestCase.assertNotSame( comp10, comp20 );
+ TestCase.assertEquals( srv2, comp20.m_singleRef );
+ TestCase.assertTrue( comp20.m_multiRef.isEmpty() );
+
+ // drop srv2, expect rebind to srv3 (synchronously)
+ srv2.drop();
+
+ TestCase.assertEquals( Component.STATE_ACTIVE, component.getState() );
+ final SimpleComponent comp21 = SimpleComponent.INSTANCE;
+ TestCase.assertSame( comp20, comp21 );
+ TestCase.assertEquals( srv3, comp21.m_singleRef );
+ TestCase.assertTrue( comp21.m_multiRef.isEmpty() );
+
+ // create srv4, expect no rebind
+ final SimpleServiceImpl srv4 = SimpleServiceImpl.create( bundleContext, "srv4" );
+ delay();
+
+ TestCase.assertEquals( Component.STATE_ACTIVE, component.getState() );
+ final SimpleComponent comp22 = SimpleComponent.INSTANCE;
+ TestCase.assertSame( comp20, comp22 );
+ TestCase.assertEquals( srv3, comp22.m_singleRef );
+ TestCase.assertTrue( comp22.m_multiRef.isEmpty() );
+
+ // drop srv4 again, expect no rebind
+ srv4.drop();
+ delay();
+
+ TestCase.assertEquals( Component.STATE_ACTIVE, component.getState() );
+ final SimpleComponent comp23 = SimpleComponent.INSTANCE;
+ TestCase.assertSame( comp20, comp23 );
+ TestCase.assertEquals( srv3, comp23.m_singleRef );
+ TestCase.assertTrue( comp23.m_multiRef.isEmpty() );
+
+ // "reset"
+ component.disable();
+ srv3.drop();
+ delay();
+
+ // two services with service ranking (srv6 > srv5)
+ final SimpleServiceImpl srv5 = SimpleServiceImpl.create( bundleContext, "srv5", 10 );
+ final SimpleServiceImpl srv6 = SimpleServiceImpl.create( bundleContext, "srv6", 20 );
+
+ component.enable();
+ delay();
+
+ TestCase.assertEquals( Component.STATE_ACTIVE, component.getState() );
+ final SimpleComponent comp30 = SimpleComponent.INSTANCE;
+ TestCase.assertNotSame( comp20, comp30 );
+ TestCase.assertEquals( srv6, comp30.m_singleRef );
+ TestCase.assertTrue( comp30.m_multiRef.isEmpty() );
+
+ // another service with higher ranking -- no rebind !
+ final SimpleServiceImpl srv7 = SimpleServiceImpl.create( bundleContext, "srv7", 30 );
+ delay();
+
+ TestCase.assertEquals( Component.STATE_ACTIVE, component.getState() );
+ final SimpleComponent comp31 = SimpleComponent.INSTANCE;
+ TestCase.assertSame( comp30, comp31 );
+ TestCase.assertEquals( srv6, comp31.m_singleRef );
+ TestCase.assertTrue( comp31.m_multiRef.isEmpty() );
+
+ // srv6 goes, rebind to srv7
+ srv6.drop();
+ delay();
+
+ TestCase.assertEquals( Component.STATE_ACTIVE, component.getState() );
+ final SimpleComponent comp32 = SimpleComponent.INSTANCE;
+ TestCase.assertSame( comp30, comp32 );
+ TestCase.assertEquals( srv7, comp32.m_singleRef );
+ TestCase.assertTrue( comp32.m_multiRef.isEmpty() );
+ }
+
+
+ @Test
+ public void test_optional_multiple_dynamic()
+ {
+ final Component component = findComponentByName( "test_optional_multiple_dynamic" );
+ TestCase.assertNotNull( component );
+ TestCase.assertEquals( Component.STATE_DISABLED, component.getState() );
+
+ final SimpleServiceImpl srv1 = SimpleServiceImpl.create( bundleContext, "srv1" );
+
+ // async enabling
+ component.enable();
+ delay();
+
+ TestCase.assertEquals( Component.STATE_ACTIVE, component.getState() );
+ final SimpleComponent comp10 = SimpleComponent.INSTANCE;
+ TestCase.assertNotNull( comp10 );
+ TestCase.assertNull( comp10.m_singleRef );
+ TestCase.assertTrue( comp10.m_multiRef.contains( srv1 ) );
+
+ srv1.drop();
+ // no delay, should be immediate
+
+ TestCase.assertEquals( Component.STATE_ACTIVE, component.getState() );
+ final SimpleComponent comp11 = SimpleComponent.INSTANCE;
+ TestCase.assertSame( comp10, comp11 );
+ TestCase.assertNull( comp11.m_singleRef );
+ TestCase.assertTrue( comp11.m_multiRef.isEmpty() );
+
+ final SimpleServiceImpl srv2 = SimpleServiceImpl.create( bundleContext, "srv2" );
+ delay(); // async binding
+
+ TestCase.assertEquals( Component.STATE_ACTIVE, component.getState() );
+ final SimpleComponent comp12 = SimpleComponent.INSTANCE;
+ TestCase.assertSame( comp10, comp12 );
+ TestCase.assertNull( comp12.m_singleRef );
+ TestCase.assertTrue( comp12.m_multiRef.contains( srv2 ) );
+
+ component.disable();
+ delay(); // async disabling
+
+ final SimpleServiceImpl srv3 = SimpleServiceImpl.create( bundleContext, "srv3" );
+
+ // enable component with two services available, expect both bind
+ // async enabling
+ component.enable();
+ delay();
+
+ TestCase.assertEquals( Component.STATE_ACTIVE, component.getState() );
+ final SimpleComponent comp20 = SimpleComponent.INSTANCE;
+ TestCase.assertNotNull( comp20 );
+ TestCase.assertNotSame( comp10, comp20 );
+ TestCase.assertNull( comp20.m_singleRef );
+ TestCase.assertTrue( comp20.m_multiRef.contains( srv2 ) );
+ TestCase.assertTrue( comp20.m_multiRef.contains( srv3 ) );
+
+ srv2.drop();
+
+ TestCase.assertEquals( Component.STATE_ACTIVE, component.getState() );
+ final SimpleComponent comp21 = SimpleComponent.INSTANCE;
+ TestCase.assertSame( comp20, comp21 );
+ TestCase.assertNull( comp21.m_singleRef );
+ TestCase.assertFalse( comp21.m_multiRef.contains( srv2 ) );
+ TestCase.assertTrue( comp21.m_multiRef.contains( srv3 ) );
+
+ // create srv4, expect bind
+ final SimpleServiceImpl srv4 = SimpleServiceImpl.create( bundleContext, "srv4" );
+ delay();
+
+ TestCase.assertEquals( Component.STATE_ACTIVE, component.getState() );
+ final SimpleComponent comp22 = SimpleComponent.INSTANCE;
+ TestCase.assertSame( comp20, comp22 );
+ TestCase.assertNull( comp22.m_singleRef );
+ TestCase.assertFalse( comp22.m_multiRef.contains( srv2 ) );
+ TestCase.assertTrue( comp22.m_multiRef.contains( srv3 ) );
+ TestCase.assertTrue( comp22.m_multiRef.contains( srv4 ) );
+
+ // drop srv4 again, expect no rebind
+ srv4.drop();
+ delay();
+
+ TestCase.assertEquals( Component.STATE_ACTIVE, component.getState() );
+ final SimpleComponent comp23 = SimpleComponent.INSTANCE;
+ TestCase.assertSame( comp20, comp23 );
+ TestCase.assertNull( comp23.m_singleRef );
+ TestCase.assertFalse( comp23.m_multiRef.contains( srv2 ) );
+ TestCase.assertTrue( comp23.m_multiRef.contains( srv3 ) );
+ TestCase.assertFalse( comp23.m_multiRef.contains( srv4 ) );
+
+ // "reset"
+ component.disable();
+ srv3.drop();
+ delay();
+
+ // two services with service ranking (srv6 > srv5)
+ final SimpleServiceImpl srv5 = SimpleServiceImpl.create( bundleContext, "srv5", 10 );
+ final SimpleServiceImpl srv6 = SimpleServiceImpl.create( bundleContext, "srv6", 20 );
+
+ component.enable();
+ delay();
+
+ TestCase.assertEquals( Component.STATE_ACTIVE, component.getState() );
+ final SimpleComponent comp30 = SimpleComponent.INSTANCE;
+ TestCase.assertNotSame( comp20, comp30 );
+ TestCase.assertNull( comp30.m_singleRef );
+ TestCase.assertTrue( comp30.m_multiRef.contains( srv5 ) );
+ TestCase.assertTrue( comp30.m_multiRef.contains( srv6 ) );
+
+ // another service with higher ranking -- no rebind !
+ final SimpleServiceImpl srv7 = SimpleServiceImpl.create( bundleContext, "srv7", 30 );
+ delay();
+
+ TestCase.assertEquals( Component.STATE_ACTIVE, component.getState() );
+ final SimpleComponent comp31 = SimpleComponent.INSTANCE;
+ TestCase.assertSame( comp30, comp31 );
+ TestCase.assertNull( comp31.m_singleRef );
+ TestCase.assertTrue( comp31.m_multiRef.contains( srv5 ) );
+ TestCase.assertTrue( comp31.m_multiRef.contains( srv6 ) );
+ TestCase.assertTrue( comp31.m_multiRef.contains( srv7 ) );
+
+ // srv6 goes, rebind to srv7
+ srv6.drop();
+ delay();
+
+ TestCase.assertEquals( Component.STATE_ACTIVE, component.getState() );
+ final SimpleComponent comp32 = SimpleComponent.INSTANCE;
+ TestCase.assertSame( comp30, comp32 );
+ TestCase.assertNull( comp32.m_singleRef );
+ TestCase.assertTrue( comp32.m_multiRef.contains( srv5 ) );
+ TestCase.assertFalse( comp32.m_multiRef.contains( srv6 ) );
+ TestCase.assertTrue( comp32.m_multiRef.contains( srv7 ) );
+ }
+
+
+ @Test
+ public void test_required_multiple_dynamic()
+ {
+ final Component component = findComponentByName( "test_required_multiple_dynamic" );
+ TestCase.assertNotNull( component );
+ TestCase.assertEquals( Component.STATE_DISABLED, component.getState() );
+
+ final SimpleServiceImpl srv1 = SimpleServiceImpl.create( bundleContext, "srv1" );
+
+ // async enabling
+ component.enable();
+ delay();
+
+ TestCase.assertEquals( Component.STATE_ACTIVE, component.getState() );
+ final SimpleComponent comp10 = SimpleComponent.INSTANCE;
+ TestCase.assertNotNull( comp10 );
+ TestCase.assertNull( comp10.m_singleRef );
+ TestCase.assertTrue( comp10.m_multiRef.contains( srv1 ) );
+
+ srv1.drop();
+ // no delay, should be immediate
+
+ TestCase.assertEquals( Component.STATE_UNSATISFIED, component.getState() );
+ final SimpleComponent comp11 = SimpleComponent.INSTANCE;
+ TestCase.assertNull( comp11 );
+
+ final SimpleServiceImpl srv2 = SimpleServiceImpl.create( bundleContext, "srv2" );
+ delay(); // async binding
+
+ TestCase.assertEquals( Component.STATE_ACTIVE, component.getState() );
+ final SimpleComponent comp12 = SimpleComponent.INSTANCE;
+ TestCase.assertNotSame( comp10, comp12 );
+ TestCase.assertNull( comp12.m_singleRef );
+ TestCase.assertTrue( comp12.m_multiRef.contains( srv2 ) );
+
+ component.disable();
+ delay(); // async disabling
+
+ final SimpleServiceImpl srv3 = SimpleServiceImpl.create( bundleContext, "srv3" );
+
+ // enable component with two services available, expect both bind
+ // async enabling
+ component.enable();
+ delay();
+
+ TestCase.assertEquals( Component.STATE_ACTIVE, component.getState() );
+ final SimpleComponent comp20 = SimpleComponent.INSTANCE;
+ TestCase.assertNotNull( comp20 );
+ TestCase.assertNotSame( comp10, comp20 );
+ TestCase.assertNull( comp20.m_singleRef );
+ TestCase.assertTrue( comp20.m_multiRef.contains( srv2 ) );
+ TestCase.assertTrue( comp20.m_multiRef.contains( srv3 ) );
+
+ srv2.drop();
+
+ TestCase.assertEquals( Component.STATE_ACTIVE, component.getState() );
+ final SimpleComponent comp21 = SimpleComponent.INSTANCE;
+ TestCase.assertSame( comp20, comp21 );
+ TestCase.assertNull( comp21.m_singleRef );
+ TestCase.assertFalse( comp21.m_multiRef.contains( srv2 ) );
+ TestCase.assertTrue( comp21.m_multiRef.contains( srv3 ) );
+
+ // create srv4, expect bind
+ final SimpleServiceImpl srv4 = SimpleServiceImpl.create( bundleContext, "srv4" );
+ delay();
+
+ TestCase.assertEquals( Component.STATE_ACTIVE, component.getState() );
+ final SimpleComponent comp22 = SimpleComponent.INSTANCE;
+ TestCase.assertSame( comp20, comp22 );
+ TestCase.assertNull( comp22.m_singleRef );
+ TestCase.assertFalse( comp22.m_multiRef.contains( srv2 ) );
+ TestCase.assertTrue( comp22.m_multiRef.contains( srv3 ) );
+ TestCase.assertTrue( comp22.m_multiRef.contains( srv4 ) );
+
+ // drop srv4 again, expect no rebind
+ srv4.drop();
+ delay();
+
+ TestCase.assertEquals( Component.STATE_ACTIVE, component.getState() );
+ final SimpleComponent comp23 = SimpleComponent.INSTANCE;
+ TestCase.assertSame( comp20, comp23 );
+ TestCase.assertNull( comp23.m_singleRef );
+ TestCase.assertFalse( comp23.m_multiRef.contains( srv2 ) );
+ TestCase.assertTrue( comp23.m_multiRef.contains( srv3 ) );
+ TestCase.assertFalse( comp23.m_multiRef.contains( srv4 ) );
+
+ // "reset"
+ component.disable();
+ srv3.drop();
+ delay();
+
+ // two services with service ranking (srv6 > srv5)
+ final SimpleServiceImpl srv5 = SimpleServiceImpl.create( bundleContext, "srv5", 10 );
+ final SimpleServiceImpl srv6 = SimpleServiceImpl.create( bundleContext, "srv6", 20 );
+
+ component.enable();
+ delay();
+
+ TestCase.assertEquals( Component.STATE_ACTIVE, component.getState() );
+ final SimpleComponent comp30 = SimpleComponent.INSTANCE;
+ TestCase.assertNotSame( comp20, comp30 );
+ TestCase.assertNull( comp30.m_singleRef );
+ TestCase.assertTrue( comp30.m_multiRef.contains( srv5 ) );
+ TestCase.assertTrue( comp30.m_multiRef.contains( srv6 ) );
+
+ // another service with higher ranking -- no rebind !
+ final SimpleServiceImpl srv7 = SimpleServiceImpl.create( bundleContext, "srv7", 30 );
+ delay();
+
+ TestCase.assertEquals( Component.STATE_ACTIVE, component.getState() );
+ final SimpleComponent comp31 = SimpleComponent.INSTANCE;
+ TestCase.assertSame( comp30, comp31 );
+ TestCase.assertNull( comp31.m_singleRef );
+ TestCase.assertTrue( comp31.m_multiRef.contains( srv5 ) );
+ TestCase.assertTrue( comp31.m_multiRef.contains( srv6 ) );
+ TestCase.assertTrue( comp31.m_multiRef.contains( srv7 ) );
+
+ // srv6 goes, rebind to srv7
+ srv6.drop();
+ delay();
+
+ TestCase.assertEquals( Component.STATE_ACTIVE, component.getState() );
+ final SimpleComponent comp32 = SimpleComponent.INSTANCE;
+ TestCase.assertSame( comp30, comp32 );
+ TestCase.assertNull( comp32.m_singleRef );
+ TestCase.assertTrue( comp32.m_multiRef.contains( srv5 ) );
+ TestCase.assertFalse( comp32.m_multiRef.contains( srv6 ) );
+ TestCase.assertTrue( comp32.m_multiRef.contains( srv7 ) );
+ }
+
+
+ @Test
+ public void test_optional_single_static()
+ {
+ final Component component = findComponentByName( "test_optional_single_static" );
+ TestCase.assertNotNull( component );
+ TestCase.assertEquals( Component.STATE_DISABLED, component.getState() );
+
+ final SimpleServiceImpl srv1 = SimpleServiceImpl.create( bundleContext, "srv1" );
+
+ // async enabling
+ component.enable();
+ delay();
+
+ TestCase.assertEquals( Component.STATE_ACTIVE, component.getState() );
+ final SimpleComponent comp10 = SimpleComponent.INSTANCE;
+ TestCase.assertNotNull( comp10 );
+ TestCase.assertEquals( srv1, comp10.m_singleRef );
+ TestCase.assertTrue( comp10.m_multiRef.isEmpty() );
+
+ srv1.drop();
+ delay(); // async reactivate
+
+ TestCase.assertEquals( Component.STATE_ACTIVE, component.getState() );
+ final SimpleComponent comp11 = SimpleComponent.INSTANCE;
+ TestCase.assertNotSame( comp10, comp11 );
+ TestCase.assertNull( comp11.m_singleRef );
+ TestCase.assertTrue( comp11.m_multiRef.isEmpty() );
+
+ final SimpleServiceImpl srv2 = SimpleServiceImpl.create( bundleContext, "srv2" );
+ delay(); // async binding
+
+ // static reference does not rebind unless component is cycled for other reasons !!
+ TestCase.assertEquals( Component.STATE_ACTIVE, component.getState() );
+ final SimpleComponent comp12 = SimpleComponent.INSTANCE;
+ TestCase.assertNotSame( comp10, comp12 );
+ TestCase.assertSame( comp11, comp12 );
+ TestCase.assertNull( comp12.m_singleRef );
+ TestCase.assertTrue( comp12.m_multiRef.isEmpty() );
+
+ component.disable();
+ delay(); // async disabling
+
+ final SimpleServiceImpl srv3 = SimpleServiceImpl.create( bundleContext, "srv3" );
+
+ // enable component with two services available, expect srv2 bind
+ // async enabling
+ component.enable();
+ delay();
+
+ TestCase.assertEquals( Component.STATE_ACTIVE, component.getState() );
+ final SimpleComponent comp20 = SimpleComponent.INSTANCE;
+ TestCase.assertNotNull( comp20 );
+ TestCase.assertNotSame( comp10, comp20 );
+ TestCase.assertEquals( srv2, comp20.m_singleRef );
+ TestCase.assertTrue( comp20.m_multiRef.isEmpty() );
+
+ // drop srv2, expect rebind to srv3 (synchronously)
+ srv2.drop();
+ delay(); // async reactivate
+
+ TestCase.assertEquals( Component.STATE_ACTIVE, component.getState() );
+ final SimpleComponent comp21 = SimpleComponent.INSTANCE;
+ TestCase.assertNotSame( comp20, comp21 );
+ TestCase.assertEquals( srv3, comp21.m_singleRef );
+ TestCase.assertTrue( comp21.m_multiRef.isEmpty() );
+
+ // create srv4, expect no rebind
+ final SimpleServiceImpl srv4 = SimpleServiceImpl.create( bundleContext, "srv4" );
+ delay();
+
+ TestCase.assertEquals( Component.STATE_ACTIVE, component.getState() );
+ final SimpleComponent comp22 = SimpleComponent.INSTANCE;
+ TestCase.assertNotSame( comp20, comp22 );
+ TestCase.assertSame( comp21, comp22 );
+ TestCase.assertEquals( srv3, comp22.m_singleRef );
+ TestCase.assertTrue( comp22.m_multiRef.isEmpty() );
+
+ // drop srv4 again, expect no rebind
+ srv4.drop();
+ delay();
+
+ TestCase.assertEquals( Component.STATE_ACTIVE, component.getState() );
+ final SimpleComponent comp23 = SimpleComponent.INSTANCE;
+ TestCase.assertNotSame( comp20, comp23 );
+ TestCase.assertSame( comp21, comp23 );
+ TestCase.assertSame( comp22, comp23 );
+ TestCase.assertEquals( srv3, comp23.m_singleRef );
+ TestCase.assertTrue( comp23.m_multiRef.isEmpty() );
+
+ // "reset"
+ component.disable();
+ srv3.drop();
+ delay();
+
+ // two services with service ranking (srv6 > srv5)
+ final SimpleServiceImpl srv5 = SimpleServiceImpl.create( bundleContext, "srv5", 10 );
+ final SimpleServiceImpl srv6 = SimpleServiceImpl.create( bundleContext, "srv6", 20 );
+
+ component.enable();
+ delay();
+
+ TestCase.assertEquals( Component.STATE_ACTIVE, component.getState() );
+ final SimpleComponent comp30 = SimpleComponent.INSTANCE;
+ TestCase.assertNotSame( comp23, comp30 );
+ TestCase.assertEquals( srv6, comp30.m_singleRef );
+ TestCase.assertTrue( comp30.m_multiRef.isEmpty() );
+
+ // another service with higher ranking -- no rebind !
+ final SimpleServiceImpl srv7 = SimpleServiceImpl.create( bundleContext, "srv7", 30 );
+ delay();
+
+ TestCase.assertEquals( Component.STATE_ACTIVE, component.getState() );
+ final SimpleComponent comp31 = SimpleComponent.INSTANCE;
+ TestCase.assertSame( comp30, comp31 );
+ TestCase.assertEquals( srv6, comp31.m_singleRef );
+ TestCase.assertTrue( comp31.m_multiRef.isEmpty() );
+
+ // srv6 goes, rebind to srv7
+ srv6.drop();
+ delay();
+
+ TestCase.assertEquals( Component.STATE_ACTIVE, component.getState() );
+ final SimpleComponent comp32 = SimpleComponent.INSTANCE;
+ TestCase.assertNotSame( comp30, comp32 );
+ TestCase.assertNotSame( comp31, comp32 );
+ TestCase.assertEquals( srv7, comp32.m_singleRef );
+ TestCase.assertTrue( comp32.m_multiRef.isEmpty() );
+ }
+
+
+ @Test
+ public void test_required_single_static()
+ {
+ final Component component = findComponentByName( "test_required_single_static" );
+ TestCase.assertNotNull( component );
+ TestCase.assertEquals( Component.STATE_DISABLED, component.getState() );
+
+ final SimpleServiceImpl srv1 = SimpleServiceImpl.create( bundleContext, "srv1" );
+
+ // async enabling
+ component.enable();
+ delay();
+
+ TestCase.assertEquals( Component.STATE_ACTIVE, component.getState() );
+ final SimpleComponent comp10 = SimpleComponent.INSTANCE;
+ TestCase.assertNotNull( comp10 );
+ TestCase.assertEquals( srv1, comp10.m_singleRef );
+ TestCase.assertTrue( comp10.m_multiRef.isEmpty() );
+
+ srv1.drop();
+ delay(); // async reactivate
+
+ TestCase.assertEquals( Component.STATE_UNSATISFIED, component.getState() );
+ final SimpleComponent comp11 = SimpleComponent.INSTANCE;
+ TestCase.assertNull( comp11 );
+
+ final SimpleServiceImpl srv2 = SimpleServiceImpl.create( bundleContext, "srv2" );
+ delay(); // async binding
+
+ TestCase.assertEquals( Component.STATE_ACTIVE, component.getState() );
+ final SimpleComponent comp12 = SimpleComponent.INSTANCE;
+ TestCase.assertNotSame( comp10, comp12 );
+ TestCase.assertEquals( srv2, comp12.m_singleRef );
+ TestCase.assertTrue( comp12.m_multiRef.isEmpty() );
+
+ component.disable();
+ delay(); // async disabling
+
+ final SimpleServiceImpl srv3 = SimpleServiceImpl.create( bundleContext, "srv3" );
+
+ // enable component with two services available, expect srv2 bind
+ // async enabling
+ component.enable();
+ delay();
+
+ TestCase.assertEquals( Component.STATE_ACTIVE, component.getState() );
+ final SimpleComponent comp20 = SimpleComponent.INSTANCE;
+ TestCase.assertNotNull( comp20 );
+ TestCase.assertNotSame( comp10, comp20 );
+ TestCase.assertEquals( srv2, comp20.m_singleRef );
+ TestCase.assertTrue( comp20.m_multiRef.isEmpty() );
+
+ // drop srv2, expect rebind to srv3
+ srv2.drop();
+ delay(); // async reactivate
+
+ TestCase.assertEquals( Component.STATE_ACTIVE, component.getState() );
+ final SimpleComponent comp21 = SimpleComponent.INSTANCE;
+ TestCase.assertNotSame( comp20, comp21 );
+ TestCase.assertEquals( srv3, comp21.m_singleRef );
+ TestCase.assertTrue( comp21.m_multiRef.isEmpty() );
+
+ // create srv4, expect no rebind
+ final SimpleServiceImpl srv4 = SimpleServiceImpl.create( bundleContext, "srv4" );
+ delay();
+
+ TestCase.assertEquals( Component.STATE_ACTIVE, component.getState() );
+ final SimpleComponent comp22 = SimpleComponent.INSTANCE;
+ TestCase.assertNotSame( comp20, comp22 );
+ TestCase.assertSame( comp21, comp22 );
+ TestCase.assertEquals( srv3, comp22.m_singleRef );
+ TestCase.assertTrue( comp22.m_multiRef.isEmpty() );
+
+ // drop srv4 again, expect no rebind
+ srv4.drop();
+ delay();
+
+ TestCase.assertEquals( Component.STATE_ACTIVE, component.getState() );
+ final SimpleComponent comp23 = SimpleComponent.INSTANCE;
+ TestCase.assertNotSame( comp20, comp23 );
+ TestCase.assertSame( comp21, comp23 );
+ TestCase.assertSame( comp22, comp23 );
+ TestCase.assertEquals( srv3, comp23.m_singleRef );
+ TestCase.assertTrue( comp23.m_multiRef.isEmpty() );
+
+ // "reset"
+ component.disable();
+ srv3.drop();
+ delay();
+
+ // two services with service ranking (srv6 > srv5)
+ final SimpleServiceImpl srv5 = SimpleServiceImpl.create( bundleContext, "srv5", 10 );
+ final SimpleServiceImpl srv6 = SimpleServiceImpl.create( bundleContext, "srv6", 20 );
+
+ component.enable();
+ delay();
+
+ TestCase.assertEquals( Component.STATE_ACTIVE, component.getState() );
+ final SimpleComponent comp30 = SimpleComponent.INSTANCE;
+ TestCase.assertNotSame( comp23, comp30 );
+ TestCase.assertEquals( srv6, comp30.m_singleRef );
+ TestCase.assertTrue( comp30.m_multiRef.isEmpty() );
+
+ // another service with higher ranking -- no rebind !
+ final SimpleServiceImpl srv7 = SimpleServiceImpl.create( bundleContext, "srv7", 30 );
+ delay();
+
+ TestCase.assertEquals( Component.STATE_ACTIVE, component.getState() );
+ final SimpleComponent comp31 = SimpleComponent.INSTANCE;
+ TestCase.assertSame( comp30, comp31 );
+ TestCase.assertEquals( srv6, comp31.m_singleRef );
+ TestCase.assertTrue( comp31.m_multiRef.isEmpty() );
+
+ // srv6 goes, rebind to srv7
+ srv6.drop();
+ delay();
+
+ TestCase.assertEquals( Component.STATE_ACTIVE, component.getState() );
+ final SimpleComponent comp32 = SimpleComponent.INSTANCE;
+ TestCase.assertNotSame( comp30, comp32 );
+ TestCase.assertNotSame( comp31, comp32 );
+ TestCase.assertEquals( srv7, comp32.m_singleRef );
+ TestCase.assertTrue( comp32.m_multiRef.isEmpty() );
+ }
+
+
+ @Test
+ public void test_optional_multiple_static()
+ {
+ final Component component = findComponentByName( "test_optional_multiple_static" );
+ TestCase.assertNotNull( component );
+ TestCase.assertEquals( Component.STATE_DISABLED, component.getState() );
+
+ final SimpleServiceImpl srv1 = SimpleServiceImpl.create( bundleContext, "srv1" );
+
+ // async enabling
+ component.enable();
+ delay();
+
+ TestCase.assertEquals( Component.STATE_ACTIVE, component.getState() );
+ final SimpleComponent comp10 = SimpleComponent.INSTANCE;
+ TestCase.assertNotNull( comp10 );
+ TestCase.assertNull( comp10.m_singleRef );
+ TestCase.assertTrue( comp10.m_multiRef.contains( srv1 ) );
+
+ srv1.drop();
+ delay(); // async reactivate
+
+ TestCase.assertEquals( Component.STATE_ACTIVE, component.getState() );
+ final SimpleComponent comp11 = SimpleComponent.INSTANCE;
+ TestCase.assertNotSame( comp10, comp11 );
+ TestCase.assertNull( comp11.m_singleRef );
+ TestCase.assertTrue( comp11.m_multiRef.isEmpty() );
+
+ final SimpleServiceImpl srv2 = SimpleServiceImpl.create( bundleContext, "srv2" );
+ delay(); // async binding
+
+ TestCase.assertEquals( Component.STATE_ACTIVE, component.getState() );
+ final SimpleComponent comp12 = SimpleComponent.INSTANCE;
+ TestCase.assertNotSame( comp10, comp12 );
+ TestCase.assertSame( comp11, comp12 );
+ TestCase.assertNull( comp12.m_singleRef );
+ TestCase.assertTrue( comp12.m_multiRef.isEmpty() );
+
+ component.disable();
+ delay(); // async disabling
+
+ final SimpleServiceImpl srv3 = SimpleServiceImpl.create( bundleContext, "srv3" );
+
+ // enable component with two services available, expect both bind
+ // async enabling
+ component.enable();
+ delay();
+
+ TestCase.assertEquals( Component.STATE_ACTIVE, component.getState() );
+ final SimpleComponent comp20 = SimpleComponent.INSTANCE;
+ TestCase.assertNotNull( comp20 );
+ TestCase.assertNotSame( comp10, comp20 );
+ TestCase.assertNotSame( comp11, comp20 );
+ TestCase.assertNotSame( comp12, comp20 );
+ TestCase.assertNull( comp20.m_singleRef );
+ TestCase.assertTrue( comp20.m_multiRef.contains( srv2 ) );
+ TestCase.assertTrue( comp20.m_multiRef.contains( srv3 ) );
+
+ srv2.drop();
+ delay(); // async reactivate
+
+ TestCase.assertEquals( Component.STATE_ACTIVE, component.getState() );
+ final SimpleComponent comp21 = SimpleComponent.INSTANCE;
+ TestCase.assertNotSame( comp20, comp21 );
+ TestCase.assertNull( comp21.m_singleRef );
+ TestCase.assertFalse( comp21.m_multiRef.contains( srv2 ) );
+ TestCase.assertTrue( comp21.m_multiRef.contains( srv3 ) );
+
+ // create srv4, expect not bind (static case)
+ final SimpleServiceImpl srv4 = SimpleServiceImpl.create( bundleContext, "srv4" );
+ delay();
+
+ TestCase.assertEquals( Component.STATE_ACTIVE, component.getState() );
+ final SimpleComponent comp22 = SimpleComponent.INSTANCE;
+ TestCase.assertNotSame( comp20, comp22 );
+ TestCase.assertSame( comp21, comp22 );
+ TestCase.assertNull( comp22.m_singleRef );
+ TestCase.assertFalse( comp22.m_multiRef.contains( srv2 ) );
+ TestCase.assertTrue( comp22.m_multiRef.contains( srv3 ) );
+ TestCase.assertFalse( comp22.m_multiRef.contains( srv4 ) );
+
+ // drop srv4 again, expect no rebind
+ srv4.drop();
+ delay();
+
+ TestCase.assertEquals( Component.STATE_ACTIVE, component.getState() );
+ final SimpleComponent comp23 = SimpleComponent.INSTANCE;
+ TestCase.assertNotSame( comp20, comp23 );
+ TestCase.assertSame( comp21, comp23 );
+ TestCase.assertSame( comp22, comp23 );
+ TestCase.assertNull( comp23.m_singleRef );
+ TestCase.assertFalse( comp23.m_multiRef.contains( srv2 ) );
+ TestCase.assertTrue( comp23.m_multiRef.contains( srv3 ) );
+ TestCase.assertFalse( comp23.m_multiRef.contains( srv4 ) );
+
+ // "reset"
+ component.disable();
+ srv3.drop();
+ delay();
+
+ // two services with service ranking (srv6 > srv5)
+ final SimpleServiceImpl srv5 = SimpleServiceImpl.create( bundleContext, "srv5", 10 );
+ final SimpleServiceImpl srv6 = SimpleServiceImpl.create( bundleContext, "srv6", 20 );
+
+ component.enable();
+ delay();
+
+ TestCase.assertEquals( Component.STATE_ACTIVE, component.getState() );
+ final SimpleComponent comp30 = SimpleComponent.INSTANCE;
+ TestCase.assertNotSame( comp23, comp30 );
+ TestCase.assertNull( comp30.m_singleRef );
+ TestCase.assertTrue( comp30.m_multiRef.contains( srv5 ) );
+ TestCase.assertTrue( comp30.m_multiRef.contains( srv6 ) );
+
+ // another service with higher ranking -- no rebind !
+ final SimpleServiceImpl srv7 = SimpleServiceImpl.create( bundleContext, "srv7", 30 );
+ delay();
+
+ TestCase.assertEquals( Component.STATE_ACTIVE, component.getState() );
+ final SimpleComponent comp31 = SimpleComponent.INSTANCE;
+ TestCase.assertSame( comp30, comp31 );
+ TestCase.assertNull( comp31.m_singleRef );
+ TestCase.assertTrue( comp31.m_multiRef.contains( srv5 ) );
+ TestCase.assertTrue( comp31.m_multiRef.contains( srv6 ) );
+ TestCase.assertFalse( comp31.m_multiRef.contains( srv7 ) );
+
+ // srv6 goes, rebind to srv7
+ srv6.drop();
+ delay();
+
+ TestCase.assertEquals( Component.STATE_ACTIVE, component.getState() );
+ final SimpleComponent comp32 = SimpleComponent.INSTANCE;
+ TestCase.assertNotSame( comp30, comp32 );
+ TestCase.assertNotSame( comp31, comp32 );
+ TestCase.assertNull( comp32.m_singleRef );
+ TestCase.assertTrue( comp32.m_multiRef.contains( srv5 ) );
+ TestCase.assertFalse( comp32.m_multiRef.contains( srv6 ) );
+ TestCase.assertTrue( comp32.m_multiRef.contains( srv7 ) );
+ }
+
+
+ @Test
+ public void test_required_multiple_static()
+ {
+ final Component component = findComponentByName( "test_required_multiple_static" );
+ TestCase.assertNotNull( component );
+ TestCase.assertEquals( Component.STATE_DISABLED, component.getState() );
+
+ final SimpleServiceImpl srv1 = SimpleServiceImpl.create( bundleContext, "srv1" );
+
+ // async enabling
+ component.enable();
+ delay();
+
+ TestCase.assertEquals( Component.STATE_ACTIVE, component.getState() );
+ final SimpleComponent comp10 = SimpleComponent.INSTANCE;
+ TestCase.assertNotNull( comp10 );
+ TestCase.assertNull( comp10.m_singleRef );
+ TestCase.assertTrue( comp10.m_multiRef.contains( srv1 ) );
+
+ srv1.drop();
+ delay(); // async reactivate
+
+ TestCase.assertEquals( Component.STATE_UNSATISFIED, component.getState() );
+ final SimpleComponent comp11 = SimpleComponent.INSTANCE;
+ TestCase.assertNull( comp11 );
+
+ final SimpleServiceImpl srv2 = SimpleServiceImpl.create( bundleContext, "srv2" );
+ delay(); // async binding
+
+ TestCase.assertEquals( Component.STATE_ACTIVE, component.getState() );
+ final SimpleComponent comp12 = SimpleComponent.INSTANCE;
+ TestCase.assertNotSame( comp10, comp12 );
+ TestCase.assertNull( comp12.m_singleRef );
+ TestCase.assertTrue( comp12.m_multiRef.contains( srv2 ) );
+
+ component.disable();
+ delay(); // async disabling
+
+ final SimpleServiceImpl srv3 = SimpleServiceImpl.create( bundleContext, "srv3" );
+
+ // enable component with two services available, expect both bind
+ // async enabling
+ component.enable();
+ delay();
+
+ TestCase.assertEquals( Component.STATE_ACTIVE, component.getState() );
+ final SimpleComponent comp20 = SimpleComponent.INSTANCE;
+ TestCase.assertNotNull( comp20 );
+ TestCase.assertNotSame( comp10, comp20 );
+ TestCase.assertNotSame( comp12, comp20 );
+ TestCase.assertNull( comp20.m_singleRef );
+ TestCase.assertTrue( comp20.m_multiRef.contains( srv2 ) );
+ TestCase.assertTrue( comp20.m_multiRef.contains( srv3 ) );
+
+ srv2.drop();
+ delay(); // async reactivate
+
+ TestCase.assertEquals( Component.STATE_ACTIVE, component.getState() );
+ final SimpleComponent comp21 = SimpleComponent.INSTANCE;
+ TestCase.assertNotSame( comp20, comp21 );
+ TestCase.assertNull( comp21.m_singleRef );
+ TestCase.assertFalse( comp21.m_multiRef.contains( srv2 ) );
+ TestCase.assertTrue( comp21.m_multiRef.contains( srv3 ) );
+
+ // create srv4, expect bind
+ final SimpleServiceImpl srv4 = SimpleServiceImpl.create( bundleContext, "srv4" );
+ delay();
+
+ TestCase.assertEquals( Component.STATE_ACTIVE, component.getState() );
+ final SimpleComponent comp22 = SimpleComponent.INSTANCE;
+ TestCase.assertNotSame( comp20, comp22 );
+ TestCase.assertSame( comp21, comp22 );
+ TestCase.assertNull( comp22.m_singleRef );
+ TestCase.assertFalse( comp22.m_multiRef.contains( srv2 ) );
+ TestCase.assertTrue( comp22.m_multiRef.contains( srv3 ) );
+ TestCase.assertFalse( comp22.m_multiRef.contains( srv4 ) );
+
+ // drop srv4 again, expect no rebind
+ srv4.drop();
+ delay();
+
+ TestCase.assertEquals( Component.STATE_ACTIVE, component.getState() );
+ final SimpleComponent comp23 = SimpleComponent.INSTANCE;
+ TestCase.assertNotSame( comp20, comp23 );
+ TestCase.assertSame( comp21, comp23 );
+ TestCase.assertSame( comp22, comp23 );
+ TestCase.assertNull( comp23.m_singleRef );
+ TestCase.assertFalse( comp23.m_multiRef.contains( srv2 ) );
+ TestCase.assertTrue( comp23.m_multiRef.contains( srv3 ) );
+ TestCase.assertFalse( comp23.m_multiRef.contains( srv4 ) );
+
+ // "reset"
+ component.disable();
+ srv3.drop();
+ delay();
+
+ // two services with service ranking (srv6 > srv5)
+ final SimpleServiceImpl srv5 = SimpleServiceImpl.create( bundleContext, "srv5", 10 );
+ final SimpleServiceImpl srv6 = SimpleServiceImpl.create( bundleContext, "srv6", 20 );
+
+ component.enable();
+ delay();
+
+ TestCase.assertEquals( Component.STATE_ACTIVE, component.getState() );
+ final SimpleComponent comp30 = SimpleComponent.INSTANCE;
+ TestCase.assertNotSame( comp23, comp30 );
+ TestCase.assertNull( comp30.m_singleRef );
+ TestCase.assertTrue( comp30.m_multiRef.contains( srv5 ) );
+ TestCase.assertTrue( comp30.m_multiRef.contains( srv6 ) );
+
+ // another service with higher ranking -- no rebind !
+ final SimpleServiceImpl srv7 = SimpleServiceImpl.create( bundleContext, "srv7", 30 );
+ delay();
+
+ TestCase.assertEquals( Component.STATE_ACTIVE, component.getState() );
+ final SimpleComponent comp31 = SimpleComponent.INSTANCE;
+ TestCase.assertSame( comp30, comp31 );
+ TestCase.assertNull( comp31.m_singleRef );
+ TestCase.assertTrue( comp31.m_multiRef.contains( srv5 ) );
+ TestCase.assertTrue( comp31.m_multiRef.contains( srv6 ) );
+ TestCase.assertFalse( comp31.m_multiRef.contains( srv7 ) );
+
+ // srv6 goes, rebind to srv7
+ srv6.drop();
+ delay();
+
+ TestCase.assertEquals( Component.STATE_ACTIVE, component.getState() );
+ final SimpleComponent comp32 = SimpleComponent.INSTANCE;
+ TestCase.assertNotSame( comp30, comp32 );
+ TestCase.assertNotSame( comp31, comp32 );
+ TestCase.assertNull( comp32.m_singleRef );
+ TestCase.assertTrue( comp32.m_multiRef.contains( srv5 ) );
+ TestCase.assertFalse( comp32.m_multiRef.contains( srv6 ) );
+ TestCase.assertTrue( comp32.m_multiRef.contains( srv7 ) );
+ }
+}
\ No newline at end of file
Propchange: felix/trunk/scr/src/test/java/org/apache/felix/scr/integration/ServiceBindTest.java
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: felix/trunk/scr/src/test/java/org/apache/felix/scr/integration/ServiceBindTest.java
------------------------------------------------------------------------------
svn:keywords = Author Date Id Revision Rev Url
Modified: felix/trunk/scr/src/test/java/org/apache/felix/scr/integration/components/SimpleComponent.java
URL: http://svn.apache.org/viewvc/felix/trunk/scr/src/test/java/org/apache/felix/scr/integration/components/SimpleComponent.java?rev=807142&r1=807141&r2=807142&view=diff
==============================================================================
--- felix/trunk/scr/src/test/java/org/apache/felix/scr/integration/components/SimpleComponent.java (original)
+++ felix/trunk/scr/src/test/java/org/apache/felix/scr/integration/components/SimpleComponent.java Mon Aug 24 10:37:44 2009
@@ -45,6 +45,10 @@
public ComponentContext m_activateContext;
+ public SimpleService m_singleRef;
+
+ public final Set<SimpleService> m_multiRef = new HashSet<SimpleService>();
+
@SuppressWarnings("unused")
private void activate( ComponentContext activateContext, Map<?, ?> config )
@@ -112,4 +116,35 @@
{
return m_config.get( name );
}
+
+
+ // bind method for single service binding
+ public void setSimpleService( SimpleService simpleService )
+ {
+ this.m_singleRef = simpleService;
+ }
+
+
+ // unbind method for single service binding
+ public void unsetSimpleService( SimpleService simpleService )
+ {
+ if ( this.m_singleRef == simpleService )
+ {
+ this.m_singleRef = null;
+ }
+ }
+
+
+ // bind method for multi-service binding
+ public void bindSimpleService( SimpleService simpleService )
+ {
+ this.m_multiRef.add( simpleService );
+ }
+
+
+ // unbind method for multi-service binding
+ public void unbindSimpleService( SimpleService simpleService )
+ {
+ this.m_multiRef.remove( simpleService );
+ }
}
Added: felix/trunk/scr/src/test/java/org/apache/felix/scr/integration/components/SimpleService.java
URL: http://svn.apache.org/viewvc/felix/trunk/scr/src/test/java/org/apache/felix/scr/integration/components/SimpleService.java?rev=807142&view=auto
==============================================================================
--- felix/trunk/scr/src/test/java/org/apache/felix/scr/integration/components/SimpleService.java (added)
+++ felix/trunk/scr/src/test/java/org/apache/felix/scr/integration/components/SimpleService.java Mon Aug 24 10:37:44 2009
@@ -0,0 +1,26 @@
+/*
+ * 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.felix.scr.integration.components;
+
+
+public interface SimpleService
+{
+
+ String getValue();
+}
Propchange: felix/trunk/scr/src/test/java/org/apache/felix/scr/integration/components/SimpleService.java
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: felix/trunk/scr/src/test/java/org/apache/felix/scr/integration/components/SimpleService.java
------------------------------------------------------------------------------
svn:keywords = Author Date Id Revision Rev Url
Added: felix/trunk/scr/src/test/java/org/apache/felix/scr/integration/components/SimpleServiceImpl.java
URL: http://svn.apache.org/viewvc/felix/trunk/scr/src/test/java/org/apache/felix/scr/integration/components/SimpleServiceImpl.java?rev=807142&view=auto
==============================================================================
--- felix/trunk/scr/src/test/java/org/apache/felix/scr/integration/components/SimpleServiceImpl.java (added)
+++ felix/trunk/scr/src/test/java/org/apache/felix/scr/integration/components/SimpleServiceImpl.java Mon Aug 24 10:37:44 2009
@@ -0,0 +1,91 @@
+/*
+ * 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.felix.scr.integration.components;
+
+
+import java.util.Properties;
+
+import org.osgi.framework.BundleContext;
+import org.osgi.framework.Constants;
+import org.osgi.framework.ServiceRegistration;
+
+
+public class SimpleServiceImpl implements SimpleService
+{
+
+ private final String m_value;
+
+ private ServiceRegistration m_registration;
+
+
+ public static SimpleServiceImpl create( BundleContext bundleContext, String value )
+ {
+ return create( bundleContext, value, 0 );
+ }
+
+
+ public static SimpleServiceImpl create( BundleContext bundleContext, String value, int ranking )
+ {
+ SimpleServiceImpl instance = new SimpleServiceImpl( value );
+ Properties props = new Properties();
+ props.put( "value", value );
+ if ( ranking != 0 )
+ {
+ props.put( Constants.SERVICE_RANKING, Integer.valueOf( ranking ) );
+ }
+ instance.setRegistration( bundleContext.registerService( SimpleService.class.getName(), instance, props ) );
+ return instance;
+ }
+
+
+ SimpleServiceImpl( String value )
+ {
+ this.m_value = value;
+
+ }
+
+
+ public void drop()
+ {
+ ServiceRegistration sr = getRegistration();
+ if ( sr != null )
+ {
+ setRegistration( null );
+ sr.unregister();
+ }
+ }
+
+
+ public String getValue()
+ {
+ return m_value;
+ }
+
+
+ public void setRegistration( ServiceRegistration registration )
+ {
+ m_registration = registration;
+ }
+
+
+ public ServiceRegistration getRegistration()
+ {
+ return m_registration;
+ }
+}
Propchange: felix/trunk/scr/src/test/java/org/apache/felix/scr/integration/components/SimpleServiceImpl.java
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: felix/trunk/scr/src/test/java/org/apache/felix/scr/integration/components/SimpleServiceImpl.java
------------------------------------------------------------------------------
svn:keywords = Author Date Id Revision Rev Url
Added: felix/trunk/scr/src/test/resources/integration_test_simple_components_service_binding.xml
URL: http://svn.apache.org/viewvc/felix/trunk/scr/src/test/resources/integration_test_simple_components_service_binding.xml?rev=807142&view=auto
==============================================================================
--- felix/trunk/scr/src/test/resources/integration_test_simple_components_service_binding.xml (added)
+++ felix/trunk/scr/src/test/resources/integration_test_simple_components_service_binding.xml Mon Aug 24 10:37:44 2009
@@ -0,0 +1,134 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!--
+ 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.
+-->
+<components xmlns:scr="http://www.osgi.org/xmlns/scr/v1.1.0">
+
+ <scr:component name="test_optional_single_dynamic"
+ enabled="false"
+ configuration-policy="ignore">
+ <implementation class="org.apache.felix.scr.integration.components.SimpleComponent" />
+ <reference
+ name="ref"
+ interface="org.apache.felix.scr.integration.components.SimpleService"
+ cardinality="0..1"
+ policy="dynamic"
+ bind="setSimpleService"
+ unbind="unsetSimpleService"
+ />
+ </scr:component>
+
+ <scr:component name="test_required_single_dynamic"
+ enabled="false"
+ configuration-policy="ignore">
+ <implementation class="org.apache.felix.scr.integration.components.SimpleComponent" />
+ <reference
+ name="ref"
+ interface="org.apache.felix.scr.integration.components.SimpleService"
+ cardinality="1..1"
+ policy="dynamic"
+ bind="setSimpleService"
+ unbind="unsetSimpleService"
+ />
+ </scr:component>
+
+ <scr:component name="test_optional_multiple_dynamic"
+ enabled="false"
+ configuration-policy="ignore">
+ <implementation class="org.apache.felix.scr.integration.components.SimpleComponent" />
+ <reference
+ name="ref"
+ interface="org.apache.felix.scr.integration.components.SimpleService"
+ cardinality="0..n"
+ policy="dynamic"
+ bind="bindSimpleService"
+ unbind="unbindSimpleService"
+ />
+ </scr:component>
+
+ <scr:component name="test_required_multiple_dynamic"
+ enabled="false"
+ configuration-policy="ignore">
+ <implementation class="org.apache.felix.scr.integration.components.SimpleComponent" />
+ <reference
+ name="ref"
+ interface="org.apache.felix.scr.integration.components.SimpleService"
+ cardinality="1..n"
+ policy="dynamic"
+ bind="bindSimpleService"
+ unbind="unbindSimpleService"
+ />
+ </scr:component>
+
+ <scr:component name="test_optional_single_static"
+ enabled="false"
+ configuration-policy="ignore">
+ <implementation class="org.apache.felix.scr.integration.components.SimpleComponent" />
+ <reference
+ name="ref"
+ interface="org.apache.felix.scr.integration.components.SimpleService"
+ cardinality="0..1"
+ policy="static"
+ bind="setSimpleService"
+ unbind="unsetSimpleService"
+ />
+ </scr:component>
+
+ <scr:component name="test_required_single_static"
+ enabled="false"
+ configuration-policy="ignore">
+ <implementation class="org.apache.felix.scr.integration.components.SimpleComponent" />
+ <reference
+ name="ref"
+ interface="org.apache.felix.scr.integration.components.SimpleService"
+ cardinality="1..1"
+ policy="static"
+ bind="setSimpleService"
+ unbind="unsetSimpleService"
+ />
+ </scr:component>
+
+ <scr:component name="test_optional_multiple_static"
+ enabled="false"
+ configuration-policy="ignore">
+ <implementation class="org.apache.felix.scr.integration.components.SimpleComponent" />
+ <reference
+ name="ref"
+ interface="org.apache.felix.scr.integration.components.SimpleService"
+ cardinality="0..n"
+ policy="static"
+ bind="bindSimpleService"
+ unbind="unbindSimpleService"
+ />
+ </scr:component>
+
+ <scr:component name="test_required_multiple_static"
+ enabled="false"
+ configuration-policy="ignore">
+ <implementation class="org.apache.felix.scr.integration.components.SimpleComponent" />
+ <reference
+ name="ref"
+ interface="org.apache.felix.scr.integration.components.SimpleService"
+ cardinality="1..n"
+ policy="static"
+ bind="bindSimpleService"
+ unbind="unbindSimpleService"
+ />
+ </scr:component>
+
+</components>
Propchange: felix/trunk/scr/src/test/resources/integration_test_simple_components_service_binding.xml
------------------------------------------------------------------------------
svn:eol-style = native