You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@karaf.apache.org by jb...@apache.org on 2012/10/25 15:52:21 UTC
svn commit: r1402152 - in
/karaf/cellar/branches/cellar-2.3.x/bundle/src/main/java/org/apache/karaf/cellar/bundle:
LocalBundleListener.java shell/ListBundleCommand.java
Author: jbonofre
Date: Thu Oct 25 13:52:20 2012
New Revision: 1402152
URL: http://svn.apache.org/viewvc?rev=1402152&view=rev
Log:
[KARAF-1974] Fix bundle state in the distributed map
Modified:
karaf/cellar/branches/cellar-2.3.x/bundle/src/main/java/org/apache/karaf/cellar/bundle/LocalBundleListener.java
karaf/cellar/branches/cellar-2.3.x/bundle/src/main/java/org/apache/karaf/cellar/bundle/shell/ListBundleCommand.java
Modified: karaf/cellar/branches/cellar-2.3.x/bundle/src/main/java/org/apache/karaf/cellar/bundle/LocalBundleListener.java
URL: http://svn.apache.org/viewvc/karaf/cellar/branches/cellar-2.3.x/bundle/src/main/java/org/apache/karaf/cellar/bundle/LocalBundleListener.java?rev=1402152&r1=1402151&r2=1402152&view=diff
==============================================================================
--- karaf/cellar/branches/cellar-2.3.x/bundle/src/main/java/org/apache/karaf/cellar/bundle/LocalBundleListener.java (original)
+++ karaf/cellar/branches/cellar-2.3.x/bundle/src/main/java/org/apache/karaf/cellar/bundle/LocalBundleListener.java Thu Oct 25 13:52:20 2012
@@ -67,13 +67,17 @@ public class LocalBundleListener extends
// update the cluster map
Map<String, BundleState> bundles = clusterManager.getMap(Constants.BUNDLE_MAP + Configurations.SEPARATOR + group.getName());
- BundleState state = bundles.get(symbolicName + "/" + version);
- if (state == null) {
- state = new BundleState();
+ if (type== BundleEvent.UNINSTALLED) {
+ bundles.remove(symbolicName + "/" + version);
+ } else {
+ BundleState state = bundles.get(symbolicName + "/" + version);
+ if (state == null) {
+ state = new BundleState();
+ }
+ state.setStatus(event.getBundle().getState());
+ state.setLocation(event.getBundle().getLocation());
+ bundles.put(symbolicName + "/" + version, state);
}
- state.setStatus(event.getBundle().getState());
- state.setLocation(event.getBundle().getLocation());
- bundles.put(symbolicName + "/" + version, state);
// broadcast the cluster event
RemoteBundleEvent remoteBundleEvent = new RemoteBundleEvent(symbolicName, version, bundleLocation, type);
Modified: karaf/cellar/branches/cellar-2.3.x/bundle/src/main/java/org/apache/karaf/cellar/bundle/shell/ListBundleCommand.java
URL: http://svn.apache.org/viewvc/karaf/cellar/branches/cellar-2.3.x/bundle/src/main/java/org/apache/karaf/cellar/bundle/shell/ListBundleCommand.java?rev=1402152&r1=1402151&r2=1402152&view=diff
==============================================================================
--- karaf/cellar/branches/cellar-2.3.x/bundle/src/main/java/org/apache/karaf/cellar/bundle/shell/ListBundleCommand.java (original)
+++ karaf/cellar/branches/cellar-2.3.x/bundle/src/main/java/org/apache/karaf/cellar/bundle/shell/ListBundleCommand.java Thu Oct 25 13:52:20 2012
@@ -67,13 +67,13 @@ public class ListBundleCommand extends C
status = "Resolved";
break;
case BundleEvent.STARTED:
- status = "Started";
+ status = "Active";
break;
case BundleEvent.STARTING:
status = "Starting";
break;
case BundleEvent.STOPPED:
- status = "Stopped";
+ status = "Resolved";
break;
case BundleEvent.STOPPING:
status = "Stopping";