X-Git-Url: http://git.argeo.org/?a=blobdiff_plain;ds=inline;f=runtime%2Forg.argeo.slc.support.osgi%2Fsrc%2Fmain%2Fjava%2Forg%2Fargeo%2Fslc%2Fosgi%2FBundlesManager.java;h=7d96ae4c9e6d5487e7dddae839cc4716dae452fe;hb=e153254668834a28b10411febed79bb2a07bae7b;hp=3d6510d147bb051e0348bf631b8117f7d60d222a;hpb=aee87eeef820af87f18c2cf2e9b86b612393f7db;p=gpl%2Fargeo-slc.git

diff --git a/runtime/org.argeo.slc.support.osgi/src/main/java/org/argeo/slc/osgi/BundlesManager.java b/runtime/org.argeo.slc.support.osgi/src/main/java/org/argeo/slc/osgi/BundlesManager.java
index 3d6510d14..7d96ae4c9 100644
--- a/runtime/org.argeo.slc.support.osgi/src/main/java/org/argeo/slc/osgi/BundlesManager.java
+++ b/runtime/org.argeo.slc.support.osgi/src/main/java/org/argeo/slc/osgi/BundlesManager.java
@@ -1,5 +1,5 @@
 /*
- * Copyright (C) 2010 Mathieu Baudier <mbaudier@argeo.org>
+ * Copyright (C) 2007-2012 Mathieu Baudier
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
@@ -13,7 +13,6 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-
 package org.argeo.slc.osgi;
 
 import org.apache.commons.logging.Log;
@@ -49,7 +48,7 @@ public class BundlesManager implements BundleContextAware, FrameworkListener,
 
 	private BundleContext bundleContext;
 
-	private Long defaultTimeout = 120 * 1000l;
+	private Long defaultTimeout = 30 * 1000l;
 	private Long pollingPeriod = 200l;
 
 	// Refresh sync objects
@@ -268,7 +267,7 @@ public class BundlesManager implements BundleContextAware, FrameworkListener,
 		try {
 			Thread.sleep(pollingPeriod);
 		} catch (InterruptedException e) {
-			// silent
+			throw new SlcException("Polling interrupted");
 		}
 	}
 
@@ -304,15 +303,20 @@ public class BundlesManager implements BundleContextAware, FrameworkListener,
 		return (T) bundleContext.getService(sfs[0]);
 	}
 
-	public <T> T getSingleServiceStrict(Class<T> clss, String filter) {
-		T service = getSingleService(clss, filter, true);
+	public <T> T getSingleServiceStrict(Class<T> clss, String filter,
+			Boolean synchronous) {
+		T service = getSingleService(clss, filter, synchronous);
 		if (service == null)
 			throw new SlcException("No execution flow found for " + filter);
 		else
 			return service;
 	}
 
-	/** @return the related bundle or null if not found */
+	/**
+	 * @param osgiBundle
+	 *            cannot be null
+	 * @return the related bundle or null if not found
+	 */
 	public Bundle findRelatedBundle(OsgiBundle osgiBundle) {
 		Bundle bundle = null;
 		if (osgiBundle.getInternalBundleId() != null) {
@@ -326,7 +330,8 @@ public class BundlesManager implements BundleContextAware, FrameworkListener,
 								bundle.getHeaders().get(
 										Constants.BUNDLE_VERSION)),
 						"version consistent");
-		} else if (osgiBundle.getVersion() == null) {
+		} else if (osgiBundle.getVersion() == null
+				|| osgiBundle.getVersion().equals("0.0.0")) {
 			bundle = OsgiBundleUtils.findBundleBySymbolicName(bundleContext,
 					osgiBundle.getName());
 		} else {// scan all bundles
@@ -387,8 +392,11 @@ public class BundlesManager implements BundleContextAware, FrameworkListener,
 		this.defaultTimeout = defaultTimeout;
 	}
 
-	/** Temporary internal access for {@link OsgiExecutionModulesManager} */
-	BundleContext getBundleContext() {
+	/**
+	 * Use with caution since it may interfer with some cached information
+	 * within this object
+	 */
+	public BundleContext getBundleContext() {
 		return bundleContext;
 	}