make sure we update last failure

This commit is contained in:
Shay Banon 2013-07-23 10:54:34 +02:00
parent aa5c15a1d7
commit f9ce791578
1 changed files with 1 additions and 0 deletions

View File

@ -124,6 +124,7 @@ public class TransportDeleteIndexAction extends TransportMasterNodeOperationActi
@Override @Override
public void onFailure(Throwable t) { public void onFailure(Throwable t) {
logger.debug("[{}] failed to delete index", t, index); logger.debug("[{}] failed to delete index", t, index);
lastFailure = t;
if (count.decrementAndGet() == 0) { if (count.decrementAndGet() == 0) {
listener.onFailure(t); listener.onFailure(t);
} }