Attachment #93305 for bug #174480

This Bugzilla instance is a read-only archive of historic NetBeans bug reports. To report a bug in NetBeans please follow the project's instructions for reporting issues.

View | Details | Raw Unified | Return to bug 174480
Collapse All | Expand All





import java.io.IOException;
import java.io.InputStream;
import java.lang.reflect.Field;
import java.net.URL;
import java.util.Enumeration;
import java.util.HashMap;
import java.util.Set;
import java.util.concurrent.CopyOnWriteArraySet;
import java.util.logging.Level;
import org.apache.felix.framework.ModuleImpl;
import org.apache.felix.framework.ModuleImpl.ModuleClassLoader;
import org.netbeans.Module;
import org.openide.modules.ModuleInfo;
import org.osgi.framework.Bundle;
import org.osgi.framework.BundleActivator;
import org.osgi.framework.BundleContext;
import org.osgi.framework.BundleEvent;
import org.osgi.framework.SynchronousBundleListener;

/**
 *
 * @author Jaroslav Tulach <jtulach@netbeans.org>
 */
final class NetigsoActivator extends HashMap<Bundle,ClassLoader> {
    private static final Set<Module> all = new CopyOnWriteArraySet<Module>();
    private Set<Module> all = new CopyOnWriteArraySet<Module>();

    public NetigsoActivator() {
    }
    private BundleContext m_context = null;

    @Override
    public ClassLoader get(Object o) {
        if (o instanceof Bundle) {
            String loc = ((Bundle) o).getLocation();
            final String pref = "netigso://"; // NOI18N
            if (loc != null && loc.startsWith(pref)) {
                String cnb = loc.substring(pref.length());
                for (ModuleInfo mi : all) {
                    if (cnb.equals(mi.getCodeNameBase())) {
                        return new DelegateLoader(mi);
                    }
                }
            }
        }
        return null;
    }

    static void register(Module m) {
        String loc = ev.getBundle().getLocation();
        NetigsoModule.LOG.log(Level.FINER, "bundleChanged {0}", ev);
        final String pref = "netigso://"; // NOI18N
        if (ev.getType() == BundleEvent.RESOLVED && loc != null && loc.startsWith(pref)) {
            String cnb = loc.substring(pref.length());
            for (ModuleInfo mi : all) {
                if (cnb.equals(mi.getCodeNameBase())) {
                join(ev.getBundle(), mi);
                    return;
                }
            }
            NetigsoModule.LOG.log(Level.WARNING, "No join for {0}", cnb);
        }
    }

    void register(Module m) {
        NetigsoModule.LOG.log(Level.FINER, "register module {0}", m.getCodeNameBase());
        all.add(m);
    }

    private static final class DelegateLoader extends ClassLoader {

        private final ModuleInfo mi;
     */
    private void join(Bundle bundle, ModuleInfo mi) {
        try {
            Field modules = findField(bundle, "m_modules");
            Object[] arr = (Object[])modules.get(bundle);
            Field loader = null;
            for (int i = 0; i < arr.length; i++) {
                ModuleImpl impl = (ModuleImpl)arr[i];
                if (loader == null) {
                    loader = findField(impl, "m_classLoader");
                }
                loader.set(impl, new DelegateLoader(impl, mi));
            }
        } catch (Exception ex) {
            throw new IllegalStateException(ex);
        }
    }
    private static Field findField(Object obj, String name) throws Exception {
        Exception first = null;
        Class<?> c = obj.getClass();
        while (c != null) {
            try {
                Field m = c.getDeclaredField(name);
                m.setAccessible(true);
                return m;
            } catch (Exception e) {
                first = e;
            }
            c = c.getSuperclass();
        }
        throw first;
    }

