You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@karaf.apache.org by cs...@apache.org on 2015/04/08 14:57:02 UTC
[2/2] karaf git commit: [KARAF-3102] Small refactoring
[KARAF-3102] Small refactoring
Project: http://git-wip-us.apache.org/repos/asf/karaf/repo
Commit: http://git-wip-us.apache.org/repos/asf/karaf/commit/a265e2bd
Tree: http://git-wip-us.apache.org/repos/asf/karaf/tree/a265e2bd
Diff: http://git-wip-us.apache.org/repos/asf/karaf/diff/a265e2bd
Branch: refs/heads/master
Commit: a265e2bd8c3476ad79205b11715dbcb22405014e
Parents: 8b7f604
Author: Christian Schneider <ch...@die-schneider.net>
Authored: Wed Apr 8 13:03:03 2015 +0200
Committer: Christian Schneider <ch...@die-schneider.net>
Committed: Wed Apr 8 14:56:36 2015 +0200
----------------------------------------------------------------------
.../features/internal/service/Deployer.java | 25 +++++---
.../internal/service/FeaturesServiceImpl.java | 62 +++++++++-----------
2 files changed, 44 insertions(+), 43 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/karaf/blob/a265e2bd/features/core/src/main/java/org/apache/karaf/features/internal/service/Deployer.java
----------------------------------------------------------------------
diff --git a/features/core/src/main/java/org/apache/karaf/features/internal/service/Deployer.java b/features/core/src/main/java/org/apache/karaf/features/internal/service/Deployer.java
index f852fe6..7de999f 100644
--- a/features/core/src/main/java/org/apache/karaf/features/internal/service/Deployer.java
+++ b/features/core/src/main/java/org/apache/karaf/features/internal/service/Deployer.java
@@ -224,19 +224,14 @@ public class Deployer {
for (Iterator<String> iterator = prereqs.iterator(); iterator.hasNext(); ) {
String prereq = iterator.next();
String[] parts = prereq.split("/");
- VersionRange range;
- if (parts[1].equals("0.0.0")) {
- range = VersionRange.ANY_VERSION;
- } else if (!parts[1].startsWith("[") && !parts[1].startsWith("(")) {
- range = new VersionRange(Macro.transform(request.featureResolutionRange, parts[1]));
- } else {
- range = new VersionRange(parts[1]);
- }
+ String name = parts[0];
+ String version = parts[1];
+ VersionRange range = getRange(version, request.featureResolutionRange);
boolean found = false;
for (Set<String> featureSet : dstate.state.installedFeatures.values()) {
for (String feature : featureSet) {
String[] p = feature.split("/");
- found = parts[0].equals(p[0]) && range.contains(VersionTable.getVersion(p[1]));
+ found = name.equals(p[0]) && range.contains(VersionTable.getVersion(p[1]));
if (found) break;
}
if (found) break;
@@ -815,6 +810,18 @@ public class Deployer {
print("Done.", verbose);
}
+ private VersionRange getRange(String version, String featureResolutionRange) {
+ VersionRange range;
+ if (version.equals("0.0.0")) {
+ range = VersionRange.ANY_VERSION;
+ } else if (!version.startsWith("[") && !version.startsWith("(")) {
+ range = new VersionRange(Macro.transform(featureResolutionRange, version));
+ } else {
+ range = new VersionRange(version);
+ }
+ return range;
+ }
+
private void propagateState(Map<Resource, FeaturesService.RequestedState> states, Resource resource, FeaturesService.RequestedState state, SubsystemResolver resolver) {
if (!isSubsystem(resource)) {
FeaturesService.RequestedState reqState = mergeStates(state, states.get(resource));
http://git-wip-us.apache.org/repos/asf/karaf/blob/a265e2bd/features/core/src/main/java/org/apache/karaf/features/internal/service/FeaturesServiceImpl.java
----------------------------------------------------------------------
diff --git a/features/core/src/main/java/org/apache/karaf/features/internal/service/FeaturesServiceImpl.java b/features/core/src/main/java/org/apache/karaf/features/internal/service/FeaturesServiceImpl.java
index e60e40b..2f83605 100644
--- a/features/core/src/main/java/org/apache/karaf/features/internal/service/FeaturesServiceImpl.java
+++ b/features/core/src/main/java/org/apache/karaf/features/internal/service/FeaturesServiceImpl.java
@@ -505,16 +505,8 @@ public class FeaturesServiceImpl implements FeaturesService, Deployer.DeployCall
@Override
public String getRepositoryName(URI uri) throws Exception {
- // Make sure the cache is loaded
- getFeatures();
- synchronized (lock) {
- for (Repository repo : this.repositoryCache.values()) {
- if (repo.getURI().equals(uri)) {
- return repo.getName();
- }
- }
- return null;
- }
+ Repository repo = getRepository(uri);
+ return (repo != null) ? repo.getName() : null;
}
//
@@ -807,15 +799,7 @@ public class FeaturesServiceImpl implements FeaturesService, Deployer.DeployCall
}
}
featuresToAdd = new ArrayList<>(new LinkedHashSet<>(featuresToAdd));
- StringBuilder sb = new StringBuilder();
- sb.append("Adding features: ");
- for (int i = 0; i < featuresToAdd.size(); i++) {
- if (i > 0) {
- sb.append(", ");
- }
- sb.append(featuresToAdd.get(i));
- }
- print(sb.toString(), options.contains(Option.Verbose));
+ print("Adding features: " + join(featuresToAdd), options.contains(Option.Verbose));
Set<String> fl = required.get(region);
if (fl == null) {
fl = new HashSet<>();
@@ -844,6 +828,7 @@ public class FeaturesServiceImpl implements FeaturesService, Deployer.DeployCall
List<String> toRemove = new ArrayList<>();
feature = normalize(feature);
if (feature.endsWith("/0.0.0")) {
+ // Match only on name
String nameSep = "feature:" + feature.substring(0, feature.indexOf("/") + 1);
for (String f : fl) {
Pattern pattern = Pattern.compile(nameSep.substring(0, nameSep.length() - 1));
@@ -853,15 +838,11 @@ public class FeaturesServiceImpl implements FeaturesService, Deployer.DeployCall
}
}
} else {
+ // Match on name and version
String name = feature.substring(0, feature.indexOf("/"));
String version = feature.substring(feature.indexOf("/") + 1);
+ Pattern pattern = getFeaturePattern(name, version);
for (String f : fl) {
- String req = "feature:" + name + "/" + new VersionRange(version, true);
- req = req.replace("[", "\\[");
- req = req.replace("(", "\\(");
- req = req.replace("]", "\\]");
- req = req.replace(")", "\\)");
- Pattern pattern = Pattern.compile(req);
Matcher matcher = pattern.matcher(f);
if (matcher.matches()) {
toRemove.add(f);
@@ -876,15 +857,7 @@ public class FeaturesServiceImpl implements FeaturesService, Deployer.DeployCall
featuresToRemove.addAll(toRemove);
}
featuresToRemove = new ArrayList<>(new LinkedHashSet<>(featuresToRemove));
- StringBuilder sb = new StringBuilder();
- sb.append("Removing features: ");
- for (int i = 0; i < featuresToRemove.size(); i++) {
- if (i > 0) {
- sb.append(", ");
- }
- sb.append(featuresToRemove.get(i));
- }
- print(sb.toString(), options.contains(Option.Verbose));
+ print("Removing features: " + join(featuresToRemove), options.contains(Option.Verbose));
fl.removeAll(featuresToRemove);
if (fl.isEmpty()) {
required.remove(region);
@@ -1281,4 +1254,25 @@ public class FeaturesServiceImpl implements FeaturesService, Deployer.DeployCall
}
digraph.replace(temp);
}
+
+ private Pattern getFeaturePattern(String name, String version) {
+ String req = "feature:" + name + "/" + new VersionRange(version, true);
+ req = req.replace("[", "\\[");
+ req = req.replace("(", "\\(");
+ req = req.replace("]", "\\]");
+ req = req.replace(")", "\\)");
+ Pattern pattern = Pattern.compile(req);
+ return pattern;
+ }
+
+ private String join(List<String> list) {
+ StringBuilder sb = new StringBuilder();
+ for (int i = 0; i < list.size(); i++) {
+ if (i > 0) {
+ sb.append(", ");
+ }
+ sb.append(list.get(i));
+ }
+ return sb.toString();
+ }
}