Start line:  
End line:  

Snippet Preview

Snippet HTML Code

Stack Overflow Questions
Copyright (c) 2006, 2010 Cognos Incorporated, IBM Corporation and others. All rights reserved. This program and the accompanying materials are made available under the terms of the Eclipse Public License v1.0 which accompanies this distribution, and is available at http://www.eclipse.org/legal/epl-v10.html /
  
  package org.eclipse.osgi.framework.internal.protocol;
 
 import java.util.*;
 
 /*
  * An abstract class for handler factory impls (Stream and Content) that can 
  * handle environments running multiple osgi frameworks with the same VM.
  */
 public abstract class MultiplexingFactory {
 
 	protected static final String PACKAGEADMINCLASS = "org.osgi.service.packageadmin.PackageAdmin"//$NON-NLS-1$
 	protected BundleContext context;
 	protected FrameworkAdaptor adaptor;
 	private List factories// list of multiplexed factories
 
 	// used to get access to the protected SecurityManager#getClassContext method
 	private static class InternalSecurityManager extends SecurityManager {
 		public Class[] getClassContext() {
 			return super.getClassContext();
 		}
 	}
 
 
 		this. = context;
 		this. = adaptor;
 	}
 
 	abstract public void setParentFactory(Object parentFactory);
 
 	abstract public Object getParentFactory();
 
 	public synchronized boolean isMultiplexing() {
 		return  != null;
 	}
 
 	public synchronized void register(Object factory) {
 		if ( == null)
 			 = new LinkedList();
 
 		// set parent for each factory so they can do proper delegation
 		try {
 			Class clazz = factory.getClass();
 			Method setParentFactory = clazz.getMethod("setParentFactory"new Class[] {Object.class}); //$NON-NLS-1$
 			setParentFactory.invoke(factorynew Object[] {getParentFactory()});
 		} catch (Exception e) {
 			.getFrameworkLog().log(new FrameworkLogEntry(MultiplexingFactory.class.getName(), ., 0, "register".enull)); //$NON-NLS-1$
 			throw new RuntimeException(e.getMessage(), e);
 		}
 		.add(factory);
 	}
 
 	public synchronized void unregister(Object factory) {
 		.remove(factory);
 		if (.isEmpty())
 			 = null;
 		// close the service tracker
 		try {
 			// this is brittle; if class does not directly extend MultplexingFactory then this method will not exist, but we do not want a public method here
 			Method closeTracker = factory.getClass().getSuperclass().getDeclaredMethod("closePackageAdminTracker"null); //$NON-NLS-1$
 			closeTracker.setAccessible(true); // its a private method
 			closeTracker.invoke(factorynull);
 		} catch (Exception e) {
 			.getFrameworkLog().log(new FrameworkLogEntry(MultiplexingFactory.class.getName(), ., 0, "unregister".enull)); //$NON-NLS-1$
 			throw new RuntimeException(e.getMessage(), e);
 		}
 	}
 
 	public synchronized Object designateSuccessor() {
 		Object parentFactory = getParentFactory();
 		if ( == null || .isEmpty())
 			return parentFactory;
 
 		Object successor = .remove(0);
 		try {
 			Class clazz = successor.getClass();
 			Method register = clazz.getMethod("register"new Class[] {Object.class}); //$NON-NLS-1$		
 			for (Iterator it = .iterator(); it.hasNext();) {
 				register.invoke(successornew Object[] {it.next()});
 			}
 		} catch (Exception e) {
			.getFrameworkLog().log(new FrameworkLogEntry(MultiplexingFactory.class.getName(), ., 0, "designateSuccessor".enull)); //$NON-NLS-1$
			throw new RuntimeException(e.getMessage(), e);
		}
		 = null;
		closePackageAdminTracker(); // close tracker
		return successor;
	}
	private void closePackageAdminTracker() {
	}
	public synchronized Object findAuthorizedFactory(List ignoredClasses) {
		for (int i = 0; i < classStack.lengthi++) {
			Class clazz = classStack[i];
			if (clazz == InternalSecurityManager.class || clazz == MultiplexingFactory.class || ignoredClasses.contains(clazz))
				continue;
			if (hasAuthority(clazz))
				return this;
			if ( == null)
				continue;
			for (Iterator it = .iterator(); it.hasNext();) {
				Object factory = it.next();
				try {
					Method hasAuthorityMethod = factory.getClass().getMethod("hasAuthority"new Class[] {Class.class}); //$NON-NLS-1$
					if (((BooleanhasAuthorityMethod.invoke(factorynew Object[] {clazz})).booleanValue()) {
						return factory;
					}
catch (Exception e) {
					.getFrameworkLog().log(new FrameworkLogEntry(MultiplexingFactory.class.getName(), ., 0, "findAuthorizedURLStreamHandler-loop".enull)); //$NON-NLS-1$
					throw new RuntimeException(e.getMessage(), e);
				}
			}
		}
		return null;
	}
	public boolean hasAuthority(Class clazz) {
		if (packageAdminService != null) {
			return packageAdminService.getBundle(clazz) != null;
		}
		return false;
	}
New to GrepCode? Check out our FAQ X