From fc1d6670dfc9999ae9d626fd5d431fc5ffe4e00f Mon Sep 17 00:00:00 2001 From: Luca Cavanna Date: Mon, 2 Sep 2013 12:16:14 +0200 Subject: [PATCH] Added log lines to log (debug level) acknowledgements regarding index alias creation and index state change --- .../cluster/metadata/MetaDataIndexAliasesService.java | 3 ++- .../cluster/metadata/MetaDataIndexStateService.java | 3 ++- 2 files changed, 4 insertions(+), 2 deletions(-) diff --git a/src/main/java/org/elasticsearch/cluster/metadata/MetaDataIndexAliasesService.java b/src/main/java/org/elasticsearch/cluster/metadata/MetaDataIndexAliasesService.java index 6ceaa111e58..b9518de346b 100644 --- a/src/main/java/org/elasticsearch/cluster/metadata/MetaDataIndexAliasesService.java +++ b/src/main/java/org/elasticsearch/cluster/metadata/MetaDataIndexAliasesService.java @@ -257,10 +257,11 @@ public class MetaDataIndexAliasesService extends AbstractComponent { @Override public void onAliasesUpdated(NodeAliasesUpdatedAction.NodeAliasesUpdatedResponse response) { if (version <= response.version()) { - logger.trace("Received NodeAliasesUpdatedResponse with version [{}] from [{}]", response.version(), response.nodeId()); + logger.debug("Received NodeAliasesUpdatedResponse with version [{}] from [{}]", response.version(), response.nodeId()); if (countDown.decrementAndGet() == 0) { aliasOperationPerformedAction.remove(this); if (notified.compareAndSet(false, true)) { + logger.debug("NodeAliasUpdated was acknowledged by all expected nodes, returning"); listener.onResponse(new Response(true)); } } diff --git a/src/main/java/org/elasticsearch/cluster/metadata/MetaDataIndexStateService.java b/src/main/java/org/elasticsearch/cluster/metadata/MetaDataIndexStateService.java index ee433e388d6..5cecca57232 100644 --- a/src/main/java/org/elasticsearch/cluster/metadata/MetaDataIndexStateService.java +++ b/src/main/java/org/elasticsearch/cluster/metadata/MetaDataIndexStateService.java @@ -288,10 +288,11 @@ public class MetaDataIndexStateService extends AbstractComponent { @Override public void onIndexStateUpdated(NodeIndicesStateUpdatedAction.NodeIndexStateUpdatedResponse response) { if (version <= response.version()) { - logger.trace("Received NodeIndexStateUpdatedResponse with version [{}] from [{}]", response.version(), response.nodeId()); + logger.debug("Received NodeIndexStateUpdatedResponse with version [{}] from [{}]", response.version(), response.nodeId()); if (countDown.decrementAndGet() == 0) { indicesStateUpdatedAction.remove(this); if (notified.compareAndSet(false, true)) { + logger.debug("NodeIndexStateUpdated was acknowledged by all expected nodes, returning"); listener.onResponse(new Response(true)); } }