        public DelegateLoader(ModuleInfo mi) {
        private final ModuleInfo mi;
        public DelegateLoader(ModuleImpl impl, ModuleInfo mi) {
            impl.super(null);
            this.mi = mi;
        }





import org.openide.util.Lookup;
import org.openide.util.lookup.ServiceProvider;
import org.osgi.framework.Bundle;
import org.osgi.framework.BundleActivator;
import org.osgi.framework.BundleException;
import org.osgi.framework.Constants;
import org.osgi.framework.launch.Framework;

            configMap.put("felix.cache.dir", cache);
            configMap.put(Constants.FRAMEWORK_STORAGE, cache);
            activator = new NetigsoActivator();
            configMap.put("felix.bootdelegation.classloaders", activator);
            activators.add(activator);
            configMap.put("felix.systembundle.activators", activators);
            FrameworkFactory frameworkFactory = Lookup.getDefault().lookup(FrameworkFactory.class);
            framework = frameworkFactory.newFramework(configMap);
            framework.init();

        InputStream is = fakeBundle(m);
        if (is != null) {
            try {
                NetigsoActivator.register(m);
                getContainer().getBundleContext().installBundle("netigso://" + m.getCodeNameBase(), is);
                activator.register(m);
                is.close();
            } catch (BundleException ex) {
                throw new IOException(ex.getMessage());

Return to bug 174480

Lines 41-151 Link Here

(-)a/core.netigso/src/org/netbeans/core/netigso/NetigsoActivator.java (-78 / +20 lines)
41		41
42	import java.io.IOException;	42	import java.io.IOException;
43	import java.io.InputStream;	43	import java.io.InputStream;
44	import java.lang.reflect.Field;
45	import java.net.URL;	44	import java.net.URL;
46	import java.util.Enumeration;	45	import java.util.Enumeration;
		46	import java.util.HashMap;
47	import java.util.Set;	47	import java.util.Set;
48	import java.util.concurrent.CopyOnWriteArraySet;	48	import java.util.concurrent.CopyOnWriteArraySet;
49	import java.util.logging.Level;	49	import java.util.logging.Level;
50	import org.apache.felix.framework.ModuleImpl;
51	import org.apache.felix.framework.ModuleImpl.ModuleClassLoader;
52	import org.netbeans.Module;	50	import org.netbeans.Module;
53	import org.openide.modules.ModuleInfo;	51	import org.openide.modules.ModuleInfo;
54	import org.osgi.framework.Bundle;	52	import org.osgi.framework.Bundle;
55	import org.osgi.framework.BundleActivator;
56	import org.osgi.framework.BundleContext;
57	import org.osgi.framework.BundleEvent;
58	import org.osgi.framework.SynchronousBundleListener;
59		53
60	/**	54	/**
61	*	55	*
62	* @author Jaroslav Tulach <jtulach@netbeans.org>	56	* @author Jaroslav Tulach <jtulach@netbeans.org>
63	*/	57	*/
64	final class NetigsoActivator	58	final class NetigsoActivator extends HashMap<Bundle,ClassLoader> {
65	implements BundleActivator, SynchronousBundleListener {	59	private static final Set<Module> all = new CopyOnWriteArraySet<Module>();
66	private Set<Module> all = new CopyOnWriteArraySet<Module>();
67		60
68	public NetigsoActivator() {	61	public NetigsoActivator() {
69	}	62	}
70	private BundleContext m_context = null;
71		63
72	public void start(BundleContext context) {	64	@Override
73	m_context = context;	65	public ClassLoader get(Object o) {
74	context.addBundleListener(this);	66	if (o instanceof Bundle) {
75	}	67	String loc = ((Bundle) o).getLocation();
76		68	final String pref = "netigso://"; // NOI18N
77	public void stop(BundleContext context) {	69	if (loc != null && loc.startsWith(pref)) {
78	context.removeBundleListener(this);	70	String cnb = loc.substring(pref.length());
79	m_context = null;	71	for (ModuleInfo mi : all) {
80	}	72	if (cnb.equals(mi.getCodeNameBase())) {
81		73	return new DelegateLoader(mi);
82	public Bundle[] getBundles() {	74	}
83	if (m_context != null) {	75	}
84	return m_context.getBundles();	76	}
85	}	77	}
86	return null;	78	return null;
87	}	79	}
88		80
89	public void bundleChanged(BundleEvent ev) {	81	static void register(Module m) {
90	String loc = ev.getBundle().getLocation();
91	NetigsoModule.LOG.log(Level.FINER, "bundleChanged {0}", ev);
92	final String pref = "netigso://"; // NOI18N
93	if (ev.getType() == BundleEvent.RESOLVED && loc != null && loc.startsWith(pref)) {
94	String cnb = loc.substring(pref.length());
95	for (ModuleInfo mi : all) {
96	if (cnb.equals(mi.getCodeNameBase())) {
97	join(ev.getBundle(), mi);
98	return;
99	}
100	}
101	NetigsoModule.LOG.log(Level.WARNING, "No join for {0}", cnb);
102	}
103	}
104
105	void register(Module m) {
106	NetigsoModule.LOG.log(Level.FINER, "register module {0}", m.getCodeNameBase());	82	NetigsoModule.LOG.log(Level.FINER, "register module {0}", m.getCodeNameBase());
107	all.add(m);	83	all.add(m);
108	}	84	}
109		85
		86	private static final class DelegateLoader extends ClassLoader {
110		87
111	/** Injects classloader of mi to Felix's bundle.	88	private final ModuleInfo mi;
112	*/
113	private void join(Bundle bundle, ModuleInfo mi) {
114	try {
115	Field modules = findField(bundle, "m_modules");
116	Object[] arr = (Object[])modules.get(bundle);
117	Field loader = null;
118	for (int i = 0; i < arr.length; i++) {
119	ModuleImpl impl = (ModuleImpl)arr[i];
120	if (loader == null) {
121	loader = findField(impl, "m_classLoader");
122	}
123	loader.set(impl, new DelegateLoader(impl, mi));
124	}
125	} catch (Exception ex) {
126	throw new IllegalStateException(ex);
127	}
128	}
129	private static Field findField(Object obj, String name) throws Exception {
130	Exception first = null;
131	Class<?> c = obj.getClass();
132	while (c != null) {
133	try {
134	Field m = c.getDeclaredField(name);
135	m.setAccessible(true);
136	return m;
137	} catch (Exception e) {
138	first = e;
139	}
140	c = c.getSuperclass();
141	}
142	throw first;
143	}
144		89
145	private static final class DelegateLoader extends ModuleClassLoader {	90	public DelegateLoader(ModuleInfo mi) {
146	private final ModuleInfo mi;
147	public DelegateLoader(ModuleImpl impl, ModuleInfo mi) {
148	impl.super(null);
149	this.mi = mi;	91	this.mi = mi;
150	}	92	}
151		93

Lines 68-74 Link Here

(-)a/core.netigso/src/org/netbeans/core/netigso/NetigsoModuleFactory.java (-5 / +2 lines)
68	import org.openide.util.Lookup;	68	import org.openide.util.Lookup;
69	import org.openide.util.lookup.ServiceProvider;	69	import org.openide.util.lookup.ServiceProvider;
70	import org.osgi.framework.Bundle;	70	import org.osgi.framework.Bundle;
71	import org.osgi.framework.BundleActivator;
72	import org.osgi.framework.BundleException;	71	import org.osgi.framework.BundleException;
73	import org.osgi.framework.Constants;	72	import org.osgi.framework.Constants;
74	import org.osgi.framework.launch.Framework;	73	import org.osgi.framework.launch.Framework;
Lines 244-252 Link Here
244	configMap.put("felix.cache.dir", cache);	243	configMap.put("felix.cache.dir", cache);
245	configMap.put(Constants.FRAMEWORK_STORAGE, cache);	244	configMap.put(Constants.FRAMEWORK_STORAGE, cache);
246	activator = new NetigsoActivator();	245	activator = new NetigsoActivator();
247	List<BundleActivator> activators = new ArrayList<BundleActivator>();	246	configMap.put("felix.bootdelegation.classloaders", activator);
248	activators.add(activator);
249	configMap.put("felix.systembundle.activators", activators);
250	FrameworkFactory frameworkFactory = Lookup.getDefault().lookup(FrameworkFactory.class);	247	FrameworkFactory frameworkFactory = Lookup.getDefault().lookup(FrameworkFactory.class);
251	framework = frameworkFactory.newFramework(configMap);	248	framework = frameworkFactory.newFramework(configMap);
252	framework.init();	249	framework.init();
Lines 330-337 Link Here
330	InputStream is = fakeBundle(m);	327	InputStream is = fakeBundle(m);
331	if (is != null) {	328	if (is != null) {
332	try {	329	try {
		330	NetigsoActivator.register(m);
333	getContainer().getBundleContext().installBundle("netigso://" + m.getCodeNameBase(), is);	331	getContainer().getBundleContext().installBundle("netigso://" + m.getCodeNameBase(), is);
334	activator.register(m);
335	is.close();	332	is.close();
336	} catch (BundleException ex) {	333	} catch (BundleException ex) {
337	throw new IOException(ex.getMessage());	334	throw new IOException(ex.getMessage());