X-Git-Url: http://wamblee.org/gitweb/?a=blobdiff_plain;f=system%2Fgeneral%2Fsrc%2Fmain%2Fjava%2Forg%2Fwamblee%2Fsystem%2FContainer.java;h=bd059902d5f2a5995c5bfe6cf283fbe95f315536;hb=66cabd44d9f89e5f07cd04190ac0566dfcb26731;hp=d9dc29be471126bdfeba4f818c4b2e859e5d6ff4;hpb=6a914dcbd1c89027eafae6021af4199a636e4e48;p=utils

diff --git a/system/general/src/main/java/org/wamblee/system/Container.java b/system/general/src/main/java/org/wamblee/system/Container.java
index d9dc29be..bd059902 100644
--- a/system/general/src/main/java/org/wamblee/system/Container.java
+++ b/system/general/src/main/java/org/wamblee/system/Container.java
@@ -1,14 +1,30 @@
+/*
+ * Copyright 2007 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.system;
 
 import java.util.ArrayList;
 import java.util.Arrays;
+import java.util.Collection;
+import java.util.HashSet;
 import java.util.List;
+import java.util.Set;
 
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
 
-import sun.util.LocaleServiceProviderPool.LocalizedObjectGetter;
-
 /**
  * Composite system consisting of multiple subsystems. 
  *
@@ -20,6 +36,30 @@ public class Container extends AbstractComponent {
 
 	private Component[] _systems;
 
+	public static RequiredInterface[] filterRequiredServices(
+			ProvidedInterface aProvided,
+			Collection<RequiredInterface> aDescriptors) {
+		List<RequiredInterface> required = new ArrayList<RequiredInterface>();
+		for (RequiredInterface descriptor : aDescriptors) {
+			if (descriptor.implementedBy(aProvided)) {
+				required.add(descriptor);
+			}
+		}
+		return required.toArray(new RequiredInterface[0]);
+	}
+
+	public static ProvidedInterface[] filterProvidedServices(
+			RequiredInterface aRequired,
+			Collection<ProvidedInterface> aProvided) {
+		List<ProvidedInterface> provided = new ArrayList<ProvidedInterface>();
+		for (ProvidedInterface descriptor : aProvided) {
+			if (aRequired.implementedBy(descriptor)) {
+				provided.add(descriptor);
+			}
+		}
+		return provided.toArray(new ProvidedInterface[0]);
+	}
+	
 	/**
 	 * Construcst the composite system. 
 	 * @param aName Name of the system. 
@@ -72,7 +112,7 @@ public class Container extends AbstractComponent {
 		// Compute all required interfaces that are not provided
 		for (ProvidedInterface service : provided) {
 			List<RequiredInterface> fulfilled = 
-				Arrays.asList(SystemAssembler.filterRequiredServices(service, 
+				Arrays.asList(filterRequiredServices(service, 
 					reallyRequired));
 			reallyRequired.removeAll(fulfilled); 
 		}
@@ -104,11 +144,65 @@ public class Container extends AbstractComponent {
 			provided.add(intf.getProvider());
 		}
 		
-		SystemAssembler assembler = new SystemAssembler( _systems, 
-				provided.toArray(new ProvidedInterface[0]));
-		assembler.start();
+		startImpl();
 	}
 	
+	/**
+	 * Starts the subsystems.
+	 * 
+	 * @param aRequiredServices
+	 *            Services that are available from other systems that have been
+	 *            started before.
+	 */
+	private void startImpl() {
+		LOG.info("Starting '" + "'");
+		List<ProvidedInterface> allProvided = new ArrayList<ProvidedInterface>();
+		
+		// Add the provides of all externally required interfaces to the list of available
+		// interfaces
+		for (RequiredInterface required: getRequiredServices()) { 
+			allProvided.add(required.getProvider());
+		}
+		
+		for (Component system : _systems) {
+			// Check if all required services are already provided by earlier
+			// systems.
+			RequiredInterface[] required = system.getRequiredServices();
+
+			for (RequiredInterface descriptor : required) {
+				ProvidedInterface[] filtered = filterProvidedServices(
+						descriptor, allProvided);
+
+				if (filtered.length == 0) {
+					throw new SystemAssemblyException(
+							"Service '"
+									+ descriptor
+									+ "' required by system '"
+									+ system
+									+ "' is not provided by systems that are started earlier");
+				}
+				if (filtered.length > 1) {
+					throw new SystemAssemblyException(
+							"Service '"
+									+ descriptor
+									+ "' required by system '"
+									+ system
+									+ "' matches multiple services provided by other systems: " + 
+									Arrays.asList(filtered));
+				}
+				descriptor.setProvider(filtered[0]);
+			}
+			
+			// Start the service. 
+			system.start(getQualifiedName());
+
+			// add all provided services
+			ProvidedInterface[] provided = system.getProvidedServices();
+			allProvided.addAll(Arrays.asList(provided));
+		}
+	}
+
+	
 	@Override
 	protected void doStop() {
 		for (int i = _systems.length-1; i >= 0; i--) {