From e5f27a8f539809437402e659f4fc0c03d79654ed Mon Sep 17 00:00:00 2001 From: Simon Brandhof Date: Fri, 20 Feb 2015 14:43:03 +0100 Subject: [PATCH] Remove useless debug logs --- .../org/sonar/server/search/IndexQueue.java | 19 ++++--------------- 1 file changed, 4 insertions(+), 15 deletions(-) diff --git a/server/sonar-server/src/main/java/org/sonar/server/search/IndexQueue.java b/server/sonar-server/src/main/java/org/sonar/server/search/IndexQueue.java index 1ad5214180d..c29cd525cc9 100644 --- a/server/sonar-server/src/main/java/org/sonar/server/search/IndexQueue.java +++ b/server/sonar-server/src/main/java/org/sonar/server/search/IndexQueue.java @@ -79,31 +79,23 @@ public class IndexQueue implements ServerComponent, WorkQueue> { BulkRequestBuilder bulkRequestBuilder = searchClient.prepareBulk(); - long normTime = processActionsIntoQueries(bulkRequestBuilder, actions); + processActionsIntoQueries(bulkRequestBuilder, actions); if (bulkRequestBuilder.numberOfActions() > 0) { // execute the request - long indexTime = System.currentTimeMillis(); BulkResponse response = bulkRequestBuilder.setRefresh(false).get(); - indexTime = System.currentTimeMillis() - indexTime; - - long refreshTime = 0; if (refreshRequired) { - refreshTime = this.refreshRequiredIndex(indices); + this.refreshRequiredIndex(indices); } - LOGGER.debug("-- submitted {} items with {}ms in normalization, {}ms indexing and {}ms refresh({}). Total: {}ms", - bulkRequestBuilder.numberOfActions(), normTime, indexTime, refreshTime, indices, (normTime + indexTime + refreshTime)); - if (response.hasFailures()) { throw new IllegalStateException("Errors while indexing stack: " + response.buildFailureMessage()); } } } - private long refreshRequiredIndex(Set indices) { - long refreshTime = System.currentTimeMillis(); + private void refreshRequiredIndex(Set indices) { if (!indices.isEmpty()) { RefreshRequestBuilder refreshRequest = searchClient.prepareRefresh(indices.toArray(new String[indices.size()])) .setForce(false); @@ -114,11 +106,9 @@ public class IndexQueue implements ServerComponent, WorkQueue> { LOGGER.warn("{} Shard(s) did not refresh", refreshResponse.getFailedShards()); } } - return System.currentTimeMillis() - refreshTime; } - private long processActionsIntoQueries(BulkRequestBuilder bulkRequestBuilder, List> actions) { - long normTime = System.currentTimeMillis(); + private void processActionsIntoQueries(BulkRequestBuilder bulkRequestBuilder, List> actions) { try { boolean hasInlineRefreshRequest = false; ExecutorService executorService = Executors.newFixedThreadPool(CONCURRENT_NORMALIZATION_FACTOR); @@ -145,7 +135,6 @@ public class IndexQueue implements ServerComponent, WorkQueue> { } catch (Exception e) { throw new IllegalStateException("Could not execute normalization for stack", e); } - return System.currentTimeMillis() - normTime; } private Map getIndexMap() { -- 2.39.5