eliminate dup code

spotify · Dec 18, 2020 · fcf7e6b · fcf7e6b
1 parent c4568c7
commit fcf7e6b
Showing 1 changed file with 14 additions and 20 deletions.
diff --git a/...sticsearch/src/main/java/com/spotify/heroic/metadata/elasticsearch/MetadataBackendKV.java b/...sticsearch/src/main/java/com/spotify/heroic/metadata/elasticsearch/MetadataBackendKV.java
@@ -236,27 +236,21 @@ public AsyncFuture<WriteMetadata> write(
                 try (Scope ignored = tracer.withSpan(span)) {
                     span.putAttribute("index", AttributeValue.stringAttributeValue(index));
 
-                    if (indexResourceIdentifiers) {
-                        if (!writeCache.acquire(Pair.of(index, series.getHashCode()),
-                            reporter::reportWriteDroppedByCacheHit)) {
-                            span.setStatus(
-                                Status
-                                    .ALREADY_EXISTS
-                                    .withDescription("Write dropped by cache hit"));
-                            span.end();
-                            continue;
-                        }
-                    } else {
-                        if (!writeCache.acquire(Pair.of(index, series.getHashCodeTagOnly()),
-                            reporter::reportWriteDroppedByCacheHit)) {
-                            span.setStatus(
-                                Status
-                                    .ALREADY_EXISTS
-                                    .withDescription("Write dropped by cache hit"));
-                            span.end();
-                            continue;
-                        }
+                    HashCode hc =
+                        indexResourceIdentifiers ?
+                            series.getHashCode() :
+                            series.getHashCodeTagOnly();
+
+                    if (!writeCache.acquire(Pair.of(index, hc),
+                        reporter::reportWriteDroppedByCacheHit)) {
+                        span.setStatus(
+                            Status
+                                .ALREADY_EXISTS
+                                .withDescription("Write dropped by cache hit"));
+                        span.end();
+                        continue;
                     }
+
                     indexSpans.add(span);
 
                     final XContentBuilder source = XContentFactory.jsonBuilder();