connect/src/main/java/org/apache/felix/connect/felix/framework/ServiceRegistry.java [65:279]: - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - m_callbacks = callbacks; } /** * Get all service references for a bundle * @param bundle * @return List with all valid service references or {@code null}. */ public ServiceReference[] getRegisteredServices(final Bundle bundle) { final List> regs = m_regsMap.get(bundle); if (regs != null) { final List> refs = new ArrayList>(regs.size()); // this is a per bundle list, therefore synchronizing this should be fine synchronized ( regs ) { for (final ServiceRegistration reg : regs) { try { refs.add(reg.getReference()); } catch (final IllegalStateException ex) { // Don't include the reference as it is not valid anymore } } } return refs.toArray(new ServiceReference[refs.size()]); } return null; } /** * Register a new service * * Caller must fire service event as this method is not doing it! * * @param bundle The bundle registering the service * @param classNames The service class names * @param svcObj The service object * @param dict Optional service properties * @return Service registration */ public ServiceRegistration registerService( final Bundle bundle, final String[] classNames, final Object svcObj, final Dictionary dict) { // Create the service registration. final ServiceRegistrationImpl reg = new ServiceRegistrationImpl( this, bundle, classNames, m_currentServiceId.getAndIncrement(), svcObj, dict); // Keep track of registered hooks. this.hookRegistry.addHooks(classNames, svcObj, reg.getReference()); // Get the bundles current registered services. final List> newRegs = new ArrayList>(); List> regs = m_regsMap.putIfAbsent(bundle, newRegs); if (regs == null) { regs = newRegs; } // this is a per bundle list, therefore synchronizing this should be fine synchronized ( regs ) { regs.add(reg); } m_regCapSet.addCapability((BundleCapabilityImpl) reg.getReference()); return reg; } /** * Unregister a service * @param bundle The bundle unregistering the service * @param reg The service registration */ public void unregisterService( final Bundle bundle, final ServiceRegistration reg) { // If this is a hook, it should be removed. this.hookRegistry.removeHooks(reg.getReference()); // Now remove the registered service. final List> regs = m_regsMap.get(bundle); if (regs != null) { // this is a per bundle list, therefore synchronizing this should be fine synchronized ( regs ) { regs.remove(reg); } } m_regCapSet.removeCapability((BundleCapabilityImpl) reg.getReference()); // Notify callback objects about unregistering service. if (m_callbacks != null) { m_callbacks.serviceChanged( new ServiceEvent(ServiceEvent.UNREGISTERING, reg.getReference()), null); } // Now forcibly unget the service object for all stubborn clients. final ServiceReference ref = reg.getReference(); ungetServices(ref); // Invalidate registration ((ServiceRegistrationImpl) reg).invalidate(); // Bundles are allowed to get a reference while unregistering // get fresh set of bundles (should be empty, but this is a sanity check) ungetServices(ref); // Now flush all usage counts as the registration is invalid for (Bundle usingBundle : m_inUseMap.keySet()) { flushUsageCount(usingBundle, ref, null); } } private void ungetServices(final ServiceReference ref) { final Bundle[] clients = getUsingBundles(ref); for (int i = 0; (clients != null) && (i < clients.length); i++) { final UsageCount[] usages = m_inUseMap.get(clients[i]); for (int x = 0; (usages != null) && (x < usages.length); x++) { if (usages[x].m_ref.equals(ref)) { ungetService(clients[i], ref, (usages[x].m_prototype ? usages[x].getService() : null)); } } } } /** * This method retrieves all services registrations for the specified bundle and * invokes {@code ServiceRegistration.unregister()} on each one. This method is * only called be the framework to clean up after a stopped bundle. * * @param bundle the bundle whose services should be unregistered. **/ public void unregisterServices(final Bundle bundle) { // Simply remove all service registrations for the bundle. final List> regs = m_regsMap.remove(bundle); // Note, there is no race condition here with respect to the // bundle registering more services, because its bundle context // has already been invalidated by this point, so it would not // be able to register more services. // Unregister each service. if (regs != null) { final List> copyRefs; // there shouldn't be a need to sync, but just to be safe // we create a copy array and use that for iterating synchronized ( regs ) { copyRefs = new ArrayList>(regs); } for (final ServiceRegistration reg : copyRefs) { if (((ServiceRegistrationImpl) reg).isValid()) { try { reg.unregister(); } catch (final IllegalStateException e) { // Ignore exception if the service has already been unregistered } } } } } public Collection getServiceReferences(final String className, SimpleFilter filter) { if ((className == null) && (filter == null)) { // Return all services. filter = new SimpleFilter(null, null, SimpleFilter.MATCH_ALL); } else if ((className != null) && (filter == null)) { // Return services matching the class name. filter = new SimpleFilter(Constants.OBJECTCLASS, className, SimpleFilter.EQ); } else if ((className != null) && (filter != null)) { // Return services matching the class name and filter. final List filters = new ArrayList(2); filters.add(new SimpleFilter(Constants.OBJECTCLASS, className, SimpleFilter.EQ)); filters.add(filter); filter = new SimpleFilter(null, filters, SimpleFilter.AND); } // else just use the specified filter. return m_regCapSet.match(filter, false); } public ServiceReference[] getServicesInUse(final Bundle bundle) { final UsageCount[] usages = m_inUseMap.get(bundle); if (usages != null) { final ServiceReference[] refs = new ServiceReference[usages.length]; - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - framework/src/main/java/org/apache/felix/framework/ServiceRegistry.java [68:282]: - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - m_callbacks = callbacks; } /** * Get all service references for a bundle * @param bundle * @return List with all valid service references or {@code null}. */ public ServiceReference[] getRegisteredServices(final Bundle bundle) { final List> regs = m_regsMap.get(bundle); if (regs != null) { final List> refs = new ArrayList>(regs.size()); // this is a per bundle list, therefore synchronizing this should be fine synchronized ( regs ) { for (final ServiceRegistration reg : regs) { try { refs.add(reg.getReference()); } catch (final IllegalStateException ex) { // Don't include the reference as it is not valid anymore } } } return refs.toArray(new ServiceReference[refs.size()]); } return null; } /** * Register a new service * * Caller must fire service event as this method is not doing it! * * @param bundle The bundle registering the service * @param classNames The service class names * @param svcObj The service object * @param dict Optional service properties * @return Service registration */ public ServiceRegistration registerService( final Bundle bundle, final String[] classNames, final Object svcObj, final Dictionary dict) { // Create the service registration. final ServiceRegistrationImpl reg = new ServiceRegistrationImpl( this, bundle, classNames, m_currentServiceId.getAndIncrement(), svcObj, dict); // Keep track of registered hooks. this.hookRegistry.addHooks(classNames, svcObj, reg.getReference()); // Get the bundles current registered services. final List> newRegs = new ArrayList>(); List> regs = m_regsMap.putIfAbsent(bundle, newRegs); if (regs == null) { regs = newRegs; } // this is a per bundle list, therefore synchronizing this should be fine synchronized ( regs ) { regs.add(reg); } m_regCapSet.addCapability((BundleCapabilityImpl) reg.getReference()); return reg; } /** * Unregister a service * @param bundle The bundle unregistering the service * @param reg The service registration */ public void unregisterService( final Bundle bundle, final ServiceRegistration reg) { // If this is a hook, it should be removed. this.hookRegistry.removeHooks(reg.getReference()); // Now remove the registered service. final List> regs = m_regsMap.get(bundle); if (regs != null) { // this is a per bundle list, therefore synchronizing this should be fine synchronized ( regs ) { regs.remove(reg); } } m_regCapSet.removeCapability((BundleCapabilityImpl) reg.getReference()); // Notify callback objects about unregistering service. if (m_callbacks != null) { m_callbacks.serviceChanged( new ServiceEvent(ServiceEvent.UNREGISTERING, reg.getReference()), null); } // Now forcibly unget the service object for all stubborn clients. final ServiceReference ref = reg.getReference(); ungetServices(ref); // Invalidate registration ((ServiceRegistrationImpl) reg).invalidate(); // Bundles are allowed to get a reference while unregistering // get fresh set of bundles (should be empty, but this is a sanity check) ungetServices(ref); // Now flush all usage counts as the registration is invalid for (Bundle usingBundle : m_inUseMap.keySet()) { flushUsageCount(usingBundle, ref, null); } } private void ungetServices(final ServiceReference ref) { final Bundle[] clients = getUsingBundles(ref); for (int i = 0; (clients != null) && (i < clients.length); i++) { final UsageCount[] usages = m_inUseMap.get(clients[i]); for (int x = 0; (usages != null) && (x < usages.length); x++) { if (usages[x].m_ref.equals(ref)) { ungetService(clients[i], ref, (usages[x].m_prototype ? usages[x].getService() : null)); } } } } /** * This method retrieves all services registrations for the specified * bundle and invokes ServiceRegistration.unregister() on each * one. This method is only called be the framework to clean up after * a stopped bundle. * @param bundle the bundle whose services should be unregistered. **/ public void unregisterServices(final Bundle bundle) { // Simply remove all service registrations for the bundle. final List> regs = m_regsMap.remove(bundle); // Note, there is no race condition here with respect to the // bundle registering more services, because its bundle context // has already been invalidated by this point, so it would not // be able to register more services. // Unregister each service. if (regs != null) { final List> copyRefs; // there shouldn't be a need to sync, but just to be safe // we create a copy array and use that for iterating synchronized ( regs ) { copyRefs = new ArrayList>(regs); } for (final ServiceRegistration reg : copyRefs) { if (((ServiceRegistrationImpl) reg).isValid()) { try { reg.unregister(); } catch (final IllegalStateException e) { // Ignore exception if the service has already been unregistered } } } } } public Collection getServiceReferences(final String className, SimpleFilter filter) { if ((className == null) && (filter == null)) { // Return all services. filter = new SimpleFilter(null, null, SimpleFilter.MATCH_ALL); } else if ((className != null) && (filter == null)) { // Return services matching the class name. filter = new SimpleFilter(Constants.OBJECTCLASS, className, SimpleFilter.EQ); } else if ((className != null) && (filter != null)) { // Return services matching the class name and filter. final List filters = new ArrayList(2); filters.add(new SimpleFilter(Constants.OBJECTCLASS, className, SimpleFilter.EQ)); filters.add(filter); filter = new SimpleFilter(null, filters, SimpleFilter.AND); } // else just use the specified filter. return m_regCapSet.match(filter, false); } public ServiceReference[] getServicesInUse(final Bundle bundle) { final UsageCount[] usages = m_inUseMap.get(bundle); if (usages != null) { final ServiceReference[] refs = new ServiceReference[usages.length]; - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -