From: Simon Brandhof Date: Fri, 20 Feb 2015 13:43:03 +0000 (+0100) Subject: Remove useless debug logs X-Git-Tag: 5.1-RC1~136 X-Git-Url: https://source.dussan.org/?a=commitdiff_plain;h=e5f27a8f539809437402e659f4fc0c03d79654ed;p=sonarqube.git Remove useless debug logs --- 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() {