X-Git-Url: http://wamblee.org/gitweb/?a=blobdiff_plain;f=system%2Fgeneral%2Fsrc%2Fmain%2Fjava%2Forg%2Fwamblee%2Fsystem%2FSystemAssembler.java;h=5cdb3890cc5a3b810345f0dc114b424d143af7e6;hb=0af4854898104bd6322c0f22feb6dc285859f420;hp=561e3f9569ebcf39db1770a5bcda7ee517075e16;hpb=cc58fc5b498c82163904e8ccdc5eed7b96406a65;p=utils diff --git a/system/general/src/main/java/org/wamblee/system/SystemAssembler.java b/system/general/src/main/java/org/wamblee/system/SystemAssembler.java index 561e3f95..5cdb3890 100644 --- a/system/general/src/main/java/org/wamblee/system/SystemAssembler.java +++ b/system/general/src/main/java/org/wamblee/system/SystemAssembler.java @@ -24,28 +24,28 @@ public class SystemAssembler { private String _context; private Component[] _systems; - public static RequiredInterfaceDescriptor[] filterRequiredServices( - ProvidedInterfaceDescriptor aProvided, - Collection aDescriptors) { - List required = new ArrayList(); - for (RequiredInterfaceDescriptor descriptor : aDescriptors) { + public static RequiredInterface[] filterRequiredServices( + ProvidedInterface aProvided, + Collection aDescriptors) { + List required = new ArrayList(); + for (RequiredInterface descriptor : aDescriptors) { if (descriptor.implementedBy(aProvided)) { required.add(descriptor); } } - return required.toArray(new RequiredInterfaceDescriptor[0]); + return required.toArray(new RequiredInterface[0]); } - public static ProvidedInterfaceDescriptor[] filterProvidedServices( - RequiredInterfaceDescriptor aRequired, - Collection aProvided) { - List provided = new ArrayList(); - for (ProvidedInterfaceDescriptor descriptor : aProvided) { + public static ProvidedInterface[] filterProvidedServices( + RequiredInterface aRequired, + Collection aProvided) { + List provided = new ArrayList(); + for (ProvidedInterface descriptor : aProvided) { if (aRequired.implementedBy(descriptor)) { provided.add(descriptor); } } - return provided.toArray(new ProvidedInterfaceDescriptor[0]); + return provided.toArray(new ProvidedInterface[0]); } /** @@ -58,7 +58,7 @@ public class SystemAssembler { * that this assembler manages. */ public SystemAssembler(Component[] aSystems, - ProvidedInterfaceDescriptor[] aAvailableServices) { + ProvidedInterface[] aAvailableServices) { this(ROOT_CONTEXT_NAME, aSystems, aAvailableServices); } @@ -74,7 +74,7 @@ public class SystemAssembler { * that this assembler manages. */ public SystemAssembler(String aContext, Component[] aSystems, - ProvidedInterfaceDescriptor[] aAvailableServices) { + ProvidedInterface[] aAvailableServices) { _context = aContext; _systems = aSystems; validate(aAvailableServices); @@ -84,20 +84,20 @@ public class SystemAssembler { * Determines if the systems are ordered appropriately so that all * dependencies are met. */ - private void validate(ProvidedInterfaceDescriptor[] aDescriptors) + private void validate(ProvidedInterface[] aDescriptors) throws SystemAssemblyException { - List allProvided = new ArrayList(); - for (ProvidedInterfaceDescriptor descriptor : aDescriptors) { + List allProvided = new ArrayList(); + for (ProvidedInterface descriptor : aDescriptors) { allProvided.add(descriptor); } for (Component system : _systems) { // Check if all required services are already provided by earlier // systems. - RequiredInterfaceDescriptor[] required = system.getRequiredServices(); + RequiredInterface[] required = system.getRequiredServices(); - for (RequiredInterfaceDescriptor descriptor : required) { - ProvidedInterfaceDescriptor[] filtered = filterProvidedServices( + for (RequiredInterface descriptor : required) { + ProvidedInterface[] filtered = filterProvidedServices( descriptor, allProvided); if (filtered.length == 0) { @@ -120,7 +120,7 @@ public class SystemAssembler { } // add all provided services - ProvidedInterfaceDescriptor[] provided = system.getProvidedServices(); + ProvidedInterface[] provided = system.getProvidedServices(); allProvided.addAll(Arrays.asList(provided)); } } @@ -136,7 +136,7 @@ public class SystemAssembler { */ public void start(ServiceRegistry aRegistry, Service[] aRequiredServices) { LOG.info("Starting '" + _context + "'"); - Map allProvided = new HashMap(); + Map allProvided = new HashMap(); for (Service service : aRequiredServices) { allProvided.put(service.getDescriptor(), service); @@ -145,11 +145,11 @@ public class SystemAssembler { // Compose a list of the required services required for the subsystem. - RequiredInterfaceDescriptor[] descriptors = system + RequiredInterface[] descriptors = system .getRequiredServices(); List services = new ArrayList(); - for (RequiredInterfaceDescriptor descriptor : descriptors) { - ProvidedInterfaceDescriptor[] provided = filterProvidedServices( + for (RequiredInterface descriptor : descriptors) { + ProvidedInterface[] provided = filterProvidedServices( descriptor, allProvided.keySet()); services.add(allProvided.get(provided[0])); }