deploymentadmin/autoconf/src/main/java/org/apache/felix/deployment/rp/autoconf/AutoConfResourceProcessor.java - onos-felix - Gitiles

 /*
  * 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.deployment.rp.autoconf;

 import java.io.File;
 import java.io.IOException;
 import java.io.InputStream;
 import java.util.ArrayList;
 import java.util.Arrays;
 import java.util.Dictionary;
 import java.util.Enumeration;
 import java.util.HashMap;
 import java.util.Hashtable;
 import java.util.Iterator;
 import java.util.List;
 import java.util.Map;
 import java.util.Set;
 import java.util.Vector;

 import org.apache.felix.metatype.Attribute;
 import org.apache.felix.metatype.Designate;
 import org.apache.felix.metatype.MetaData;
 import org.apache.felix.metatype.MetaDataReader;
 import org.apache.felix.metatype.OCD;
 import org.osgi.framework.Bundle;
 import org.osgi.framework.BundleContext;
 import org.osgi.service.cm.Configuration;
 import org.osgi.service.cm.ConfigurationAdmin;
 import org.osgi.service.deploymentadmin.spi.DeploymentSession;
 import org.osgi.service.deploymentadmin.spi.ResourceProcessor;
 import org.osgi.service.deploymentadmin.spi.ResourceProcessorException;
 import org.osgi.service.log.LogService;
 import org.osgi.service.metatype.AttributeDefinition;
 import org.osgi.service.metatype.MetaTypeInformation;
 import org.osgi.service.metatype.MetaTypeService;
 import org.osgi.service.metatype.ObjectClassDefinition;
 import org.xmlpull.v1.XmlPullParserException;

 public class AutoConfResourceProcessor implements ResourceProcessor {

 	private static final String LOCATION_PREFIX = "osgi-dp:";

 	private volatile LogService m_log;					// injected by dependency manager
 	private volatile ConfigurationAdmin m_configAdmin;	// injected by dependency manager
 	private volatile MetaTypeService m_metaService;		// injected by dependency manager
 	private volatile BundleContext m_bc;				// injected by dependency manager

 	private DeploymentSession m_session = null;
 	private Map m_toBeInstalled = new HashMap(); // Map<String, List<AutoConfResource>>
 	private Map m_toBeDeleted = new HashMap();

 	private PersistencyManager m_persistencyManager;

 	public void start() throws IOException {
 		File root = m_bc.getDataFile("");
 		if (root == null) {
 			throw new IOException("No file system support");
 		}
 		m_persistencyManager = new PersistencyManager(root);
 	}

     public void begin(DeploymentSession session) {
 	    m_session = session;
     }

     public void process(String name, InputStream stream) throws ResourceProcessorException {

 	   // initial validation
 	   if (m_session == null) {
 		   throw new ResourceProcessorException(ResourceProcessorException.CODE_OTHER_ERROR, "Can not process resource without a Deployment Session");
 	   }
 	   MetaDataReader reader = new MetaDataReader();
 	   MetaData data = null;
 	   try {
 		   data = reader.parse(stream);
 	   } catch (IOException e) {
 		   throw new ResourceProcessorException(ResourceProcessorException.CODE_OTHER_ERROR, "Unable to process resource.", e);
 	   } catch (XmlPullParserException e) {
 		   throw new ResourceProcessorException(ResourceProcessorException.CODE_OTHER_ERROR, "Supplied configuration is not conform the metatype xml specification.", e);
 	   }
 	   if (data == null) {
 		   throw new ResourceProcessorException(ResourceProcessorException.CODE_OTHER_ERROR, "Supplied configuration is not conform the metatype xml specification.");
 	   }

 	   // process resources
 	   Map designates = data.getDesignates();
 	   Map localOcds = data.getObjectClassDefinitions();
 	   Iterator i = designates.keySet().iterator();
 	   while (i.hasNext()) {
 		   Designate designate = (Designate) designates.get(i.next());

 		   // determine OCD
 		   ObjectClassDefinition ocd = null;
 		   String ocdRef = designate.getObject().getOcdRef();
 		   OCD localOcd = (OCD) localOcds.get(ocdRef);
 		   // ask meta type service for matching OCD if no local OCD has been defined
 		   ocd = (localOcd != null) ? new ObjectClassDefinitionImpl(localOcd) : getMetaTypeOCD(data, designate);
 		   if (ocd == null) {
 			   throw new ResourceProcessorException(ResourceProcessorException.CODE_OTHER_ERROR, "No Object Class Definition found with id=" + ocdRef);
 		   }

 		   // determine configuration data based on the values and their type definition
 		   Dictionary dict = getProperties(designate, ocd);
 		   if (dict == null) {
 			   // designate does not match it's definition, but was marked optional, ignore it
 			   continue;
 		   }

 		   // add to session data
 		   if (!m_toBeInstalled.containsKey(name)) {
 			   m_toBeInstalled.put(name, new ArrayList());
 		   }
 		   List resources = (List) m_toBeInstalled.get(name);
 		   resources.add(new AutoConfResource(name, designate.getPid(), designate.getFactoryPid(), designate.getBundleLocation(), designate.isMerge(), dict));
 	   }
     }

     public void dropped(String name) throws ResourceProcessorException {
     	if (m_session == null) {
     		throw new ResourceProcessorException(ResourceProcessorException.CODE_OTHER_ERROR, "Can not process resource without a Deployment Session");
     	}
     	try {
     		List resources = m_persistencyManager.load(name);
     		if (!m_toBeDeleted.containsKey(name)) {
     			m_toBeDeleted.put(name, new ArrayList());
     		}
     		((List) m_toBeDeleted.get(name)).addAll(resources);
     	}
     	catch (IOException ioe) {
     		throw new ResourceProcessorException(ResourceProcessorException.CODE_OTHER_ERROR, "Unable to drop resource: " + name, ioe);
     	}
     }

     public void dropAllResources() throws ResourceProcessorException {
     	if (m_session == null) {
     		throw new ResourceProcessorException(ResourceProcessorException.CODE_OTHER_ERROR, "Can not drop all resources without a Deployment Session");
     	}
     	try {
     		Map loadAll = m_persistencyManager.loadAll();
     		for (Iterator i = loadAll.keySet().iterator(); i.hasNext();) {
     			String name = (String) i.next();
     			dropped(name);
     		}
     	}
     	catch (IOException ioe) {
     		throw new ResourceProcessorException(ResourceProcessorException.CODE_OTHER_ERROR, "Unable to drop all resources.", ioe);
     	}

     	File basedir = m_bc.getDataFile("");
     	if (basedir != null && basedir.isDirectory()) {
     		String[] files = basedir.list();
     		for (int i = 0; i < files.length; i++) {
     			dropped(files[i]);
     		}
     	}
     	else {
     		throw new ResourceProcessorException(ResourceProcessorException.CODE_OTHER_ERROR, "Unable to drop resources, data area is not accessible");
     	}
     }

     public void prepare() throws ResourceProcessorException {
     	if (m_session == null) {
     		throw new ResourceProcessorException(ResourceProcessorException.CODE_OTHER_ERROR, "Can not process resource without a Deployment Session");
     	}

     	try {
     		// delete dropped resources
     		for (Iterator i = m_toBeDeleted.keySet().iterator(); i.hasNext();) {
     			String name = (String) i.next();
     			List resources = (List) m_toBeDeleted.get(name);
     			for (Iterator j = resources.iterator(); j.hasNext();) {
     				AutoConfResource resource = (AutoConfResource) j.next();
     				if (resource.isFactoryConfig()) {
     					Configuration configuration = m_configAdmin.getConfiguration(resource.getGeneratedPid(), resource.getBundleLocation());
     					configuration.delete();
     				} else {
     					Configuration configuration = m_configAdmin.getConfiguration(resource.getPid(), resource.getBundleLocation());
     					configuration.delete();
     				}
     			}
     			m_persistencyManager.delete(name);
     		}

     		// install new/updated resources
     		for (Iterator j = m_toBeInstalled.keySet().iterator(); j.hasNext();) {
     			String name = (String) j.next();
     			List existingResources = null;
     			try {
     				existingResources = m_persistencyManager.load(name);
     			} catch (IOException ioe) {
     				throw new ResourceProcessorException(ResourceProcessorException.CODE_PREPARE, "Unable to read existing resources for resource " + name, ioe);
     			}
     			List resources = (List) m_toBeInstalled.get(name);
     			for (Iterator iterator = resources.iterator(); iterator.hasNext();) {
     				AutoConfResource resource = (AutoConfResource) iterator.next();

     				Dictionary properties = resource.getProperties();
     				String bundleLocation = resource.getBundleLocation();
     				Configuration configuration = null;

     				// update configuration
     				if (resource.isFactoryConfig()) {
     					// check if this is an factory config instance update
     					for (Iterator i = existingResources.iterator(); i.hasNext();) {
     						AutoConfResource existingResource = (AutoConfResource) i.next();
     						if (resource.equalsTargetConfiguration(existingResource)) {
     							// existing instance found
     							configuration = m_configAdmin.getConfiguration(existingResource.getGeneratedPid(), bundleLocation);
     							existingResources.remove(existingResource);
     							break;
     						}
     					}
     					if (configuration == null) {
     						// no existing instance, create new
     						configuration = m_configAdmin.createFactoryConfiguration(resource.getFactoryPid(), bundleLocation);
     					}
     					resource.setGeneratedPid(configuration.getPid());
     				}
     				else {
     					for (Iterator i = existingResources.iterator(); i.hasNext();) {
     						AutoConfResource existingResource = (AutoConfResource) i.next();
     						if (resource.getPid().equals(existingResource.getPid())) {
     							// existing resource found
     							existingResources.remove(existingResource);
     							break;
     						}
     					}
     					configuration = m_configAdmin.getConfiguration(resource.getPid(), bundleLocation);
     					if (!bundleLocation.equals(configuration.getBundleLocation())) {
     						// an existing configuration exists that is bound to a different location, which is not allowed
     						throw new ResourceProcessorException(ResourceProcessorException.CODE_PREPARE, "Existing configuration was not unbound and not bound to the specified bundlelocation");
     					}
     				}
     				if (resource.isMerge()) {
     					Dictionary existingProperties = configuration.getProperties();
     					if (existingProperties != null) {
     						Enumeration keys = existingProperties.keys();
     						while (keys.hasMoreElements()) {
     							Object key = keys.nextElement();
     							properties.put(key, existingProperties.get(key));
     						}
     					}
     				}
     				configuration.update(properties);
     			}

     			// remove existing configurations that were not in the new version of the resource
     			for (Iterator i = existingResources.iterator(); i.hasNext();) {
     				AutoConfResource existingResource = (AutoConfResource) i.next();
     				Configuration configuration = null;
     				if (existingResource.isFactoryConfig()) {
     					configuration = m_configAdmin.getConfiguration(existingResource.getGeneratedPid(), existingResource.getBundleLocation());
     				} else {
     					configuration = m_configAdmin.getConfiguration(existingResource.getPid(), existingResource.getBundleLocation());
     				}
     				configuration.delete();
     			}
     			m_persistencyManager.store(name, resources);
     		}
     	}
     	catch (IOException ioe) {
     		m_toBeInstalled.clear();
     		throw new ResourceProcessorException(ResourceProcessorException.CODE_PREPARE, "Unable to prepare for commit for resource", ioe);
     	}
     }

     public synchronized void commit() {
     	m_toBeInstalled.clear();
     	m_toBeDeleted.clear();
     	m_session = null;
     }

     public void rollback() {
     	Set keys = m_toBeInstalled.keySet();
     	for (Iterator i = keys.iterator(); i.hasNext();) {
     		List configs = (List) m_toBeInstalled.get(i.next());
     		for (Iterator j = configs.iterator(); j.hasNext();) {
     			AutoConfResource resource = (AutoConfResource) j.next();
     			String name = resource.getName();
     			try {
     				dropped(name);
     			} catch (ResourceProcessorException e) {
     				m_log.log(LogService.LOG_ERROR, "Unable to roll back resource '" + name + "', reason: " + e.getMessage() + ", caused by: " + e.getCause().getMessage());
     			}
     			break;
     		}
     	}
     	m_toBeInstalled.clear();
     	m_session = null;
     }

     public void cancel() {
     	rollback();
     	m_session = null;
     }

     /**
      * Determines the actual configuration data based on the specified designate and object class definition
      *
      * @param designate The designate object containing the values for the properties
      * @param ocd The object class definition
      * @return A dictionary containing data as described in the designate and ocd objects, or <code>null</code> if the designate does not match it's
      * definition and the designate was marked as optional.
      * @throws ResourceProcessorException If the designate does not match the ocd and the designate is not marked as optional.
      */
     private Dictionary getProperties(Designate designate, ObjectClassDefinition ocd) throws ResourceProcessorException {
     	Dictionary properties = new Hashtable();
     	AttributeDefinition[] attributeDefs = ocd.getAttributeDefinitions(ObjectClassDefinition.ALL);
     	List attributes = designate.getObject().getAttributes();

     	for (Iterator i = attributes.iterator(); i.hasNext();) {
     		Attribute attribute = (Attribute) i.next();

     		String adRef = attribute.getAdRef();
     		boolean found = false;
     		for(int j = 0; j < attributeDefs.length; j++) {
     			AttributeDefinition ad = attributeDefs[j];
     			if (adRef.equals(ad.getID())) {
     				// found attribute definition
     				Object value = getValue(attribute, ad);
     				if (value == null) {
     					if (designate.isOptional()) {
     						properties = null;
     						break;
     					}
     					else {
     						throw new ResourceProcessorException(ResourceProcessorException.CODE_OTHER_ERROR, "Could not match attribute to it's definition: adref=" + adRef);
     					}
     				}
     				properties.put(adRef, value);
     				found = true;
     				break;
     			}
     		}
     		if (!found) {
     			if (designate.isOptional()) {
     				properties = null;
     				break;
     			} else {
     				throw new ResourceProcessorException(ResourceProcessorException.CODE_OTHER_ERROR, "Could not find attribute definition: adref=" + adRef);
     			}
     		}
     	}

     	return properties;
     }

     /**
      * Determines the object class definition matching the specified designate.
      *
      * @param data The meta data containing 'local' object class definitions.
      * @param designate The designate whose object class definition should be determined.
      * @return
      * @throws ResourceProcessorException
      */
     private ObjectClassDefinition getMetaTypeOCD(MetaData data, Designate designate) throws ResourceProcessorException {
     	ObjectClassDefinition ocd = null;
     	String ocdRef = designate.getObject().getOcdRef();
     	Bundle bundle = getBundle(designate.getBundleLocation(), isFactoryConfig(designate));
     	if (bundle != null) {
     		MetaTypeInformation mti = m_metaService.getMetaTypeInformation(bundle);
     		if (mti != null) {
     			String pid = isFactoryConfig(designate) ? pid = designate.getFactoryPid() : designate.getPid();
     			try {
     				ObjectClassDefinition tempOcd = mti.getObjectClassDefinition(pid, null);
     				// tempOcd will always have a value, if pid was not known IAE will be thrown
     				if (ocdRef.equals(tempOcd.getID())) {
     					ocd = tempOcd;
     				}
     			}
     			catch (IllegalArgumentException iae) {
     				// let null be returned
     			}
     		}
     	}
     	return ocd;
     }

     private boolean isFactoryConfig(Designate designate) {
     	String factoryPid = designate.getFactoryPid();
     	return (factoryPid != null || !"".equals(factoryPid));
     }

     private Bundle getBundle(String bundleLocation, boolean isFactory) throws ResourceProcessorException {
     	Bundle bundle = null;
     	if (!isFactory) {
     		// singleton configuration, no foreign bundles allowed, use source deployment package to find specified bundle
     		if (bundleLocation.startsWith(LOCATION_PREFIX)) {
     			bundle = m_session.getSourceDeploymentPackage().getBundle(bundleLocation.substring(LOCATION_PREFIX.length()));
     		}
     	}
     	else {
     		// factory configuration, foreign bundles allowed, use bundle context to find the specified bundle
     		Bundle[] bundles = m_bc.getBundles();
     		for (int i = 0; i < bundles.length; i++) {
     			String location = bundles[i].getLocation();
     			if (bundleLocation.equals(location)) {
     				bundle = bundles[i];
     				break;
     			}
     		}
     	}
     	return bundle;
     }

     /**
      * Determines the value of an attribute based on an attribute definition
      *
      * @param attribute The attribute containing value(s)
      * @param ad The attribute definition
      * @return An <code>Object</code> reflecting what was specified in the attribute and it's definition or <code>null</code> if
      * the value did not match it's definition.
      */
     private Object getValue(Attribute attribute, AttributeDefinition ad) {
     	if (attribute == null || ad == null || !attribute.getAdRef().equals(ad.getID())) {
     		// wrong attribute or definition
     		return null;
     	}
     	String[] content = attribute.getContent();

     	// verify correct type of the value(s)
     	int type = ad.getType();
     	Object[] typedContent = null;
     	try {
     		for (int i = 0; i < content.length; i++) {
     			String value = content[i];
     			switch (type) {
     			case AttributeDefinition.BOOLEAN:
     				typedContent = (typedContent == null) ? new Boolean[content.length] : typedContent;
     				typedContent[i] = Boolean.valueOf(value);
     				break;
     			case AttributeDefinition.BYTE:
     				typedContent = (typedContent == null) ? new Byte[content.length] : typedContent;
     				typedContent[i] = Byte.valueOf(value);
     				break;
     			case AttributeDefinition.CHARACTER:
     				typedContent = (typedContent == null) ? new Character[content.length] : typedContent;
     				char[] charArray = value.toCharArray();
     				if (charArray.length == 1) {
     					typedContent[i] = new Character(charArray[0]);
     				}
     				else {
     					return null;
     				}
     				break;
     			case AttributeDefinition.DOUBLE:
     				typedContent = (typedContent == null) ? new Double[content.length] : typedContent;
     				typedContent[i] = Double.valueOf(value);
     				break;
     			case AttributeDefinition.FLOAT:
     				typedContent = (typedContent == null) ? new Float[content.length] : typedContent;
     				typedContent[i] = Float.valueOf(value);
     				break;
     			case AttributeDefinition.INTEGER:
     				typedContent = (typedContent == null) ? new Integer[content.length] : typedContent;
     				typedContent[i] = Integer.valueOf(value);
     				break;
     			case AttributeDefinition.LONG:
     				typedContent = (typedContent == null) ? new Long[content.length] : typedContent;
     				typedContent[i] = Long.valueOf(value);
     				break;
     			case AttributeDefinition.SHORT:
     				typedContent = (typedContent == null) ? new Short[content.length] : typedContent;
     				typedContent[i] = Short.valueOf(value);
     				break;
     			case AttributeDefinition.STRING:
     				typedContent = (typedContent == null) ? new String[content.length] : typedContent;
     				typedContent[i] = value;
     				break;
     			default:
     				// unsupported type
     				return null;
     			}
     		}
     	}
     	catch (NumberFormatException nfe) {
     		return null;
     	}

     	// verify cardinality of value(s)
     	int cardinality = ad.getCardinality();
     	Object result = null;
     	if (cardinality == 0) {
     		if (typedContent.length == 1) {
     			result = typedContent[0];
     		}
     		else {
     			result = null;
     		}
     	}
     	else if (cardinality == Integer.MIN_VALUE) {
     		result = new Vector(Arrays.asList(typedContent));
     	}
     	else if (cardinality == Integer.MAX_VALUE) {
     		result = typedContent;
     	}
     	else if (cardinality < 0) {
     		if (typedContent.length == cardinality) {
     			result = new Vector(Arrays.asList(typedContent));
     		}
     		else {
     			result = null;
     		}
     	}
     	else if (cardinality > 0) {
     		if (typedContent.length == cardinality) {
     			result = typedContent;
     		}
     		else {
     			result = null;
     		}
     	}
     	return result;
     }
 }
	/*
	* 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.deployment.rp.autoconf;

	import java.io.File;
	import java.io.IOException;
	import java.io.InputStream;
	import java.util.ArrayList;
	import java.util.Arrays;
	import java.util.Dictionary;
	import java.util.Enumeration;
	import java.util.HashMap;
	import java.util.Hashtable;
	import java.util.Iterator;
	import java.util.List;
	import java.util.Map;
	import java.util.Set;
	import java.util.Vector;

	import org.apache.felix.metatype.Attribute;
	import org.apache.felix.metatype.Designate;
	import org.apache.felix.metatype.MetaData;
	import org.apache.felix.metatype.MetaDataReader;
	import org.apache.felix.metatype.OCD;
	import org.osgi.framework.Bundle;
	import org.osgi.framework.BundleContext;
	import org.osgi.service.cm.Configuration;
	import org.osgi.service.cm.ConfigurationAdmin;
	import org.osgi.service.deploymentadmin.spi.DeploymentSession;
	import org.osgi.service.deploymentadmin.spi.ResourceProcessor;
	import org.osgi.service.deploymentadmin.spi.ResourceProcessorException;
	import org.osgi.service.log.LogService;
	import org.osgi.service.metatype.AttributeDefinition;
	import org.osgi.service.metatype.MetaTypeInformation;
	import org.osgi.service.metatype.MetaTypeService;
	import org.osgi.service.metatype.ObjectClassDefinition;
	import org.xmlpull.v1.XmlPullParserException;

	public class AutoConfResourceProcessor implements ResourceProcessor {

	private static final String LOCATION_PREFIX = "osgi-dp:";

	private volatile LogService m_log; // injected by dependency manager
	private volatile ConfigurationAdmin m_configAdmin; // injected by dependency manager
	private volatile MetaTypeService m_metaService; // injected by dependency manager
	private volatile BundleContext m_bc; // injected by dependency manager

	private DeploymentSession m_session = null;
	private Map m_toBeInstalled = new HashMap(); // Map<String, List<AutoConfResource>>
	private Map m_toBeDeleted = new HashMap();

	private PersistencyManager m_persistencyManager;

	public void start() throws IOException {
	File root = m_bc.getDataFile("");
	if (root == null) {
	throw new IOException("No file system support");
	}
	m_persistencyManager = new PersistencyManager(root);
	}

	public void begin(DeploymentSession session) {
	m_session = session;
	}

	public void process(String name, InputStream stream) throws ResourceProcessorException {

	// initial validation
	if (m_session == null) {
	throw new ResourceProcessorException(ResourceProcessorException.CODE_OTHER_ERROR, "Can not process resource without a Deployment Session");
	}
	MetaDataReader reader = new MetaDataReader();
	MetaData data = null;
	try {
	data = reader.parse(stream);
	} catch (IOException e) {
	throw new ResourceProcessorException(ResourceProcessorException.CODE_OTHER_ERROR, "Unable to process resource.", e);
	} catch (XmlPullParserException e) {
	throw new ResourceProcessorException(ResourceProcessorException.CODE_OTHER_ERROR, "Supplied configuration is not conform the metatype xml specification.", e);
	}
	if (data == null) {
	throw new ResourceProcessorException(ResourceProcessorException.CODE_OTHER_ERROR, "Supplied configuration is not conform the metatype xml specification.");
	}

	// process resources
	Map designates = data.getDesignates();
	Map localOcds = data.getObjectClassDefinitions();
	Iterator i = designates.keySet().iterator();
	while (i.hasNext()) {
	Designate designate = (Designate) designates.get(i.next());

	// determine OCD
	ObjectClassDefinition ocd = null;
	String ocdRef = designate.getObject().getOcdRef();
	OCD localOcd = (OCD) localOcds.get(ocdRef);
	// ask meta type service for matching OCD if no local OCD has been defined
	ocd = (localOcd != null) ? new ObjectClassDefinitionImpl(localOcd) : getMetaTypeOCD(data, designate);
	if (ocd == null) {
	throw new ResourceProcessorException(ResourceProcessorException.CODE_OTHER_ERROR, "No Object Class Definition found with id=" + ocdRef);
	}

	// determine configuration data based on the values and their type definition
	Dictionary dict = getProperties(designate, ocd);
	if (dict == null) {
	// designate does not match it's definition, but was marked optional, ignore it
	continue;
	}

	// add to session data
	if (!m_toBeInstalled.containsKey(name)) {
	m_toBeInstalled.put(name, new ArrayList());
	}
	List resources = (List) m_toBeInstalled.get(name);
	resources.add(new AutoConfResource(name, designate.getPid(), designate.getFactoryPid(), designate.getBundleLocation(), designate.isMerge(), dict));
	}
	}

	public void dropped(String name) throws ResourceProcessorException {
	if (m_session == null) {
	throw new ResourceProcessorException(ResourceProcessorException.CODE_OTHER_ERROR, "Can not process resource without a Deployment Session");
	}
	try {
	List resources = m_persistencyManager.load(name);
	if (!m_toBeDeleted.containsKey(name)) {
	m_toBeDeleted.put(name, new ArrayList());
	}
	((List) m_toBeDeleted.get(name)).addAll(resources);
	}
	catch (IOException ioe) {
	throw new ResourceProcessorException(ResourceProcessorException.CODE_OTHER_ERROR, "Unable to drop resource: " + name, ioe);
	}
	}

	public void dropAllResources() throws ResourceProcessorException {
	if (m_session == null) {
	throw new ResourceProcessorException(ResourceProcessorException.CODE_OTHER_ERROR, "Can not drop all resources without a Deployment Session");
	}
	try {
	Map loadAll = m_persistencyManager.loadAll();
	for (Iterator i = loadAll.keySet().iterator(); i.hasNext();) {
	String name = (String) i.next();
	dropped(name);
	}
	}
	catch (IOException ioe) {
	throw new ResourceProcessorException(ResourceProcessorException.CODE_OTHER_ERROR, "Unable to drop all resources.", ioe);
	}

	File basedir = m_bc.getDataFile("");
	if (basedir != null && basedir.isDirectory()) {
	String[] files = basedir.list();
	for (int i = 0; i < files.length; i++) {
	dropped(files[i]);
	}
	}
	else {
	throw new ResourceProcessorException(ResourceProcessorException.CODE_OTHER_ERROR, "Unable to drop resources, data area is not accessible");
	}
	}

	public void prepare() throws ResourceProcessorException {
	if (m_session == null) {
	throw new ResourceProcessorException(ResourceProcessorException.CODE_OTHER_ERROR, "Can not process resource without a Deployment Session");
	}

	try {
	// delete dropped resources
	for (Iterator i = m_toBeDeleted.keySet().iterator(); i.hasNext();) {
	String name = (String) i.next();
	List resources = (List) m_toBeDeleted.get(name);
	for (Iterator j = resources.iterator(); j.hasNext();) {
	AutoConfResource resource = (AutoConfResource) j.next();
	if (resource.isFactoryConfig()) {
	Configuration configuration = m_configAdmin.getConfiguration(resource.getGeneratedPid(), resource.getBundleLocation());
	configuration.delete();
	} else {
	Configuration configuration = m_configAdmin.getConfiguration(resource.getPid(), resource.getBundleLocation());
	configuration.delete();
	}
	}
	m_persistencyManager.delete(name);
	}

	// install new/updated resources
	for (Iterator j = m_toBeInstalled.keySet().iterator(); j.hasNext();) {
	String name = (String) j.next();
	List existingResources = null;
	try {
	existingResources = m_persistencyManager.load(name);
	} catch (IOException ioe) {
	throw new ResourceProcessorException(ResourceProcessorException.CODE_PREPARE, "Unable to read existing resources for resource " + name, ioe);
	}
	List resources = (List) m_toBeInstalled.get(name);
	for (Iterator iterator = resources.iterator(); iterator.hasNext();) {
	AutoConfResource resource = (AutoConfResource) iterator.next();

	Dictionary properties = resource.getProperties();
	String bundleLocation = resource.getBundleLocation();
	Configuration configuration = null;

	// update configuration
	if (resource.isFactoryConfig()) {
	// check if this is an factory config instance update
	for (Iterator i = existingResources.iterator(); i.hasNext();) {
	AutoConfResource existingResource = (AutoConfResource) i.next();
	if (resource.equalsTargetConfiguration(existingResource)) {
	// existing instance found
	configuration = m_configAdmin.getConfiguration(existingResource.getGeneratedPid(), bundleLocation);
	existingResources.remove(existingResource);
	break;
	}
	}
	if (configuration == null) {
	// no existing instance, create new
	configuration = m_configAdmin.createFactoryConfiguration(resource.getFactoryPid(), bundleLocation);
	}
	resource.setGeneratedPid(configuration.getPid());
	}
	else {
	for (Iterator i = existingResources.iterator(); i.hasNext();) {
	AutoConfResource existingResource = (AutoConfResource) i.next();
	if (resource.getPid().equals(existingResource.getPid())) {
	// existing resource found
	existingResources.remove(existingResource);
	break;
	}
	}
	configuration = m_configAdmin.getConfiguration(resource.getPid(), bundleLocation);
	if (!bundleLocation.equals(configuration.getBundleLocation())) {
	// an existing configuration exists that is bound to a different location, which is not allowed
	throw new ResourceProcessorException(ResourceProcessorException.CODE_PREPARE, "Existing configuration was not unbound and not bound to the specified bundlelocation");
	}
	}
	if (resource.isMerge()) {
	Dictionary existingProperties = configuration.getProperties();
	if (existingProperties != null) {
	Enumeration keys = existingProperties.keys();
	while (keys.hasMoreElements()) {
	Object key = keys.nextElement();
	properties.put(key, existingProperties.get(key));
	}
	}
	}
	configuration.update(properties);
	}

	// remove existing configurations that were not in the new version of the resource
	for (Iterator i = existingResources.iterator(); i.hasNext();) {
	AutoConfResource existingResource = (AutoConfResource) i.next();
	Configuration configuration = null;
	if (existingResource.isFactoryConfig()) {
	configuration = m_configAdmin.getConfiguration(existingResource.getGeneratedPid(), existingResource.getBundleLocation());
	} else {
	configuration = m_configAdmin.getConfiguration(existingResource.getPid(), existingResource.getBundleLocation());
	}
	configuration.delete();
	}
	m_persistencyManager.store(name, resources);
	}
	}
	catch (IOException ioe) {
	m_toBeInstalled.clear();
	throw new ResourceProcessorException(ResourceProcessorException.CODE_PREPARE, "Unable to prepare for commit for resource", ioe);
	}
	}

	public synchronized void commit() {
	m_toBeInstalled.clear();
	m_toBeDeleted.clear();
	m_session = null;
	}

	public void rollback() {
	Set keys = m_toBeInstalled.keySet();
	for (Iterator i = keys.iterator(); i.hasNext();) {
	List configs = (List) m_toBeInstalled.get(i.next());
	for (Iterator j = configs.iterator(); j.hasNext();) {
	AutoConfResource resource = (AutoConfResource) j.next();
	String name = resource.getName();
	try {
	dropped(name);
	} catch (ResourceProcessorException e) {
	m_log.log(LogService.LOG_ERROR, "Unable to roll back resource '" + name + "', reason: " + e.getMessage() + ", caused by: " + e.getCause().getMessage());
	}
	break;
	}
	}
	m_toBeInstalled.clear();
	m_session = null;
	}

	public void cancel() {
	rollback();
	m_session = null;
	}

	/**
	* Determines the actual configuration data based on the specified designate and object class definition
	*
	* @param designate The designate object containing the values for the properties
	* @param ocd The object class definition
	* @return A dictionary containing data as described in the designate and ocd objects, or <code>null</code> if the designate does not match it's
	* definition and the designate was marked as optional.
	* @throws ResourceProcessorException If the designate does not match the ocd and the designate is not marked as optional.
	*/
	private Dictionary getProperties(Designate designate, ObjectClassDefinition ocd) throws ResourceProcessorException {
	Dictionary properties = new Hashtable();
	AttributeDefinition[] attributeDefs = ocd.getAttributeDefinitions(ObjectClassDefinition.ALL);
	List attributes = designate.getObject().getAttributes();

	for (Iterator i = attributes.iterator(); i.hasNext();) {
	Attribute attribute = (Attribute) i.next();

	String adRef = attribute.getAdRef();
	boolean found = false;
	for(int j = 0; j < attributeDefs.length; j++) {
	AttributeDefinition ad = attributeDefs[j];
	if (adRef.equals(ad.getID())) {
	// found attribute definition
	Object value = getValue(attribute, ad);
	if (value == null) {
	if (designate.isOptional()) {
	properties = null;
	break;
	}
	else {
	throw new ResourceProcessorException(ResourceProcessorException.CODE_OTHER_ERROR, "Could not match attribute to it's definition: adref=" + adRef);
	}
	}
	properties.put(adRef, value);
	found = true;
	break;
	}
	}
	if (!found) {
	if (designate.isOptional()) {
	properties = null;
	break;
	} else {
	throw new ResourceProcessorException(ResourceProcessorException.CODE_OTHER_ERROR, "Could not find attribute definition: adref=" + adRef);
	}
	}
	}

	return properties;
	}

	/**
	* Determines the object class definition matching the specified designate.
	*
	* @param data The meta data containing 'local' object class definitions.
	* @param designate The designate whose object class definition should be determined.
	* @return
	* @throws ResourceProcessorException
	*/
	private ObjectClassDefinition getMetaTypeOCD(MetaData data, Designate designate) throws ResourceProcessorException {
	ObjectClassDefinition ocd = null;
	String ocdRef = designate.getObject().getOcdRef();
	Bundle bundle = getBundle(designate.getBundleLocation(), isFactoryConfig(designate));
	if (bundle != null) {
	MetaTypeInformation mti = m_metaService.getMetaTypeInformation(bundle);
	if (mti != null) {
	String pid = isFactoryConfig(designate) ? pid = designate.getFactoryPid() : designate.getPid();
	try {
	ObjectClassDefinition tempOcd = mti.getObjectClassDefinition(pid, null);
	// tempOcd will always have a value, if pid was not known IAE will be thrown
	if (ocdRef.equals(tempOcd.getID())) {
	ocd = tempOcd;
	}
	}
	catch (IllegalArgumentException iae) {
	// let null be returned
	}
	}
	}
	return ocd;
	}

	private boolean isFactoryConfig(Designate designate) {
	String factoryPid = designate.getFactoryPid();
	return (factoryPid != null \|\| !"".equals(factoryPid));
	}

	private Bundle getBundle(String bundleLocation, boolean isFactory) throws ResourceProcessorException {
	Bundle bundle = null;
	if (!isFactory) {
	// singleton configuration, no foreign bundles allowed, use source deployment package to find specified bundle
	if (bundleLocation.startsWith(LOCATION_PREFIX)) {
	bundle = m_session.getSourceDeploymentPackage().getBundle(bundleLocation.substring(LOCATION_PREFIX.length()));
	}
	}
	else {
	// factory configuration, foreign bundles allowed, use bundle context to find the specified bundle
	Bundle[] bundles = m_bc.getBundles();
	for (int i = 0; i < bundles.length; i++) {
	String location = bundles[i].getLocation();
	if (bundleLocation.equals(location)) {
	bundle = bundles[i];
	break;
	}
	}
	}
	return bundle;
	}

	/**
	* Determines the value of an attribute based on an attribute definition
	*
	* @param attribute The attribute containing value(s)
	* @param ad The attribute definition
	* @return An <code>Object</code> reflecting what was specified in the attribute and it's definition or <code>null</code> if
	* the value did not match it's definition.
	*/
	private Object getValue(Attribute attribute, AttributeDefinition ad) {
	if (attribute == null \|\| ad == null \|\| !attribute.getAdRef().equals(ad.getID())) {
	// wrong attribute or definition
	return null;
	}
	String[] content = attribute.getContent();

	// verify correct type of the value(s)
	int type = ad.getType();
	Object[] typedContent = null;
	try {
	for (int i = 0; i < content.length; i++) {
	String value = content[i];
	switch (type) {
	case AttributeDefinition.BOOLEAN:
	typedContent = (typedContent == null) ? new Boolean[content.length] : typedContent;
	typedContent[i] = Boolean.valueOf(value);
	break;
	case AttributeDefinition.BYTE:
	typedContent = (typedContent == null) ? new Byte[content.length] : typedContent;
	typedContent[i] = Byte.valueOf(value);
	break;
	case AttributeDefinition.CHARACTER:
	typedContent = (typedContent == null) ? new Character[content.length] : typedContent;
	char[] charArray = value.toCharArray();
	if (charArray.length == 1) {
	typedContent[i] = new Character(charArray[0]);
	}
	else {
	return null;
	}
	break;
	case AttributeDefinition.DOUBLE:
	typedContent = (typedContent == null) ? new Double[content.length] : typedContent;
	typedContent[i] = Double.valueOf(value);
	break;
	case AttributeDefinition.FLOAT:
	typedContent = (typedContent == null) ? new Float[content.length] : typedContent;
	typedContent[i] = Float.valueOf(value);
	break;
	case AttributeDefinition.INTEGER:
	typedContent = (typedContent == null) ? new Integer[content.length] : typedContent;
	typedContent[i] = Integer.valueOf(value);
	break;
	case AttributeDefinition.LONG:
	typedContent = (typedContent == null) ? new Long[content.length] : typedContent;
	typedContent[i] = Long.valueOf(value);
	break;
	case AttributeDefinition.SHORT:
	typedContent = (typedContent == null) ? new Short[content.length] : typedContent;
	typedContent[i] = Short.valueOf(value);
	break;
	case AttributeDefinition.STRING:
	typedContent = (typedContent == null) ? new String[content.length] : typedContent;
	typedContent[i] = value;
	break;
	default:
	// unsupported type
	return null;
	}
	}
	}
	catch (NumberFormatException nfe) {
	return null;
	}

	// verify cardinality of value(s)
	int cardinality = ad.getCardinality();
	Object result = null;
	if (cardinality == 0) {
	if (typedContent.length == 1) {
	result = typedContent[0];
	}
	else {
	result = null;
	}
	}
	else if (cardinality == Integer.MIN_VALUE) {
	result = new Vector(Arrays.asList(typedContent));
	}
	else if (cardinality == Integer.MAX_VALUE) {
	result = typedContent;
	}
	else if (cardinality < 0) {
	if (typedContent.length == cardinality) {
	result = new Vector(Arrays.asList(typedContent));
	}
	else {
	result = null;
	}
	}
	else if (cardinality > 0) {
	if (typedContent.length == cardinality) {
	result = typedContent;
	}
	else {
	result = null;
	}
	}
	return result;
	}
	}