diff options
author | Jon Bratseth <bratseth@oath.com> | 2021-05-17 22:59:24 +0200 |
---|---|---|
committer | GitHub <noreply@github.com> | 2021-05-17 22:59:24 +0200 |
commit | db693286334d5966fb7e4a7d4549a6f9349fe6fa (patch) | |
tree | 20b813c4addf7c13ac71b232724468fcdf7d253d | |
parent | 8f41a717d44906dad622b555cbf6a08156cff161 (diff) | |
parent | 38d447ad818c8e0183325db5751635fece76989b (diff) |
Merge pull request #17870 from vespa-engine/balder/use-thread-safe-remove
Balder/use thread safe remove
-rw-r--r-- | config-model/src/main/java/com/yahoo/searchdefinition/derived/SummaryClassField.java | 16 | ||||
-rw-r--r-- | documentapi/src/main/java/com/yahoo/documentapi/messagebus/protocol/ContentPolicy.java | 6 |
2 files changed, 17 insertions, 5 deletions
diff --git a/config-model/src/main/java/com/yahoo/searchdefinition/derived/SummaryClassField.java b/config-model/src/main/java/com/yahoo/searchdefinition/derived/SummaryClassField.java index 4375b446e98..c0093e031d1 100644 --- a/config-model/src/main/java/com/yahoo/searchdefinition/derived/SummaryClassField.java +++ b/config-model/src/main/java/com/yahoo/searchdefinition/derived/SummaryClassField.java @@ -5,7 +5,19 @@ import com.yahoo.document.CollectionDataType; import com.yahoo.document.DataType; import com.yahoo.document.MapDataType; import com.yahoo.document.ReferenceDataType; -import com.yahoo.document.datatypes.*; +import com.yahoo.document.datatypes.BoolFieldValue; +import com.yahoo.document.datatypes.ByteFieldValue; +import com.yahoo.document.datatypes.DoubleFieldValue; +import com.yahoo.document.datatypes.FieldValue; +import com.yahoo.document.datatypes.Float16FieldValue; +import com.yahoo.document.datatypes.FloatFieldValue; +import com.yahoo.document.datatypes.IntegerFieldValue; +import com.yahoo.document.datatypes.LongFieldValue; +import com.yahoo.document.datatypes.PredicateFieldValue; +import com.yahoo.document.datatypes.Raw; +import com.yahoo.document.datatypes.StringFieldValue; +import com.yahoo.document.datatypes.Struct; +import com.yahoo.document.datatypes.TensorFieldValue; import com.yahoo.vespa.documentmodel.SummaryTransform; /** @@ -39,7 +51,7 @@ public class SummaryClassField { JSONSTRING("jsonstring"), TENSOR("tensor"); - private String name; + private final String name; Type(String name) { this.name = name; diff --git a/documentapi/src/main/java/com/yahoo/documentapi/messagebus/protocol/ContentPolicy.java b/documentapi/src/main/java/com/yahoo/documentapi/messagebus/protocol/ContentPolicy.java index f8e6989bbfa..792d3628ba0 100644 --- a/documentapi/src/main/java/com/yahoo/documentapi/messagebus/protocol/ContentPolicy.java +++ b/documentapi/src/main/java/com/yahoo/documentapi/messagebus/protocol/ContentPolicy.java @@ -108,13 +108,13 @@ public class ContentPolicy extends SlobrokPolicy { while ((targets.total != 0) && (100 * targets.list.size() / targets.total >= requiredUpPercentageToSendToKnownGoodNodes)) { - int randIndex = randomizer.nextInt(targets.list.size()); - String targetSpec = getTargetSpec(targets.list.get(randIndex), context); + Integer distributor = targets.list.get(randomizer.nextInt(targets.list.size())); + String targetSpec = getTargetSpec(distributor, context); if (targetSpec != null) { context.trace(3, "Sending to random node seen up in cluster state"); return targetSpec; } - targets.list.remove(randIndex); + targets.list.remove(distributor); } context.trace(3, "Too few nodes seen up in state. Sending totally random."); return getTargetSpec(null, context); |