Skip to content

Commit

Permalink
0.19.9 no longer supports /_all/_status, closes elastic#2205.
Browse files Browse the repository at this point in the history
  • Loading branch information
kimchy authored and martijnvg committed Aug 27, 2012
1 parent 16d5433 commit 40e3a5d
Showing 1 changed file with 8 additions and 18 deletions.
26 changes: 8 additions & 18 deletions src/main/java/org/elasticsearch/cluster/metadata/MetaData.java
Original file line number Diff line number Diff line change
Expand Up @@ -347,18 +347,14 @@ public Map<String, Set<String>> resolveSearchRouting(@Nullable String routing, S
}

public Map<String, Set<String>> resolveSearchRouting(@Nullable String routing, String[] aliasesOrIndices) {
if (aliasesOrIndices == null || aliasesOrIndices.length == 0) {
if (isAllIndices(aliasesOrIndices)) {
return resolveSearchRoutingAllIndices(routing);
}

aliasesOrIndices = convertFromWildcards(aliasesOrIndices, true, IgnoreIndices.MISSING);

if (aliasesOrIndices.length == 1) {
if (aliasesOrIndices[0].equals("_all")) {
return resolveSearchRoutingAllIndices(routing);
} else {
return resolveSearchRoutingSingleValue(routing, aliasesOrIndices[0]);
}
return resolveSearchRoutingSingleValue(routing, aliasesOrIndices[0]);
}

Map<String, Set<String>> routings = null;
Expand Down Expand Up @@ -512,19 +508,13 @@ public String[] concreteIndicesIgnoreMissing(String[] indices) {
* Translates the provided indices (possibly aliased) into actual indices.
*/
public String[] concreteIndices(String[] aliasesOrIndices, IgnoreIndices ignoreIndices, boolean allOnlyOpen) throws IndexMissingException {
if (aliasesOrIndices == null || aliasesOrIndices.length == 0) {
if (isAllIndices(aliasesOrIndices)) {
return allOnlyOpen ? concreteAllOpenIndices() : concreteAllIndices();
}
aliasesOrIndices = convertFromWildcards(aliasesOrIndices, allOnlyOpen, ignoreIndices);
// optimize for single element index (common case)
if (aliasesOrIndices.length == 1) {
String aliasOrIndex = aliasesOrIndices[0];
if (aliasOrIndex.length() == 0) {
return allOnlyOpen ? concreteAllOpenIndices() : concreteAllIndices();
}
if (aliasOrIndex.equals("_all")) {
return allOnlyOpen ? concreteAllOpenIndices() : concreteAllIndices();
}
// if a direct index name, just return the array provided
if (this.indices.containsKey(aliasOrIndex)) {
return aliasesOrIndices;
Expand Down Expand Up @@ -710,16 +700,12 @@ public int getTotalNumberOfShards() {
* the index itself - null is returned. Returns <tt>null</tt> if no filtering is required.</p>
*/
public String[] filteringAliases(String index, String... indices) {
if (indices == null || indices.length == 0) {
if (isAllIndices(indices)) {
return null;
}
// optimize for the most common single index/alias scenario
if (indices.length == 1) {
String alias = indices[0];
// This list contains "_all" - no filtering needed
if (alias.equals("_all")) {
return null;
}
ImmutableMap<String, Boolean> aliasToFilteringRequiredMap = indexToAliasFilteringRequiredMap.get(index);
if (aliasToFilteringRequiredMap == null) {
// Shouldn't happen
Expand Down Expand Up @@ -760,6 +746,10 @@ public String[] filteringAliases(String index, String... indices) {
return filteringAliases.toArray(new String[filteringAliases.size()]);
}

private boolean isAllIndices(String[] aliasesOrIndices) {
return (aliasesOrIndices == null || aliasesOrIndices.length == 0 || (aliasesOrIndices.length == 1 && "_all".equals(aliasesOrIndices[0])));
}


@Override
public UnmodifiableIterator<IndexMetaData> iterator() {
Expand Down

0 comments on commit 40e3a5d

Please sign in to comment.