You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@felix.apache.org by ma...@apache.org on 2010/04/02 17:16:51 UTC
svn commit: r930293 - in
/felix/trunk/dependencymanager/core/src/main/java/org/apache/felix/dm: ./
dependencies/ impl/ impl/dependencies/
Author: marrs
Date: Fri Apr 2 15:16:50 2010
New Revision: 930293
URL: http://svn.apache.org/viewvc?rev=930293&view=rev
Log:
Added support for invoking life cycle callbacks on something else than the service instance. Refactored some of the callback invocation code so all of them now use the same implementation. Implemented some still missing things.
Added:
felix/trunk/dependencymanager/core/src/main/java/org/apache/felix/dm/impl/InvocationUtil.java
felix/trunk/dependencymanager/core/src/main/java/org/apache/felix/dm/impl/dependencies/DependencyBase.java
- copied, changed from r925503, felix/trunk/dependencymanager/core/src/main/java/org/apache/felix/dm/impl/dependencies/AbstractDependency.java
Removed:
felix/trunk/dependencymanager/core/src/main/java/org/apache/felix/dm/impl/dependencies/AbstractDependency.java
Modified:
felix/trunk/dependencymanager/core/src/main/java/org/apache/felix/dm/DependencyActivatorBase.java
felix/trunk/dependencymanager/core/src/main/java/org/apache/felix/dm/DependencyManager.java
felix/trunk/dependencymanager/core/src/main/java/org/apache/felix/dm/dependencies/BundleDependency.java
felix/trunk/dependencymanager/core/src/main/java/org/apache/felix/dm/dependencies/ConfigurationDependency.java
felix/trunk/dependencymanager/core/src/main/java/org/apache/felix/dm/impl/ServiceImpl.java
felix/trunk/dependencymanager/core/src/main/java/org/apache/felix/dm/impl/dependencies/BundleDependencyImpl.java
felix/trunk/dependencymanager/core/src/main/java/org/apache/felix/dm/impl/dependencies/ConfigurationDependencyImpl.java
felix/trunk/dependencymanager/core/src/main/java/org/apache/felix/dm/impl/dependencies/ResourceDependencyImpl.java
felix/trunk/dependencymanager/core/src/main/java/org/apache/felix/dm/impl/dependencies/ServiceDependencyImpl.java
Modified: felix/trunk/dependencymanager/core/src/main/java/org/apache/felix/dm/DependencyActivatorBase.java
URL: http://svn.apache.org/viewvc/felix/trunk/dependencymanager/core/src/main/java/org/apache/felix/dm/DependencyActivatorBase.java?rev=930293&r1=930292&r2=930293&view=diff
==============================================================================
--- felix/trunk/dependencymanager/core/src/main/java/org/apache/felix/dm/DependencyActivatorBase.java (original)
+++ felix/trunk/dependencymanager/core/src/main/java/org/apache/felix/dm/DependencyActivatorBase.java Fri Apr 2 15:16:50 2010
@@ -164,17 +164,26 @@ public abstract class DependencyActivato
return m_manager.createAspectService(serviceInterface, serviceFilter, ranking, factory, factoryCreateMethod, properties);
}
- public Service createAdapterService(Class serviceInterface, String serviceFilter, Class adapterInterface, Object adapterImplementation, Dictionary adapterProperties) {
+ public Service createAdapterService(Class serviceInterface, String serviceFilter, String adapterInterface, Object adapterImplementation, Dictionary adapterProperties) {
+ return m_manager.createAdapterService(serviceInterface, serviceFilter, adapterInterface, adapterImplementation, adapterProperties);
+ }
+ public Service createAdapterService(Class serviceInterface, String serviceFilter, String[] adapterInterface, Object adapterImplementation, Dictionary adapterProperties) {
return m_manager.createAdapterService(serviceInterface, serviceFilter, adapterInterface, adapterImplementation, adapterProperties);
}
- public Service createResourceAdapter(String resourceFilter, Class adapterInterface, Dictionary adapterProperties, Object adapterImplementation, boolean propagate) {
+ public Service createResourceAdapter(String resourceFilter, String adapterInterface, Dictionary adapterProperties, Object adapterImplementation, boolean propagate) {
+ return m_manager.createResourceAdapterService(resourceFilter, adapterInterface, adapterProperties, adapterImplementation, propagate);
+ }
+ public Service createResourceAdapter(String resourceFilter, String[] adapterInterface, Dictionary adapterProperties, Object adapterImplementation, boolean propagate) {
return m_manager.createResourceAdapterService(resourceFilter, adapterInterface, adapterProperties, adapterImplementation, propagate);
}
public Service createBundleAdapterService(int bundleStateMask, String bundleFilter, Object adapterImplementation, String adapterInterface, Dictionary adapterProperties, boolean propagate) {
return m_manager.createBundleAdapterService(bundleStateMask, bundleFilter, adapterImplementation, adapterInterface, adapterProperties, propagate);
}
+ public Service createBundleAdapterService(int bundleStateMask, String bundleFilter, Object adapterImplementation, String[] adapterInterface, Dictionary adapterProperties, boolean propagate) {
+ return m_manager.createBundleAdapterService(bundleStateMask, bundleFilter, adapterImplementation, adapterInterface, adapterProperties, propagate);
+ }
/**
* Cleans up all services and their dependencies.
Modified: felix/trunk/dependencymanager/core/src/main/java/org/apache/felix/dm/DependencyManager.java
URL: http://svn.apache.org/viewvc/felix/trunk/dependencymanager/core/src/main/java/org/apache/felix/dm/DependencyManager.java?rev=930293&r1=930292&r2=930293&view=diff
==============================================================================
--- felix/trunk/dependencymanager/core/src/main/java/org/apache/felix/dm/DependencyManager.java (original)
+++ felix/trunk/dependencymanager/core/src/main/java/org/apache/felix/dm/DependencyManager.java Fri Apr 2 15:16:50 2010
@@ -222,9 +222,19 @@ public class DependencyManager {
* @param adapterProperties additional properties to use with the adapter service registration
* @return a service that acts as a factory for generating adapters
*/
- public Service createAdapterService(Class serviceInterface, String serviceFilter, Class adapterInterface, Object adapterImplementation, Dictionary adapterProperties) {
+ public Service createAdapterService(Class serviceInterface, String serviceFilter, String adapterInterface, Object adapterImplementation, Dictionary adapterProperties) {
return createService()
- .setImplementation(new AdapterImpl(serviceInterface, serviceFilter, adapterImplementation, adapterInterface.getName(), adapterProperties))
+ .setImplementation(new AdapterImpl(serviceInterface, serviceFilter, adapterImplementation, adapterInterface, adapterProperties))
+ .add(createServiceDependency()
+ .setService(serviceInterface)
+ .setAutoConfig(false)
+ .setCallbacks("added", "removed")
+ );
+ }
+
+ public Service createAdapterService(Class serviceInterface, String serviceFilter, String[] adapterInterface, Object adapterImplementation, Dictionary adapterProperties) {
+ return createService()
+ .setImplementation(new AdapterImpl(serviceInterface, serviceFilter, adapterImplementation, adapterInterface, adapterProperties))
.add(createServiceDependency()
.setService(serviceInterface)
.setAutoConfig(false)
@@ -249,9 +259,18 @@ public class DependencyManager {
* @return a service that acts as a factory for generating resource adapters
* @see Resource
*/
- public Service createResourceAdapterService(String resourceFilter, Class adapterInterface, Dictionary adapterProperties, Object adapterImplementation, boolean propagate) {
+ public Service createResourceAdapterService(String resourceFilter, String adapterInterface, Dictionary adapterProperties, Object adapterImplementation, boolean propagate) {
return createService()
- .setImplementation(new ResourceAdapterImpl(resourceFilter, adapterImplementation, adapterInterface.getName(), adapterProperties, propagate))
+ .setImplementation(new ResourceAdapterImpl(resourceFilter, adapterImplementation, adapterInterface, adapterProperties, propagate))
+ .add(createResourceDependency()
+ .setFilter(resourceFilter)
+ .setAutoConfig(false)
+ .setCallbacks("added", "removed")
+ );
+ }
+ public Service createResourceAdapterService(String resourceFilter, String[] adapterInterface, Dictionary adapterProperties, Object adapterImplementation, boolean propagate) {
+ return createService()
+ .setImplementation(new ResourceAdapterImpl(resourceFilter, adapterImplementation, adapterInterface, adapterProperties, propagate))
.add(createResourceDependency()
.setFilter(resourceFilter)
.setAutoConfig(false)
@@ -286,6 +305,15 @@ public class DependencyManager {
.setCallbacks("added", "removed")
);
}
+ public Service createBundleAdapterService(int bundleStateMask, String bundleFilter, Object adapterImplementation, String[] adapterInterface, Dictionary adapterProperties, boolean propagate) {
+ return createService()
+ .setImplementation(new BundleAdapterImpl(bundleStateMask, bundleFilter, adapterImplementation, adapterInterface, adapterProperties, propagate))
+ .add(createBundleDependency()
+ .setFilter(bundleFilter)
+ .setStateMask(bundleStateMask)
+ .setCallbacks("added", "removed")
+ );
+ }
/**
* Returns a list of services.
Modified: felix/trunk/dependencymanager/core/src/main/java/org/apache/felix/dm/dependencies/BundleDependency.java
URL: http://svn.apache.org/viewvc/felix/trunk/dependencymanager/core/src/main/java/org/apache/felix/dm/dependencies/BundleDependency.java?rev=930293&r1=930292&r2=930293&view=diff
==============================================================================
--- felix/trunk/dependencymanager/core/src/main/java/org/apache/felix/dm/dependencies/BundleDependency.java (original)
+++ felix/trunk/dependencymanager/core/src/main/java/org/apache/felix/dm/dependencies/BundleDependency.java Fri Apr 2 15:16:50 2010
@@ -77,4 +77,7 @@ public interface BundleDependency extend
BundleDependency setStateMask(int mask);
BundleDependency setPropagate(boolean propagate);
+
+ BundleDependency setInstanceBound(boolean isInstanceBound);
+
}
Modified: felix/trunk/dependencymanager/core/src/main/java/org/apache/felix/dm/dependencies/ConfigurationDependency.java
URL: http://svn.apache.org/viewvc/felix/trunk/dependencymanager/core/src/main/java/org/apache/felix/dm/dependencies/ConfigurationDependency.java?rev=930293&r1=930292&r2=930293&view=diff
==============================================================================
--- felix/trunk/dependencymanager/core/src/main/java/org/apache/felix/dm/dependencies/ConfigurationDependency.java (original)
+++ felix/trunk/dependencymanager/core/src/main/java/org/apache/felix/dm/dependencies/ConfigurationDependency.java Fri Apr 2 15:16:50 2010
@@ -71,4 +71,7 @@ public interface ConfigurationDependency
* Adds a MetaData regarding a given configuration property.
*/
ConfigurationDependency add(PropertyMetaData properties);
+
+ ConfigurationDependency setInstanceBound(boolean isInstanceBound);
+
}
Added: felix/trunk/dependencymanager/core/src/main/java/org/apache/felix/dm/impl/InvocationUtil.java
URL: http://svn.apache.org/viewvc/felix/trunk/dependencymanager/core/src/main/java/org/apache/felix/dm/impl/InvocationUtil.java?rev=930293&view=auto
==============================================================================
--- felix/trunk/dependencymanager/core/src/main/java/org/apache/felix/dm/impl/InvocationUtil.java (added)
+++ felix/trunk/dependencymanager/core/src/main/java/org/apache/felix/dm/impl/InvocationUtil.java Fri Apr 2 15:16:50 2010
@@ -0,0 +1,49 @@
+package org.apache.felix.dm.impl;
+
+import java.lang.reflect.InvocationTargetException;
+import java.lang.reflect.Method;
+import java.lang.reflect.Modifier;
+
+public class InvocationUtil {
+ public static void invokeCallbackMethod(Object[] instances, String methodName, Class[][] signatures, Object[][] parameters) throws NoSuchMethodException, IllegalArgumentException, IllegalAccessException, InvocationTargetException {
+ for (int i = 0; i < instances.length; i++) {
+ invokeCallbackMethod(instances[i], methodName, signatures, parameters);
+ return;
+ }
+ throw new NoSuchMethodException("Method '" + methodName + "' does not exist. Callback skipped.");
+ }
+
+ public static void invokeCallbackMethod(Object instance, String methodName, Class[][] signatures, Object[][] parameters) throws NoSuchMethodException, IllegalArgumentException, IllegalAccessException, InvocationTargetException {
+ Class currentClazz = instance.getClass();
+ while (currentClazz != null) {
+ try {
+ invokeMethod(instance, currentClazz, methodName, signatures, parameters, false);
+ return;
+ }
+ catch (NoSuchMethodException nsme) {
+ // ignore
+ }
+ currentClazz = currentClazz.getSuperclass();
+ }
+ throw new NoSuchMethodException(methodName);
+ }
+
+ public static void invokeMethod(Object object, Class clazz, String name, Class[][] signatures, Object[][] parameters, boolean isSuper) throws NoSuchMethodException, InvocationTargetException, IllegalArgumentException, IllegalAccessException {
+ Method m = null;
+ for (int i = 0; i < signatures.length; i++) {
+ Class[] signature = signatures[i];
+ try {
+ m = clazz.getDeclaredMethod(name, signature);
+ if (!(isSuper && Modifier.isPrivate(m.getModifiers()))) {
+ m.setAccessible(true);
+ m.invoke(object, parameters[i]);
+ return;
+ }
+ }
+ catch (NoSuchMethodException e) {
+ // ignore this and keep looking
+ }
+ }
+ throw new NoSuchMethodException();
+ }
+}
Modified: felix/trunk/dependencymanager/core/src/main/java/org/apache/felix/dm/impl/ServiceImpl.java
URL: http://svn.apache.org/viewvc/felix/trunk/dependencymanager/core/src/main/java/org/apache/felix/dm/impl/ServiceImpl.java?rev=930293&r1=930292&r2=930293&view=diff
==============================================================================
--- felix/trunk/dependencymanager/core/src/main/java/org/apache/felix/dm/impl/ServiceImpl.java (original)
+++ felix/trunk/dependencymanager/core/src/main/java/org/apache/felix/dm/impl/ServiceImpl.java Fri Apr 2 15:16:50 2010
@@ -20,7 +20,6 @@ package org.apache.felix.dm.impl;
import java.lang.reflect.Constructor;
import java.lang.reflect.Field;
-import java.lang.reflect.InvocationTargetException;
import java.lang.reflect.Method;
import java.lang.reflect.Proxy;
import java.util.ArrayList;
@@ -65,6 +64,7 @@ public class ServiceImpl implements Serv
private String m_callbackDestroy;
private Object m_serviceName;
private Object m_implementation;
+ private Object m_callbackInstance;
// configuration (dynamic, but does not affect state)
private Dictionary m_serviceProperties;
@@ -370,6 +370,18 @@ public class ServiceImpl implements Serv
m_callbackDestroy = destroy;
return this;
}
+
+ public synchronized Service setCallbacks(Object instance, String init, String start, String stop, String destroy) {
+ ensureNotActive();
+ m_callbackInstance = instance;
+ m_callbackInit = init;
+ m_callbackStart = start;
+ m_callbackStop = stop;
+ m_callbackDestroy = destroy;
+ return this;
+ }
+
+
public synchronized Service setImplementation(Object implementation) {
ensureNotActive();
@@ -572,26 +584,12 @@ public class ServiceImpl implements Serv
if (name != null) {
// invoke method if it exists
try {
- Class clazz = m_serviceInstance.getClass();
- while (clazz != null) {
- try {
- Method method = clazz.getDeclaredMethod(name, null);
- if (method != null) {
- method.setAccessible(true);
- try {
- method.invoke(m_serviceInstance, null);
- }
- catch (InvocationTargetException e) {
- m_logger.log(Logger.LOG_ERROR, "Exception while invoking method " + method + ".", e);
- }
- return;
- }
- }
- catch (NoSuchMethodException e) {
- // ignore this, we keep searching if the method does not exist
- }
- clazz = clazz.getSuperclass();
- }
+ // if a callback instance was specified, look for the method there, if not, look for the method in the
+ // instance itself
+ Object instance = m_callbackInstance != null ? m_callbackInstance : m_serviceInstance;
+ InvocationUtil.invokeCallbackMethod(instance, name,
+ new Class[][] {{ Object.class, DependencyManager.class, Service.class }, { DependencyManager.class, Service.class }, { Object.class }, {}},
+ new Object[][] {{ m_serviceInstance, m_manager, this }, { m_manager, this }, { m_serviceInstance }, {}});
}
catch (Exception e) {
m_logger.log(Logger.LOG_ERROR, "Error trying to invoke method named " + name + ".", e);
Modified: felix/trunk/dependencymanager/core/src/main/java/org/apache/felix/dm/impl/dependencies/BundleDependencyImpl.java
URL: http://svn.apache.org/viewvc/felix/trunk/dependencymanager/core/src/main/java/org/apache/felix/dm/impl/dependencies/BundleDependencyImpl.java?rev=930293&r1=930292&r2=930293&view=diff
==============================================================================
--- felix/trunk/dependencymanager/core/src/main/java/org/apache/felix/dm/impl/dependencies/BundleDependencyImpl.java (original)
+++ felix/trunk/dependencymanager/core/src/main/java/org/apache/felix/dm/impl/dependencies/BundleDependencyImpl.java Fri Apr 2 15:16:50 2010
@@ -35,7 +35,7 @@ import org.osgi.framework.BundleEvent;
import org.osgi.framework.Filter;
import org.osgi.framework.InvalidSyntaxException;
-public class BundleDependencyImpl extends AbstractDependency implements BundleDependency, BundleTrackerCustomizer, ServiceComponentDependency {
+public class BundleDependencyImpl extends DependencyBase implements BundleDependency, BundleTrackerCustomizer, ServiceComponentDependency {
private final BundleContext m_context;
private boolean m_isStarted;
private BundleTracker m_tracker;
@@ -63,15 +63,15 @@ public class BundleDependencyImpl extend
m_autoConfig = true;
}
- public boolean isInstanceBound() {
- return false; // TODO for now we are never bound to the service implementation instance
- }
-
+ public BundleDependency setInstanceBound(boolean isInstanceBound) {
+ setIsInstanceBound(isInstanceBound);
+ return this;
+ }
+
public synchronized boolean isAvailable() {
return m_isAvailable;
}
-
public void start(DependencyService service) {
boolean needsStarting = false;
synchronized (this) {
Modified: felix/trunk/dependencymanager/core/src/main/java/org/apache/felix/dm/impl/dependencies/ConfigurationDependencyImpl.java
URL: http://svn.apache.org/viewvc/felix/trunk/dependencymanager/core/src/main/java/org/apache/felix/dm/impl/dependencies/ConfigurationDependencyImpl.java?rev=930293&r1=930292&r2=930293&view=diff
==============================================================================
--- felix/trunk/dependencymanager/core/src/main/java/org/apache/felix/dm/impl/dependencies/ConfigurationDependencyImpl.java (original)
+++ felix/trunk/dependencymanager/core/src/main/java/org/apache/felix/dm/impl/dependencies/ConfigurationDependencyImpl.java Fri Apr 2 15:16:50 2010
@@ -58,22 +58,21 @@ import org.osgi.service.cm.ManagedServic
*
* @author <a href="mailto:dev@felix.apache.org">Felix Project Team</a>
*/
-public class ConfigurationDependencyImpl implements ConfigurationDependency, ManagedService, ServiceComponentDependency, DependencyActivation {
+public class ConfigurationDependencyImpl extends DependencyBase implements ConfigurationDependency, ManagedService, ServiceComponentDependency, DependencyActivation {
private BundleContext m_context;
private String m_pid;
private ServiceRegistration m_registration;
protected List m_services = new ArrayList();
private Dictionary m_settings;
private boolean m_propagate;
- private final Logger m_logger;
private String m_callback;
private boolean m_isStarted;
private final Set m_updateInvokedCache = new HashSet();
private MetaTypeProviderImpl m_metaType;
public ConfigurationDependencyImpl(BundleContext context, Logger logger) {
+ super(logger);
m_context = context;
- m_logger = logger;
}
public synchronized boolean isAvailable() {
@@ -89,11 +88,6 @@ public class ConfigurationDependencyImpl
return true;
}
- public boolean isInstanceBound() {
- // for now, configuration dependencies never are
- return false;
- }
-
/**
* Returns <code>true</code> when configuration properties should be propagated
* as service properties.
@@ -102,6 +96,12 @@ public class ConfigurationDependencyImpl
return m_propagate;
}
+ public ConfigurationDependency setInstanceBound(boolean isInstanceBound) {
+ setIsInstanceBound(isInstanceBound);
+ return this;
+ }
+
+
public Dictionary getConfiguration() {
return m_settings;
}
Copied: felix/trunk/dependencymanager/core/src/main/java/org/apache/felix/dm/impl/dependencies/DependencyBase.java (from r925503, felix/trunk/dependencymanager/core/src/main/java/org/apache/felix/dm/impl/dependencies/AbstractDependency.java)
URL: http://svn.apache.org/viewvc/felix/trunk/dependencymanager/core/src/main/java/org/apache/felix/dm/impl/dependencies/DependencyBase.java?p2=felix/trunk/dependencymanager/core/src/main/java/org/apache/felix/dm/impl/dependencies/DependencyBase.java&p1=felix/trunk/dependencymanager/core/src/main/java/org/apache/felix/dm/impl/dependencies/AbstractDependency.java&r1=925503&r2=930293&rev=930293&view=diff
==============================================================================
--- felix/trunk/dependencymanager/core/src/main/java/org/apache/felix/dm/impl/dependencies/AbstractDependency.java (original)
+++ felix/trunk/dependencymanager/core/src/main/java/org/apache/felix/dm/impl/dependencies/DependencyBase.java Fri Apr 2 15:16:50 2010
@@ -1,17 +1,15 @@
package org.apache.felix.dm.impl.dependencies;
-import java.lang.reflect.InvocationTargetException;
-import java.lang.reflect.Method;
-import java.lang.reflect.Modifier;
-
import org.apache.felix.dm.dependencies.Dependency;
+import org.apache.felix.dm.impl.InvocationUtil;
import org.apache.felix.dm.impl.Logger;
-public abstract class AbstractDependency implements Dependency, DependencyActivation {
+public abstract class DependencyBase implements Dependency, DependencyActivation {
private boolean m_isRequired;
+ private boolean m_isInstanceBound;
protected final Logger m_logger;
- public AbstractDependency(Logger logger) {
+ public DependencyBase(Logger logger) {
m_logger = logger;
}
@@ -23,57 +21,23 @@ public abstract class AbstractDependency
m_isRequired = isRequired;
}
- protected void invokeCallbackMethod(Object[] instances, String methodName, Class[][] signatures, Object[][] parameters) {
- for (int i = 0; i < instances.length; i++) {
- try {
- invokeCallbackMethod(instances[i], methodName, signatures, parameters);
- }
- catch (NoSuchMethodException e) {
- m_logger.log(Logger.LOG_DEBUG, "Method '" + methodName + "' does not exist on " + instances[i] + ". Callback skipped.");
- }
- }
+ public final boolean isInstanceBound() {
+ return m_isInstanceBound;
}
- protected void invokeCallbackMethod(Object instance, String methodName, Class[][] signatures, Object[][] parameters) throws NoSuchMethodException {
- Class currentClazz = instance.getClass();
- boolean done = false;
- while (!done && currentClazz != null) {
- done = invokeMethod(instance, currentClazz, methodName, signatures, parameters, false);
- if (!done) {
- currentClazz = currentClazz.getSuperclass();
- }
+ public final void setIsInstanceBound(boolean isInstanceBound) {
+ m_isInstanceBound = isInstanceBound;
+ }
+
+ protected void invokeCallbackMethod(Object[] instances, String methodName, Class[][] signatures, Object[][] parameters) {
+ try {
+ InvocationUtil.invokeCallbackMethod(instances, methodName, signatures, parameters);
}
- if (!done && currentClazz == null) {
- throw new NoSuchMethodException(methodName);
+ catch (NoSuchMethodException e) {
+ m_logger.log(Logger.LOG_DEBUG, "Method '" + methodName + "' does not exist. Callback skipped.");
}
- }
-
- protected boolean invokeMethod(Object object, Class clazz, String name, Class[][] signatures, Object[][] parameters, boolean isSuper) {
- Method m = null;
- for (int i = 0; i < signatures.length; i++) {
- Class[] signature = signatures[i];
- try {
- m = clazz.getDeclaredMethod(name, signature);
- if (!(isSuper && Modifier.isPrivate(m.getModifiers()))) {
- m.setAccessible(true);
- try {
- m.invoke(object, parameters[i]);
- }
- catch (InvocationTargetException e) {
- m_logger.log(Logger.LOG_ERROR, "Exception while invoking method " + m + ".", e);
- }
- // we did find and invoke the method, so we return true
- return true;
- }
- }
- catch (NoSuchMethodException e) {
- // ignore this and keep looking
- }
- catch (Exception e) {
- // could not even try to invoke the method
- m_logger.log(Logger.LOG_ERROR, "Exception while trying to invoke method " + m + ".", e);
- }
+ catch (Exception e) {
+ m_logger.log(Logger.LOG_DEBUG, "Invocation of '" + methodName + "' failed.", e);
}
- return false;
}
}
Modified: felix/trunk/dependencymanager/core/src/main/java/org/apache/felix/dm/impl/dependencies/ResourceDependencyImpl.java
URL: http://svn.apache.org/viewvc/felix/trunk/dependencymanager/core/src/main/java/org/apache/felix/dm/impl/dependencies/ResourceDependencyImpl.java?rev=930293&r1=930292&r2=930293&view=diff
==============================================================================
--- felix/trunk/dependencymanager/core/src/main/java/org/apache/felix/dm/impl/dependencies/ResourceDependencyImpl.java (original)
+++ felix/trunk/dependencymanager/core/src/main/java/org/apache/felix/dm/impl/dependencies/ResourceDependencyImpl.java Fri Apr 2 15:16:50 2010
@@ -18,9 +18,6 @@
*/
package org.apache.felix.dm.impl.dependencies;
-import java.lang.reflect.InvocationTargetException;
-import java.lang.reflect.Method;
-import java.lang.reflect.Modifier;
import java.util.ArrayList;
import java.util.Dictionary;
import java.util.List;
@@ -33,7 +30,7 @@ import org.apache.felix.dm.resources.Res
import org.osgi.framework.BundleContext;
import org.osgi.framework.ServiceRegistration;
-public class ResourceDependencyImpl implements ResourceDependency, ResourceHandler, DependencyActivation {
+public class ResourceDependencyImpl extends DependencyBase implements ResourceDependency, ResourceHandler, DependencyActivation {
private volatile BundleContext m_context;
private volatile ServiceRegistration m_registration;
// private long m_resourceCounter;
@@ -43,7 +40,6 @@ public class ResourceDependencyImpl impl
private String m_callbackChanged;
private String m_callbackRemoved;
private boolean m_autoConfig;
- private final Logger m_logger;
private String m_autoConfigInstance;
protected List m_services = new ArrayList();
private boolean m_isRequired;
@@ -53,11 +49,10 @@ public class ResourceDependencyImpl impl
private List m_resources = new ArrayList();
private Resource m_resourceInstance;
private boolean m_propagate;
- private boolean m_isInstanceBound;
public ResourceDependencyImpl(BundleContext context, Logger logger) {
+ super(logger);
m_context = context;
- m_logger = logger;
m_autoConfig = true;
}
@@ -65,19 +60,6 @@ public class ResourceDependencyImpl impl
return m_resources.size() > 0;
}
- public boolean isRequired() {
- return m_isRequired;
- }
-
- public boolean isInstanceBound() {
- return m_isInstanceBound;
- }
-
- public ResourceDependency setInstanceBound(boolean isInstanceBound) {
- m_isInstanceBound = isInstanceBound;
- return this;
- }
-
public void start(DependencyService service) {
boolean needsStarting = false;
synchronized (this) {
@@ -178,21 +160,30 @@ public class ResourceDependencyImpl impl
public void invokeAdded(DependencyService ds, Resource serviceInstance) {
Object[] callbackInstances = getCallbackInstances(ds);
if ((callbackInstances != null) && (m_callbackAdded != null)) {
- invokeCallbackMethod(callbackInstances, m_callbackAdded, serviceInstance);
+ invokeCallbackMethod(callbackInstances, m_callbackAdded,
+ new Class[][] {{ Resource.class }, { Object.class }, {}},
+ new Object[][] {{ serviceInstance}, { serviceInstance }, {}}
+ );
}
}
public void invokeChanged(DependencyService ds, Resource serviceInstance) {
Object[] callbackInstances = getCallbackInstances(ds);
if ((callbackInstances != null) && (m_callbackChanged != null)) {
- invokeCallbackMethod(callbackInstances, m_callbackChanged, serviceInstance);
+ invokeCallbackMethod(callbackInstances, m_callbackChanged,
+ new Class[][] {{ Resource.class }, { Object.class }, {}},
+ new Object[][] {{ serviceInstance}, { serviceInstance }, {}}
+ );
}
}
public void invokeRemoved(DependencyService ds, Resource serviceInstance) {
Object[] callbackInstances = getCallbackInstances(ds);
if ((callbackInstances != null) && (m_callbackRemoved != null)) {
- invokeCallbackMethod(callbackInstances, m_callbackRemoved, serviceInstance);
+ invokeCallbackMethod(callbackInstances, m_callbackRemoved,
+ new Class[][] {{ Resource.class }, { Object.class }, {}},
+ new Object[][] {{ serviceInstance}, { serviceInstance }, {}}
+ );
}
}
@@ -300,62 +291,62 @@ public class ResourceDependencyImpl impl
return this;
}
- private void invokeCallbackMethod(Object[] instances, String methodName, Object service) {
- for (int i = 0; i < instances.length; i++) {
- try {
- invokeCallbackMethod(instances[i], methodName, service);
- }
- catch (NoSuchMethodException e) {
- m_logger.log(Logger.LOG_DEBUG, "Method '" + methodName + "' does not exist on " + instances[i] + ". Callback skipped.");
- }
- }
- }
-
- private void invokeCallbackMethod(Object instance, String methodName, Object service) throws NoSuchMethodException {
- Class currentClazz = instance.getClass();
- boolean done = false;
- while (!done && currentClazz != null) {
- done = invokeMethod(instance, currentClazz, methodName,
- new Class[][] {{Resource.class}, {Object.class}, {}},
- new Object[][] {{service}, {service}, {}},
- false);
- if (!done) {
- currentClazz = currentClazz.getSuperclass();
- }
- }
- if (!done && currentClazz == null) {
- throw new NoSuchMethodException(methodName);
- }
- }
-
- private boolean invokeMethod(Object object, Class clazz, String name, Class[][] signatures, Object[][] parameters, boolean isSuper) {
- Method m = null;
- for (int i = 0; i < signatures.length; i++) {
- Class[] signature = signatures[i];
- try {
- m = clazz.getDeclaredMethod(name, signature);
- if (!(isSuper && Modifier.isPrivate(m.getModifiers()))) {
- m.setAccessible(true);
- try {
- m.invoke(object, parameters[i]);
- }
- catch (InvocationTargetException e) {
- m_logger.log(Logger.LOG_ERROR, "Exception while invoking method " + m + ".", e);
- }
- // we did find and invoke the method, so we return true
- return true;
- }
- }
- catch (NoSuchMethodException e) {
- // ignore this and keep looking
- }
- catch (Exception e) {
- // could not even try to invoke the method
- m_logger.log(Logger.LOG_ERROR, "Exception while trying to invoke method " + m + ".", e);
- }
- }
- return false;
- }
+// private void invokeCallbackMethod(Object[] instances, String methodName, Object service) {
+// for (int i = 0; i < instances.length; i++) {
+// try {
+// invokeCallbackMethod(instances[i], methodName, service);
+// }
+// catch (NoSuchMethodException e) {
+// m_logger.log(Logger.LOG_DEBUG, "Method '" + methodName + "' does not exist on " + instances[i] + ". Callback skipped.");
+// }
+// }
+// }
+//
+// private void invokeCallbackMethod(Object instance, String methodName, Object service) throws NoSuchMethodException {
+// Class currentClazz = instance.getClass();
+// boolean done = false;
+// while (!done && currentClazz != null) {
+// done = invokeMethod(instance, currentClazz, methodName,
+// new Class[][] {{Resource.class}, {Object.class}, {}},
+// new Object[][] {{service}, {service}, {}},
+// false);
+// if (!done) {
+// currentClazz = currentClazz.getSuperclass();
+// }
+// }
+// if (!done && currentClazz == null) {
+// throw new NoSuchMethodException(methodName);
+// }
+// }
+//
+// private boolean invokeMethod(Object object, Class clazz, String name, Class[][] signatures, Object[][] parameters, boolean isSuper) {
+// Method m = null;
+// for (int i = 0; i < signatures.length; i++) {
+// Class[] signature = signatures[i];
+// try {
+// m = clazz.getDeclaredMethod(name, signature);
+// if (!(isSuper && Modifier.isPrivate(m.getModifiers()))) {
+// m.setAccessible(true);
+// try {
+// m.invoke(object, parameters[i]);
+// }
+// catch (InvocationTargetException e) {
+// m_logger.log(Logger.LOG_ERROR, "Exception while invoking method " + m + ".", e);
+// }
+// // we did find and invoke the method, so we return true
+// return true;
+// }
+// }
+// catch (NoSuchMethodException e) {
+// // ignore this and keep looking
+// }
+// catch (Exception e) {
+// // could not even try to invoke the method
+// m_logger.log(Logger.LOG_ERROR, "Exception while trying to invoke method " + m + ".", e);
+// }
+// }
+// return false;
+// }
private synchronized Object[] getCallbackInstances(DependencyService ds) {
if (m_callbackInstance == null) {
@@ -373,7 +364,7 @@ public class ResourceDependencyImpl impl
public synchronized ResourceDependency setRequired(boolean required) {
ensureNotActive();
- m_isRequired = required;
+ setIsRequired(required);
return this;
}
@@ -445,4 +436,9 @@ public class ResourceDependencyImpl impl
public boolean isPropagated() {
return m_propagate;
}
+
+ public ResourceDependency setInstanceBound(boolean isInstanceBound) {
+ setIsInstanceBound(isInstanceBound);
+ return this;
+ }
}
Modified: felix/trunk/dependencymanager/core/src/main/java/org/apache/felix/dm/impl/dependencies/ServiceDependencyImpl.java
URL: http://svn.apache.org/viewvc/felix/trunk/dependencymanager/core/src/main/java/org/apache/felix/dm/impl/dependencies/ServiceDependencyImpl.java?rev=930293&r1=930292&r2=930293&view=diff
==============================================================================
--- felix/trunk/dependencymanager/core/src/main/java/org/apache/felix/dm/impl/dependencies/ServiceDependencyImpl.java (original)
+++ felix/trunk/dependencymanager/core/src/main/java/org/apache/felix/dm/impl/dependencies/ServiceDependencyImpl.java Fri Apr 2 15:16:50 2010
@@ -45,7 +45,7 @@ import org.osgi.framework.ServiceReferen
*
* @author <a href="mailto:dev@felix.apache.org">Felix Project Team</a>
*/
-public class ServiceDependencyImpl extends AbstractDependency implements ServiceDependency, ServiceTrackerCustomizer, ServiceComponentDependency {
+public class ServiceDependencyImpl extends DependencyBase implements ServiceDependency, ServiceTrackerCustomizer, ServiceComponentDependency {
protected List m_services = new ArrayList();
protected volatile ServiceTracker m_tracker;
protected BundleContext m_context;
@@ -66,7 +66,6 @@ public class ServiceDependencyImpl exten
private boolean m_autoConfigInvoked;
private Object m_defaultImplementation;
private Object m_defaultImplementationInstance;
- private boolean m_isInstanceBound;
private boolean m_isAvailable;
private static final Comparator COMPARATOR = new Comparator() {
@@ -187,10 +186,6 @@ public class ServiceDependencyImpl exten
return m_isAvailable;
}
- public boolean isInstanceBound() {
- return m_isInstanceBound;
- }
-
public synchronized Object getService() {
Object service = null;
if (m_isStarted) {
@@ -611,7 +606,7 @@ public class ServiceDependencyImpl exten
}
public ServiceDependency setInstanceBound(boolean isInstanceBound) {
- m_isInstanceBound = isInstanceBound;
+ setIsInstanceBound(isInstanceBound);
return this;
}